public final class SnappyFramedOutputStream extends AbstractSnappyOutputStream
OutputStream
.Modifier and Type | Field and Description |
---|---|
static int |
DEFAULT_BLOCK_SIZE |
static double |
DEFAULT_MIN_COMPRESSION_RATIO |
static int |
MAX_BLOCK_SIZE
We place an additional restriction that the uncompressed data in
a chunk must be no longer than 65536 bytes.
|
Constructor and Description |
---|
SnappyFramedOutputStream(java.io.OutputStream out) |
SnappyFramedOutputStream(java.io.OutputStream out,
int blockSize,
double minCompressionRatio) |
Modifier and Type | Method and Description |
---|---|
protected void |
writeBlock(java.io.OutputStream out,
byte[] data,
int offset,
int length,
boolean compressed,
int crc32c)
Each chunk consists first a single byte of chunk identifier, then a
three-byte little-endian length of the chunk in bytes (from 0 to
16777215, inclusive), and then the data if any.
|
protected void |
writeHeader(java.io.OutputStream out)
Writes the implementation specific header or "marker bytes" to
out.
|
calculateCRC32C, close, flush, write, write
public static final int MAX_BLOCK_SIZE
public static final int DEFAULT_BLOCK_SIZE
public static final double DEFAULT_MIN_COMPRESSION_RATIO
public SnappyFramedOutputStream(java.io.OutputStream out) throws java.io.IOException
java.io.IOException
public SnappyFramedOutputStream(java.io.OutputStream out, int blockSize, double minCompressionRatio) throws java.io.IOException
java.io.IOException
protected void writeHeader(java.io.OutputStream out) throws java.io.IOException
AbstractSnappyOutputStream
writeHeader
in class AbstractSnappyOutputStream
out
- The underlying OutputStream
.java.io.IOException
protected void writeBlock(java.io.OutputStream out, byte[] data, int offset, int length, boolean compressed, int crc32c) throws java.io.IOException
writeBlock
in class AbstractSnappyOutputStream
out
- The OutputStream
to write to.data
- The data to write.offset
- The offset in data to start at.length
- The length of data to use.compressed
- Indicates if data is the compressed or raw content.
This is based on whether the compression ratio desired is
reached.crc32c
- The calculated checksum.java.io.IOException