Package org.apache.hadoop.hbase.io.compress.zstd

Class ZstdByteBuffDecompressor

java.lang.Object

org.apache.hadoop.hbase.io.compress.zstd.ZstdByteBuffDecompressor

All Implemented Interfaces:

Closeable, AutoCloseable, ByteBuffDecompressor, CanReinit

@Private
public class ZstdByteBuffDecompressor
extends Object
implements ByteBuffDecompressor, CanReinit

Glue for ByteBuffDecompressor on top of zstd-jni

Field Summary

Fields

Modifier and Type	Field	Description
private boolean	allowByteBuffDecompression
protected com.github.luben.zstd.ZstdDecompressCtx	ctx
protected com.github.luben.zstd.ZstdDictDecompress	dict
protected int	dictId

Constructor Summary

Constructors

Constructor	Description
ZstdByteBuffDecompressor(byte[] dictionary)

Method Summary

Modifier and Type	Method	Description
boolean	canDecompress(ByteBuff output, ByteBuff input)	Signals of these two particular ByteBuffs are compatible with this decompressor.
void	close()
int	decompress(ByteBuff output, ByteBuff input, int inputLen)	Fills the ouput buffer with uncompressed data.
private int	decompressDirectByteBuffers(ByteBuffer output, ByteBuffer input, int inputLen)
private int	decompressHeapByteBuffers(ByteBuffer output, ByteBuffer input, int inputLen)
private int	decompressRaw(ByteBuff output, ByteBuff input, int inputLen)
void	reinit(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 Details

dictId

protected int dictId

dict

@Nullable
protected com.github.luben.zstd.ZstdDictDecompress dict

ctx

protected com.github.luben.zstd.ZstdDecompressCtx ctx

allowByteBuffDecompression

private boolean allowByteBuffDecompression

Constructor Details

ZstdByteBuffDecompressor

ZstdByteBuffDecompressor(@Nullable
 byte[] dictionary)

Method Details

canDecompress

public boolean canDecompress(ByteBuff output,
 ByteBuff input)

Description copied from interface: ByteBuffDecompressor

Signals of these two particular ByteBuffs are compatible with this decompressor. ByteBuffs can have one or multiple backing buffers, and each of these may be stored in heap or direct memory. Different ByteBuffDecompressors may be able to handle different combinations of these, so always check.

Specified by:

canDecompress in interface ByteBuffDecompressor

decompress

public int decompress(ByteBuff output,
 ByteBuff input,
 int inputLen)
               throws IOException

Description copied from interface: ByteBuffDecompressor

Fills the ouput buffer with uncompressed data. Always call ByteBuffDecompressor.canDecompress(ByteBuff, ByteBuff) first to check if this decompressor can handle your input and output buffers.

Specified by:

decompress in interface ByteBuffDecompressor

Returns:

The actual number of bytes of uncompressed data.

Throws:

IOException

decompressRaw

private int decompressRaw(ByteBuff output,
 ByteBuff input,
 int inputLen)
                   throws IOException

Throws:

IOException

decompressDirectByteBuffers

private int decompressDirectByteBuffers(ByteBuffer output,
 ByteBuffer input,
 int inputLen)

decompressHeapByteBuffers

private int decompressHeapByteBuffers(ByteBuffer output,
 ByteBuffer input,
 int inputLen)

close

public void close()

Specified by:

close in interface AutoCloseable

Specified by:

close in interface Closeable

reinit

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

Specified by:

reinit in interface CanReinit