org.apache.hadoop.io.compress

接口 CompressionCodec

所有已知子接口:

SplittableCompressionCodec

所有已知实现类:

BZip2Codec, DefaultCodec, GzipCodec, SnappyCodec

public interface CompressionCodec

This class encapsulates a streaming compression/decompression pair.

方法概要

方法

限定符和类型	方法和说明
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 stream decompressor that will read from the given input stream.
CompressionInputStream	createInputStream(InputStream in, Decompressor decompressor) Create a CompressionInputStream that will read from the given InputStream with the given Decompressor.
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.
Class<? extends Decompressor>	getDecompressorType() Get the type of Decompressor needed by this CompressionCodec.
String	getDefaultExtension() Get the default filename extension for this kind of compression.

方法详细资料

createOutputStream

CompressionOutputStream createOutputStream(OutputStream out)
                                           throws IOException

Create a CompressionOutputStream that will write to the given OutputStream.

参数:

out - the location for the final output stream

返回:

a stream the user can write uncompressed data to have it compressed

抛出:

IOException

createOutputStream

CompressionOutputStream createOutputStream(OutputStream out,
                                         Compressor compressor)
                                           throws IOException

Create a CompressionOutputStream that will write to the given OutputStream with the given Compressor.

参数:

out - the location for the final output stream

compressor - compressor to use

返回:

a stream the user can write uncompressed data to have it compressed

抛出:

IOException

getCompressorType

Class<? extends Compressor> getCompressorType()

Get the type of Compressor needed by this CompressionCodec.

返回:

the type of compressor needed by this codec.

createCompressor

Compressor createCompressor()

Create a new Compressor for use by this CompressionCodec.

返回:

a new compressor for use by this codec

createInputStream

CompressionInputStream createInputStream(InputStream in)
                                         throws IOException

Create a stream decompressor that will read from the given input stream.

参数:

in - the stream to read compressed bytes from

返回:

a stream to read uncompressed bytes from

抛出:

IOException

createInputStream

CompressionInputStream createInputStream(InputStream in,
                                       Decompressor decompressor)
                                         throws IOException

Create a CompressionInputStream that will read from the given InputStream with the given Decompressor.

参数:

in - the stream to read compressed bytes from

decompressor - decompressor to use

返回:

a stream to read uncompressed bytes from

抛出:

IOException

getDecompressorType

Class<? extends Decompressor> getDecompressorType()

Get the type of Decompressor needed by this CompressionCodec.

返回:

the type of decompressor needed by this codec.

createDecompressor

Decompressor createDecompressor()

Create a new Decompressor for use by this CompressionCodec.

返回:

a new decompressor for use by this codec

getDefaultExtension

String getDefaultExtension()

Get the default filename extension for this kind of compression.

返回:

the extension including the '.'