@InterfaceAudience.Private public class Lz4Codec extends Object implements org.apache.hadoop.conf.Configurable, org.apache.hadoop.io.compress.CompressionCodec
This is data format compatible with Hadoop's native lz4 codec.
Modifier and Type | Class and Description |
---|---|
class |
Lz4Codec.HadoopLz4Compressor |
class |
Lz4Codec.HadoopLz4Decompressor |
Modifier and Type | Field and Description |
---|---|
private org.apache.hadoop.conf.Configuration |
conf |
static String |
LZ4_BUFFER_SIZE_KEY |
Constructor and Description |
---|
Lz4Codec() |
Modifier and Type | Method and Description |
---|---|
org.apache.hadoop.io.compress.Compressor |
createCompressor() |
org.apache.hadoop.io.compress.Decompressor |
createDecompressor() |
org.apache.hadoop.io.compress.CompressionInputStream |
createInputStream(InputStream in) |
org.apache.hadoop.io.compress.CompressionInputStream |
createInputStream(InputStream in,
org.apache.hadoop.io.compress.Decompressor d) |
org.apache.hadoop.io.compress.CompressionOutputStream |
createOutputStream(OutputStream out) |
org.apache.hadoop.io.compress.CompressionOutputStream |
createOutputStream(OutputStream out,
org.apache.hadoop.io.compress.Compressor c) |
(package private) static int |
getBufferSize(org.apache.hadoop.conf.Configuration conf) |
Class<? extends org.apache.hadoop.io.compress.Compressor> |
getCompressorType() |
org.apache.hadoop.conf.Configuration |
getConf() |
Class<? extends org.apache.hadoop.io.compress.Decompressor> |
getDecompressorType() |
String |
getDefaultExtension() |
void |
setConf(org.apache.hadoop.conf.Configuration conf) |
public static final String LZ4_BUFFER_SIZE_KEY
private org.apache.hadoop.conf.Configuration conf
public Lz4Codec()
public org.apache.hadoop.conf.Configuration getConf()
getConf
in interface org.apache.hadoop.conf.Configurable
public void setConf(org.apache.hadoop.conf.Configuration conf)
setConf
in interface org.apache.hadoop.conf.Configurable
public org.apache.hadoop.io.compress.Compressor createCompressor()
createCompressor
in interface org.apache.hadoop.io.compress.CompressionCodec
public org.apache.hadoop.io.compress.Decompressor createDecompressor()
createDecompressor
in interface org.apache.hadoop.io.compress.CompressionCodec
public org.apache.hadoop.io.compress.CompressionInputStream createInputStream(InputStream in) throws IOException
createInputStream
in interface org.apache.hadoop.io.compress.CompressionCodec
IOException
public org.apache.hadoop.io.compress.CompressionInputStream createInputStream(InputStream in, org.apache.hadoop.io.compress.Decompressor d) throws IOException
createInputStream
in interface org.apache.hadoop.io.compress.CompressionCodec
IOException
public org.apache.hadoop.io.compress.CompressionOutputStream createOutputStream(OutputStream out) throws IOException
createOutputStream
in interface org.apache.hadoop.io.compress.CompressionCodec
IOException
public org.apache.hadoop.io.compress.CompressionOutputStream createOutputStream(OutputStream out, org.apache.hadoop.io.compress.Compressor c) throws IOException
createOutputStream
in interface org.apache.hadoop.io.compress.CompressionCodec
IOException
public Class<? extends org.apache.hadoop.io.compress.Compressor> getCompressorType()
getCompressorType
in interface org.apache.hadoop.io.compress.CompressionCodec
public Class<? extends org.apache.hadoop.io.compress.Decompressor> getDecompressorType()
getDecompressorType
in interface org.apache.hadoop.io.compress.CompressionCodec
public String getDefaultExtension()
getDefaultExtension
in interface org.apache.hadoop.io.compress.CompressionCodec
static int getBufferSize(org.apache.hadoop.conf.Configuration conf)
Copyright © 2007–2020 The Apache Software Foundation. All rights reserved.