org.anarres.lzo.hadoop.codec

Class LzopCodec

java.lang.Object

org.apache.hadoop.conf.Configured

org.anarres.lzo.hadoop.codec.LzoCodec

org.anarres.lzo.hadoop.codec.LzopCodec

All Implemented Interfaces:

org.apache.hadoop.conf.Configurable, org.apache.hadoop.io.compress.CompressionCodec

Direct Known Subclasses:

LzopCodec

public class LzopCodec
extends LzoCodec

A CompressionCodec for a streaming lzo compression/decompression pair compatible with lzop. http://www.lzop.org/

Field Summary

Fields inherited from class org.anarres.lzo.hadoop.codec.LzoCodec

DEFAULT_LZO_BUFFER_SIZE, LZO_BUFFER_SIZE_KEY, LZO_COMPRESSION_LEVEL_KEY, LZO_COMPRESSOR_KEY, LZO_DECOMPRESSOR_KEY, MAX_BLOCK_SIZE, UNDEFINED_COMPRESSION_LEVEL

Constructor Summary

Constructors

Constructor and Description
LzopCodec()

Method Summary

Modifier and Type	Method and Description
org.apache.hadoop.io.compress.Decompressor	createDecompressor()
org.apache.hadoop.io.compress.CompressionInputStream	createInputStream(InputStream in, org.apache.hadoop.io.compress.Decompressor decompressor)
org.apache.hadoop.io.compress.CompressionOutputStream	createOutputStream(OutputStream out, org.apache.hadoop.io.compress.Compressor compressor)
String	getDefaultExtension() Get the default filename extension for this kind of compression.

Methods inherited from class org.anarres.lzo.hadoop.codec.LzoCodec

createCompressor, createInputStream, createOutputStream, getCompressorType, getDecompressorType, setBufferSize, setCompressionLevel, setCompressionStrategy, setDecompressionStrategy

Methods inherited from class org.apache.hadoop.conf.Configured

getConf, setConf

Methods inherited from class java.lang.Object

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

Constructor Detail

LzopCodec

public LzopCodec()

Method Detail

createOutputStream

public org.apache.hadoop.io.compress.CompressionOutputStream createOutputStream(OutputStream out,
                                                                                org.apache.hadoop.io.compress.Compressor compressor)
                                                                         throws IOException

Specified by:

createOutputStream in interface org.apache.hadoop.io.compress.CompressionCodec

Overrides:

createOutputStream in class LzoCodec

Throws:

IOException

createInputStream

public org.apache.hadoop.io.compress.CompressionInputStream createInputStream(InputStream in,
                                                                              org.apache.hadoop.io.compress.Decompressor decompressor)
                                                                       throws IOException

Specified by:

createInputStream in interface org.apache.hadoop.io.compress.CompressionCodec

Overrides:

createInputStream in class LzoCodec

Throws:

IOException

createDecompressor

public org.apache.hadoop.io.compress.Decompressor createDecompressor()

Specified by:

createDecompressor in interface org.apache.hadoop.io.compress.CompressionCodec

Overrides:

createDecompressor in class LzoCodec

getDefaultExtension

public String getDefaultExtension()

Description copied from class: LzoCodec

Get the default filename extension for this kind of compression.

Specified by:

getDefaultExtension in interface org.apache.hadoop.io.compress.CompressionCodec

Overrides:

getDefaultExtension in class LzoCodec

Returns:

the extension including the '.'