org.apache.hadoop.io.compress

类 SnappyCodec

java.lang.Object

org.apache.hadoop.io.compress.SnappyCodec

所有已实现的接口:

Configurable, CompressionCodec

public class SnappyCodec
extends Object
implements Configurable, CompressionCodec

This class creates snappy compressors/decompressors.

构造器概要

构造器

构造器和说明
SnappyCodec()

方法概要

方法

限定符和类型	方法和说明
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.
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.
Configuration	getConf() Return the configuration used by this object.
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.
static boolean	isNativeSnappyLoaded(Configuration conf) Are the native snappy libraries loaded & initialized?
void	setConf(Configuration conf) Set the configuration to be used by this object.

从类继承的方法 java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

构造器详细资料

SnappyCodec

public SnappyCodec()

方法详细资料

setConf

public void setConf(Configuration conf)

Set the configuration to be used by this object.

指定者:

setConf 在接口中 Configurable

参数:

conf - the configuration object.

getConf

public Configuration getConf()

Return the configuration used by this object.

指定者:

getConf 在接口中 Configurable

返回:

the configuration object used by this objec.

isNativeSnappyLoaded

public static boolean isNativeSnappyLoaded(Configuration conf)

Are the native snappy libraries loaded & initialized?

参数:

conf - configuration

返回:

true if loaded & initialized, otherwise false

createOutputStream

public CompressionOutputStream createOutputStream(OutputStream out)
                                           throws IOException

Create a CompressionOutputStream that will write to the given OutputStream.

指定者:

createOutputStream 在接口中 CompressionCodec

参数:

out - the location for the final output stream

返回:

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

抛出:

IOException

createOutputStream

public CompressionOutputStream createOutputStream(OutputStream out,
                                         Compressor compressor)
                                           throws IOException

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

指定者:

createOutputStream 在接口中 CompressionCodec

参数:

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

public Class<? extends Compressor> getCompressorType()

Get the type of Compressor needed by this CompressionCodec.

指定者:

getCompressorType 在接口中 CompressionCodec

返回:

the type of compressor needed by this codec.

createCompressor

public Compressor createCompressor()

Create a new Compressor for use by this CompressionCodec.

指定者:

createCompressor 在接口中 CompressionCodec

返回:

a new compressor for use by this codec

createInputStream

public CompressionInputStream createInputStream(InputStream in)
                                         throws IOException

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

指定者:

createInputStream 在接口中 CompressionCodec

参数:

in - the stream to read compressed bytes from

返回:

a stream to read uncompressed bytes from

抛出:

IOException

createInputStream

public CompressionInputStream createInputStream(InputStream in,
                                       Decompressor decompressor)
                                         throws IOException

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

指定者:

createInputStream 在接口中 CompressionCodec

参数:

in - the stream to read compressed bytes from

decompressor - decompressor to use

返回:

a stream to read uncompressed bytes from

抛出:

IOException

getDecompressorType

public Class<? extends Decompressor> getDecompressorType()

Get the type of Decompressor needed by this CompressionCodec.

指定者:

getDecompressorType 在接口中 CompressionCodec

返回:

the type of decompressor needed by this codec.

createDecompressor

public Decompressor createDecompressor()

Create a new Decompressor for use by this CompressionCodec.

指定者:

createDecompressor 在接口中 CompressionCodec

返回:

a new decompressor for use by this codec

getDefaultExtension

public String getDefaultExtension()

Get the default filename extension for this kind of compression.

指定者:

getDefaultExtension 在接口中 CompressionCodec

返回:

.snappy.