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

Class ZstdHFileDecompressionContext

java.lang.Object

org.apache.hadoop.hbase.io.compress.Compression.HFileDecompressionContext

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

All Implemented Interfaces:

Closeable, AutoCloseable, HeapSize

@Private
public final class ZstdHFileDecompressionContext
extends Compression.HFileDecompressionContext

Holds HFile-level settings used by ZstdByteBuffDecompressor. It's expensive to pull these from a Configuration object every time we decompress a block, so pull them upon opening an HFile, and reuse them in every block that gets decompressed.

Field Summary

Fields

Modifier and Type	Field	Description
private final boolean	allowByteBuffDecompression
private final com.github.luben.zstd.ZstdDictDecompress	dict
private final int	dictId
static final long	FIXED_OVERHEAD

Constructor Summary

Constructors

Modifier	Constructor	Description
private	ZstdHFileDecompressionContext(com.github.luben.zstd.ZstdDictDecompress dict, int dictId, boolean allowByteBuffDecompression)

Method Summary

Modifier and Type	Method	Description
void	close()
static ZstdHFileDecompressionContext	fromConfiguration(org.apache.hadoop.conf.Configuration conf)
com.github.luben.zstd.ZstdDictDecompress	getDict()
int	getDictId()
long	heapSize()	Return the approximate 'exclusive deep size' of implementing object.
boolean	isAllowByteBuffDecompression()
String	toString()

Methods inherited from class java.lang.Object

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

Field Details

FIXED_OVERHEAD

public static final long FIXED_OVERHEAD

dict

@Nullable
private final com.github.luben.zstd.ZstdDictDecompress dict

dictId

private final int dictId

allowByteBuffDecompression

private final boolean allowByteBuffDecompression

Constructor Details

ZstdHFileDecompressionContext

private ZstdHFileDecompressionContext(@Nullable
 com.github.luben.zstd.ZstdDictDecompress dict,
 int dictId,
 boolean allowByteBuffDecompression)

Method Details

getDict

@Nullable
public com.github.luben.zstd.ZstdDictDecompress getDict()

getDictId

public int getDictId()

isAllowByteBuffDecompression

public boolean isAllowByteBuffDecompression()

fromConfiguration

public static ZstdHFileDecompressionContext fromConfiguration(org.apache.hadoop.conf.Configuration conf)

close

public void close()
           throws IOException

Throws:

IOException

heapSize

public long heapSize()

Description copied from interface: HeapSize

Return the approximate 'exclusive deep size' of implementing object. Includes count of payload and hosting object sizings.

toString

public String toString()

Overrides:

toString in class Object