@InterfaceAudience.Private public class ZstdCodec extends Object implements org.apache.hadoop.conf.Configurable, org.apache.hadoop.io.compress.CompressionCodec
This is data format compatible with Hadoop's native ZStandard codec.
Modifier and Type | Field and Description |
---|---|
private org.apache.hadoop.conf.Configuration |
conf |
static int |
ZSTD_BUFFER_SIZE_DEFAULT |
static String |
ZSTD_BUFFER_SIZE_KEY |
static String |
ZSTD_DICTIONARY_KEY |
static String |
ZSTD_LEVEL_KEY |
Constructor and Description |
---|
ZstdCodec() |
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() |
(package private) static byte[] |
getDictionary(org.apache.hadoop.conf.Configuration conf) |
(package private) static int |
getDictionaryId(byte[] dictionary) |
(package private) static int |
getLevel(org.apache.hadoop.conf.Configuration conf) |
(package private) static boolean |
isDictionary(byte[] dictionary) |
void |
setConf(org.apache.hadoop.conf.Configuration conf) |
public static final String ZSTD_LEVEL_KEY
public static final String ZSTD_BUFFER_SIZE_KEY
public static final int ZSTD_BUFFER_SIZE_DEFAULT
public static final String ZSTD_DICTIONARY_KEY
private org.apache.hadoop.conf.Configuration conf
public ZstdCodec()
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 getLevel(org.apache.hadoop.conf.Configuration conf)
static int getBufferSize(org.apache.hadoop.conf.Configuration conf)
static byte[] getDictionary(org.apache.hadoop.conf.Configuration conf)
static boolean isDictionary(byte[] dictionary)
static int getDictionaryId(byte[] dictionary)
Copyright © 2007–2020 The Apache Software Foundation. All rights reserved.