@InterfaceAudience.Private public class HFileBlockDefaultEncodingContext extends java.lang.Object implements HFileBlockEncodingContext
HFileBlockEncodingContext
. It will
compress the data section as one continuous buffer.for the decompression part
Constructor and Description |
---|
HFileBlockDefaultEncodingContext(DataBlockEncoding encoding,
byte[] headerBytes,
HFileContext fileContext) |
Modifier and Type | Method and Description |
---|---|
void |
close()
Releases the compressor this writer uses to compress blocks into the
compressor pool.
|
protected void |
compressAfterEncoding(byte[] uncompressedBytesWithHeader,
byte[] headerBytes) |
byte[] |
compressAndEncrypt(byte[] uncompressedBytesWithHeader) |
BlockType |
getBlockType() |
DataBlockEncoding |
getDataBlockEncoding() |
EncodingState |
getEncodingState() |
HFileContext |
getHFileContext() |
TagCompressionContext |
getTagCompressionContext() |
void |
postEncoding(BlockType blockType)
Do any action that needs to be performed after the encoding.
|
void |
prepareEncoding(java.io.DataOutputStream out)
prepare to start a new encoding.
|
void |
setEncodingState(EncodingState state)
Sets the encoding state.
|
void |
setTagCompressionContext(TagCompressionContext tagCompressionContext) |
public HFileBlockDefaultEncodingContext(DataBlockEncoding encoding, byte[] headerBytes, HFileContext fileContext)
encoding
- encoding usedheaderBytes
- dummy header bytesfileContext
- HFile meta datapublic void prepareEncoding(java.io.DataOutputStream out) throws java.io.IOException
java.io.IOException
public void postEncoding(BlockType blockType) throws java.io.IOException
HFileBlockEncodingContext
postEncoding
in interface HFileBlockEncodingContext
java.io.IOException
public byte[] compressAndEncrypt(byte[] uncompressedBytesWithHeader) throws java.io.IOException
compressAndEncrypt
in interface HFileBlockEncodingContext
uncompressedBytesWithHeader
- encoded bytes with headerjava.io.IOException
protected void compressAfterEncoding(byte[] uncompressedBytesWithHeader, byte[] headerBytes) throws java.io.IOException
uncompressedBytesWithHeader
- headerBytes
- java.io.IOException
public BlockType getBlockType()
getBlockType
in interface HFileBlockEncodingContext
public void close()
close
in interface HFileBlockEncodingContext
public DataBlockEncoding getDataBlockEncoding()
getDataBlockEncoding
in interface HFileBlockEncodingContext
DataBlockEncoding
encoding usedpublic HFileContext getHFileContext()
getHFileContext
in interface HFileBlockEncodingContext
public TagCompressionContext getTagCompressionContext()
public void setTagCompressionContext(TagCompressionContext tagCompressionContext)
public EncodingState getEncodingState()
getEncodingState
in interface HFileBlockEncodingContext
public void setEncodingState(EncodingState state)
HFileBlockEncodingContext
setEncodingState
in interface HFileBlockEncodingContext