@InterfaceAudience.Public @InterfaceStability.Evolving public class BZip2Codec extends Object implements Configurable, SplittableCompressionCodec
Constructor and Description |
---|
BZip2Codec()
Creates a new instance of BZip2Codec.
|
Modifier and Type | Method and Description |
---|---|
Compressor |
createCompressor()
Create a new
Compressor for use by this CompressionCodec . |
Decompressor |
createDecompressor()
Create a new
Decompressor for use by this CompressionCodec . |
CompressionInputStream |
createInputStream(InputStream in)
Create a
CompressionInputStream that will read from the given
input stream and return a stream for uncompressed data. |
CompressionInputStream |
createInputStream(InputStream in,
Decompressor decompressor)
Create a
CompressionInputStream that will read from the given
InputStream with the given Decompressor , and return a
stream for uncompressed data. |
SplitCompressionInputStream |
createInputStream(InputStream seekableIn,
Decompressor decompressor,
long start,
long end,
org.apache.hadoop.io.compress.SplittableCompressionCodec.READ_MODE readMode)
Creates CompressionInputStream to be used to read off uncompressed data
in one of the two reading modes.
|
CompressionOutputStream |
createOutputStream(OutputStream out)
Create a
CompressionOutputStream that will write to the given
OutputStream . |
CompressionOutputStream |
createOutputStream(OutputStream out,
Compressor compressor)
Create a
CompressionOutputStream that will write to the given
OutputStream with the given Compressor . |
Class<? extends Compressor> |
getCompressorType()
Get the type of
Compressor needed by this CompressionCodec . |
Configuration |
getConf()
Return the configuration used by this object.
|
Class<? extends Decompressor> |
getDecompressorType()
Get the type of
Decompressor needed by this CompressionCodec . |
String |
getDefaultExtension()
.bz2 is recognized as the default extension for compressed BZip2 files
|
void |
setConf(Configuration conf)
Set the configuration to be used by this object.
|
public void setConf(Configuration conf)
setConf
in interface Configurable
conf
- the configuration object.public Configuration getConf()
getConf
in interface Configurable
public CompressionOutputStream createOutputStream(OutputStream out) throws IOException
CompressionOutputStream
that will write to the given
OutputStream
.createOutputStream
in interface CompressionCodec
out
- the location for the final output streamIOException
public CompressionOutputStream createOutputStream(OutputStream out, Compressor compressor) throws IOException
CompressionOutputStream
that will write to the given
OutputStream
with the given Compressor
.createOutputStream
in interface CompressionCodec
out
- the location for the final output streamcompressor
- compressor to useIOException
public Class<? extends Compressor> getCompressorType()
Compressor
needed by this CompressionCodec
.getCompressorType
in interface CompressionCodec
public Compressor createCompressor()
Compressor
for use by this CompressionCodec
.createCompressor
in interface CompressionCodec
public CompressionInputStream createInputStream(InputStream in) throws IOException
CompressionInputStream
that will read from the given
input stream and return a stream for uncompressed data.createInputStream
in interface CompressionCodec
in
- the stream to read compressed bytes fromIOException
public CompressionInputStream createInputStream(InputStream in, Decompressor decompressor) throws IOException
CompressionInputStream
that will read from the given
InputStream
with the given Decompressor
, and return a
stream for uncompressed data.createInputStream
in interface CompressionCodec
in
- the stream to read compressed bytes fromdecompressor
- decompressor to useIOException
public SplitCompressionInputStream createInputStream(InputStream seekableIn, Decompressor decompressor, long start, long end, org.apache.hadoop.io.compress.SplittableCompressionCodec.READ_MODE readMode) throws IOException
createInputStream
in interface SplittableCompressionCodec
seekableIn
- The InputStreamstart
- The start offset into the compressed streamend
- The end offset into the compressed streamreadMode
- Controls whether progress is reported continuously or
only at block boundaries.IOException
public Class<? extends Decompressor> getDecompressorType()
Decompressor
needed by this CompressionCodec
.getDecompressorType
in interface CompressionCodec
public Decompressor createDecompressor()
Decompressor
for use by this CompressionCodec
.createDecompressor
in interface CompressionCodec
public String getDefaultExtension()
getDefaultExtension
in interface CompressionCodec
Copyright © 2017 Apache Software Foundation. All rights reserved.