Class FramedSnappyCompressorInputStream
- java.lang.Object
-
- java.io.InputStream
-
- org.apache.commons.compress.compressors.CompressorInputStream
-
- org.apache.commons.compress.compressors.snappy.FramedSnappyCompressorInputStream
-
- All Implemented Interfaces:
java.io.Closeable
,java.lang.AutoCloseable
,InputStreamStatistics
public class FramedSnappyCompressorInputStream extends CompressorInputStream implements InputStreamStatistics
CompressorInputStream for the framing Snappy format.Based on the "spec" in the version "Last revised: 2013-10-25"
- Since:
- 1.7
- See Also:
- Snappy framing format description
-
-
Constructor Summary
Constructors Constructor Description FramedSnappyCompressorInputStream(java.io.InputStream in)
Constructs a new input stream that decompresses snappy-framed-compressed data from the specified input stream using theFramedSnappyDialect.STANDARD
dialect.FramedSnappyCompressorInputStream(java.io.InputStream in, int blockSize, FramedSnappyDialect dialect)
Constructs a new input stream that decompresses snappy-framed-compressed data from the specified input stream.FramedSnappyCompressorInputStream(java.io.InputStream in, FramedSnappyDialect dialect)
Constructs a new input stream that decompresses snappy-framed-compressed data from the specified input stream.
-
Method Summary
All Methods Static Methods Instance Methods Concrete Methods Modifier and Type Method Description int
available()
void
close()
long
getCompressedCount()
Gets the amount of raw or compressed bytes read by the stream.static boolean
matches(byte[] signature, int length)
Checks if the signature matches what is expected for a .sz file.int
read()
int
read(byte[] b, int off, int len)
-
Methods inherited from class org.apache.commons.compress.compressors.CompressorInputStream
getBytesRead, getCount, getUncompressedCount
-
Methods inherited from class java.io.InputStream
mark, markSupported, nullInputStream, read, readAllBytes, readNBytes, readNBytes, reset, skip, transferTo
-
Methods inherited from class java.lang.Object
equals, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
-
Methods inherited from interface org.apache.commons.compress.utils.InputStreamStatistics
getUncompressedCount
-
-
-
-
Constructor Detail
-
FramedSnappyCompressorInputStream
public FramedSnappyCompressorInputStream(java.io.InputStream in) throws java.io.IOException
Constructs a new input stream that decompresses snappy-framed-compressed data from the specified input stream using theFramedSnappyDialect.STANDARD
dialect.- Parameters:
in
- the InputStream from which to read the compressed data- Throws:
java.io.IOException
- if reading fails
-
FramedSnappyCompressorInputStream
public FramedSnappyCompressorInputStream(java.io.InputStream in, FramedSnappyDialect dialect) throws java.io.IOException
Constructs a new input stream that decompresses snappy-framed-compressed data from the specified input stream.- Parameters:
in
- the InputStream from which to read the compressed datadialect
- the dialect used by the compressed stream- Throws:
java.io.IOException
- if reading fails
-
FramedSnappyCompressorInputStream
public FramedSnappyCompressorInputStream(java.io.InputStream in, int blockSize, FramedSnappyDialect dialect) throws java.io.IOException
Constructs a new input stream that decompresses snappy-framed-compressed data from the specified input stream.- Parameters:
in
- the InputStream from which to read the compressed datablockSize
- the block size to use for the compressed streamdialect
- the dialect used by the compressed stream- Throws:
java.io.IOException
- if reading failsjava.lang.IllegalArgumentException
- if blockSize is not bigger than 0- Since:
- 1.14
-
-
Method Detail
-
matches
public static boolean matches(byte[] signature, int length)
Checks if the signature matches what is expected for a .sz file..sz files start with a chunk with tag 0xff and content sNaPpY.
- Parameters:
signature
- the bytes to checklength
- the number of bytes to check- Returns:
- true if this is a .sz stream, false otherwise
-
available
public int available() throws java.io.IOException
- Overrides:
available
in classjava.io.InputStream
- Throws:
java.io.IOException
-
close
public void close() throws java.io.IOException
- Specified by:
close
in interfacejava.lang.AutoCloseable
- Specified by:
close
in interfacejava.io.Closeable
- Overrides:
close
in classjava.io.InputStream
- Throws:
java.io.IOException
-
getCompressedCount
public long getCompressedCount()
Description copied from interface:InputStreamStatistics
Gets the amount of raw or compressed bytes read by the stream.- Specified by:
getCompressedCount
in interfaceInputStreamStatistics
- Returns:
- the amount of raw or compressed bytes read by the stream.
- Since:
- 1.17
-
read
public int read() throws java.io.IOException
- Specified by:
read
in classjava.io.InputStream
- Throws:
java.io.IOException
-
read
public int read(byte[] b, int off, int len) throws java.io.IOException
- Overrides:
read
in classjava.io.InputStream
- Throws:
java.io.IOException
-
-