org.apache.hadoop.hbase.io.compress.brotli

Class BrotliCodec

java.lang.Object

org.apache.hadoop.hbase.io.compress.brotli.BrotliCodec

All Implemented Interfaces:

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

@InterfaceAudience.Private
public class BrotliCodec
extends Object
implements org.apache.hadoop.conf.Configurable, org.apache.hadoop.io.compress.CompressionCodec

Hadoop brotli codec implemented with Brotli4j

Nested Class Summary

Nested classes/interfaces inherited from interface org.apache.hadoop.io.compress.CompressionCodec

org.apache.hadoop.io.compress.CompressionCodec.Util

Field Summary

Fields

Modifier and Type	Field and Description
static int	BROTLI_BUFFERSIZE_DEFAULT
static String	BROTLI_BUFFERSIZE_KEY
static int	BROTLI_LEVEL_DEFAULT
static String	BROTLI_LEVEL_KEY
static int	BROTLI_WINDOW_DEFAULT
static String	BROTLI_WINDOW_KEY
private org.apache.hadoop.conf.Configuration	conf

Constructor Summary

Constructors

Constructor and Description
BrotliCodec()

Method Summary

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 int	getLevel(org.apache.hadoop.conf.Configuration conf)
(package private) static int	getWindow(org.apache.hadoop.conf.Configuration conf)
void	setConf(org.apache.hadoop.conf.Configuration conf)

Methods inherited from class java.lang.Object

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

Field Detail

BROTLI_LEVEL_KEY

public static final String BROTLI_LEVEL_KEY

See Also:

Constant Field Values

BROTLI_LEVEL_DEFAULT

public static final int BROTLI_LEVEL_DEFAULT

See Also:

Constant Field Values

BROTLI_WINDOW_KEY

public static final String BROTLI_WINDOW_KEY

See Also:

Constant Field Values

BROTLI_WINDOW_DEFAULT

public static final int BROTLI_WINDOW_DEFAULT

See Also:

Constant Field Values

BROTLI_BUFFERSIZE_KEY

public static final String BROTLI_BUFFERSIZE_KEY

See Also:

Constant Field Values

BROTLI_BUFFERSIZE_DEFAULT

public static final int BROTLI_BUFFERSIZE_DEFAULT

See Also:

Constant Field Values

conf

private org.apache.hadoop.conf.Configuration conf

Constructor Detail

BrotliCodec

public BrotliCodec()

Method Detail

getConf

public org.apache.hadoop.conf.Configuration getConf()

Specified by:

getConf in interface org.apache.hadoop.conf.Configurable

setConf

public void setConf(org.apache.hadoop.conf.Configuration conf)

Specified by:

setConf in interface org.apache.hadoop.conf.Configurable

createCompressor

public org.apache.hadoop.io.compress.Compressor createCompressor()

Specified by:

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

createDecompressor

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

Specified by:

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

createInputStream

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

Specified by:

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

Throws:

IOException

createInputStream

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

Specified by:

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

Throws:

IOException

createOutputStream

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

Specified by:

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

Throws:

IOException

createOutputStream

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

Specified by:

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

Throws:

IOException

getCompressorType

public Class<? extends org.apache.hadoop.io.compress.Compressor> getCompressorType()

Specified by:

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

getDecompressorType

public Class<? extends org.apache.hadoop.io.compress.Decompressor> getDecompressorType()

Specified by:

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

getDefaultExtension

public String getDefaultExtension()

Specified by:

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

getLevel

static int getLevel(org.apache.hadoop.conf.Configuration conf)

getWindow

static int getWindow(org.apache.hadoop.conf.Configuration conf)

getBufferSize

static int getBufferSize(org.apache.hadoop.conf.Configuration conf)