public class SnappyOutputStream extends OutputStream
The input data is blocked into 32kb size (in default), and each block is
compressed and then passed to the given OutputStream
.
SnappyCodec
(8 bytes)
SnappyOutputStream
cannot be
uncompressed by Snappy.uncompress(byte[])
since the output formats of
Snappy.compress(byte[])
and SnappyOutputStream
are different.
Use SnappyInputStream
for uncompress the data generated by
SnappyOutputStream
.Modifier and Type | Field and Description |
---|---|
protected byte[] |
inputBuffer |
static int |
MAX_BLOCK_SIZE |
protected OutputStream |
out |
protected byte[] |
outputBuffer |
Constructor and Description |
---|
SnappyOutputStream(OutputStream out) |
SnappyOutputStream(OutputStream out,
int blockSize) |
SnappyOutputStream(OutputStream out,
int blockSize,
BufferAllocatorFactory bufferAllocatorFactory) |
Modifier and Type | Method and Description |
---|---|
void |
close()
close the stream
|
protected void |
compressInput() |
protected void |
dumpOutput() |
void |
flush() |
void |
rawWrite(Object array,
int byteOffset,
int byteLength)
Compress the raw byte array data.
|
void |
write(byte[] b,
int byteOffset,
int byteLength) |
void |
write(double[] f)
Compress the input array data
|
void |
write(double[] f,
int off,
int len)
Compress the input double array data
|
void |
write(float[] f)
Compress the input array data
|
void |
write(float[] f,
int off,
int len)
Compress the input float array data
|
void |
write(int b)
Writes the specified byte to this output stream.
|
void |
write(int[] f)
Compress the input array data
|
void |
write(int[] f,
int off,
int len)
Compress the input int array data
|
void |
write(long[] d)
Compress the input array data
|
void |
write(long[] d,
int off,
int len)
Compress the input long array data
|
void |
write(short[] f)
Compress the input array data
|
void |
write(short[] f,
int off,
int len)
Compress the input short array data
|
write
public static final int MAX_BLOCK_SIZE
protected final OutputStream out
protected byte[] inputBuffer
protected byte[] outputBuffer
public SnappyOutputStream(OutputStream out)
public SnappyOutputStream(OutputStream out, int blockSize)
out
- blockSize
- byte size of the internal buffer sizeIllegalArgumentException
- when blockSize is larger than 512 MiBpublic SnappyOutputStream(OutputStream out, int blockSize, BufferAllocatorFactory bufferAllocatorFactory)
public void write(byte[] b, int byteOffset, int byteLength) throws IOException
write
in class OutputStream
IOException
public void write(long[] d, int off, int len) throws IOException
d
- input arrayoff
- offset in the arraylen
- the number of elements in the array to copyIOException
public void write(double[] f, int off, int len) throws IOException
f
- input arrayoff
- offset in the arraylen
- the number of elements in the array to copyIOException
public void write(float[] f, int off, int len) throws IOException
f
- input arrayoff
- offset in the arraylen
- the number of elements in the array to copyIOException
public void write(int[] f, int off, int len) throws IOException
f
- input arrayoff
- offset in the arraylen
- the number of elements in the array to copyIOException
public void write(short[] f, int off, int len) throws IOException
f
- input arrayoff
- offset in the arraylen
- the number of elements in the array to copyIOException
public void write(long[] d) throws IOException
d
- IOException
public void write(double[] f) throws IOException
f
- IOException
public void write(float[] f) throws IOException
f
- IOException
public void write(int[] f) throws IOException
f
- IOException
public void write(short[] f) throws IOException
f
- IOException
public void rawWrite(Object array, int byteOffset, int byteLength) throws IOException
array
- array data of any type (e.g., byte[], float[], long[], ...)byteOffset
- byteLength
- IOException
public void write(int b) throws IOException
write
in class OutputStream
IOException
public void flush() throws IOException
flush
in interface Flushable
flush
in class OutputStream
IOException
protected void dumpOutput() throws IOException
IOException
protected void compressInput() throws IOException
IOException
public void close() throws IOException
close
in interface Closeable
close
in interface AutoCloseable
close
in class OutputStream
IOException
Copyright © 2011–2023 xerial.org. All rights reserved.