Package org.xerial.snappy

Class SnappyHadoopCompatibleOutputStream

java.lang.Object

java.io.OutputStream

org.xerial.snappy.SnappyOutputStream

org.xerial.snappy.SnappyHadoopCompatibleOutputStream

All Implemented Interfaces:

Closeable, Flushable, AutoCloseable

public class SnappyHadoopCompatibleOutputStream
extends SnappyOutputStream

Field Summary

Fields inherited from class org.xerial.snappy.SnappyOutputStream

inputBuffer, MAX_BLOCK_SIZE, out, outputBuffer

Constructor Summary

Constructors

Constructor	Description
SnappyHadoopCompatibleOutputStream(OutputStream out)
SnappyHadoopCompatibleOutputStream(OutputStream out, int blockSize)

Method Summary

Modifier and Type	Method	Description
protected void	writeBlockPreemble()	Optionally write a preemble before a block.
protected int	writeHeader()

Methods inherited from class org.xerial.snappy.SnappyOutputStream

close, compressInput, dumpOutput, flush, rawWrite, write, write, write, write, write, write, write, write, write, write, write, write, writeCurrentDataSize

Methods inherited from class java.io.OutputStream

nullOutputStream, write

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Details

SnappyHadoopCompatibleOutputStream

public SnappyHadoopCompatibleOutputStream(OutputStream out)

SnappyHadoopCompatibleOutputStream

public SnappyHadoopCompatibleOutputStream(OutputStream out,
 int blockSize)

Method Details

writeHeader

protected int writeHeader()

Overrides:

writeHeader in class SnappyOutputStream

writeBlockPreemble

protected void writeBlockPreemble()

Description copied from class: SnappyOutputStream

Optionally write a preemble before a block. Hadoop requires the actual block data size being written. This base implementation does nothing. Derive implementation can call writeCurrentDataSize().

Overrides:

writeBlockPreemble in class SnappyOutputStream