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

DEFAULT_BLOCK_SIZE, inputBuffer, MAX_BLOCK_SIZE, MIN_BLOCK_SIZE, out, outputBuffer

Constructor Summary

Constructors

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

Method Summary

Modifier and Type	Method and 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

write

Methods inherited from class java.lang.Object

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

Constructor Detail

SnappyHadoopCompatibleOutputStream

public SnappyHadoopCompatibleOutputStream(OutputStream out)

SnappyHadoopCompatibleOutputStream

public SnappyHadoopCompatibleOutputStream(OutputStream out,
                                          int blockSize)

Method Detail

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