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

@Private
public class ZstdByteBuffDecompressor
extends Object
implements ByteBuffDecompressor

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 int	dictId

Constructor Summary

Constructors

Constructor	Description
ZstdByteBuffDecompressor(byte[] dictionaryBytes)

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	decompressRaw(ByteBuff output, ByteBuff input, int inputLen)
void	reinit(Compression.HFileDecompressionContext newHFileDecompressionContext)	Call before every use of ByteBuffDecompressor.canDecompress(ByteBuff, ByteBuff) and ByteBuffDecompressor.decompress(ByteBuff, ByteBuff, int) to reinitialize the decompressor with settings from the HFileInfo.

Methods inherited from class java.lang.Object

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

Field Details

dictId

protected int dictId

ctx

protected com.github.luben.zstd.ZstdDecompressCtx ctx

allowByteBuffDecompression

private boolean allowByteBuffDecompression

Constructor Details

ZstdByteBuffDecompressor

ZstdByteBuffDecompressor(@Nullable
 byte[] dictionaryBytes)

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

reinit

public void reinit(@Nullable
 Compression.HFileDecompressionContext newHFileDecompressionContext)

Description copied from interface: ByteBuffDecompressor

Call before every use of ByteBuffDecompressor.canDecompress(ByteBuff, ByteBuff) and ByteBuffDecompressor.decompress(ByteBuff, ByteBuff, int) to reinitialize the decompressor with settings from the HFileInfo. This can matter because ByteBuffDecompressors are reused many times.

Specified by:

reinit in interface ByteBuffDecompressor

close

public void close()

Specified by:

close in interface AutoCloseable

Specified by:

close in interface Closeable