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

Class ZstdDecompressor

java.lang.Object

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

All Implemented Interfaces:

CanReinit, org.apache.hadoop.io.compress.Decompressor

@Private
public class ZstdDecompressor
extends Object
implements CanReinit, org.apache.hadoop.io.compress.Decompressor

Hadoop decompressor glue for zstd-java.

Field Summary

Fields

Modifier and Type	Field	Description
protected int	bufferSize
protected com.github.luben.zstd.ZstdDecompressCtx	ctx
protected com.github.luben.zstd.ZstdDictDecompress	dict
protected int	dictId
protected boolean	finished
protected ByteBuffer	inBuf
protected int	inLen
protected ByteBuffer	outBuf

Constructor Summary

Constructors

Constructor	Description
ZstdDecompressor(int bufferSize)
ZstdDecompressor(int bufferSize, byte[] dictionary)

Method Summary

Modifier and Type	Method	Description
int	decompress(byte[] b, int off, int len)
void	end()
boolean	finished()
int	getRemaining()
boolean	needsDictionary()
boolean	needsInput()
void	reinit(org.apache.hadoop.conf.Configuration conf)
void	reset()
void	setDictionary(byte[] b, int off, int len)
void	setInput(byte[] b, int off, int len)

Methods inherited from class java.lang.Object

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

Field Details

inBuf

protected ByteBuffer inBuf

outBuf

protected ByteBuffer outBuf

bufferSize

protected int bufferSize

inLen

protected int inLen

finished

protected boolean finished

dictId

protected int dictId

dict

protected com.github.luben.zstd.ZstdDictDecompress dict

ctx

protected com.github.luben.zstd.ZstdDecompressCtx ctx

Constructor Details

ZstdDecompressor

ZstdDecompressor(int bufferSize,
 byte[] dictionary)

ZstdDecompressor

ZstdDecompressor(int bufferSize)

Method Details

decompress

public int decompress(byte[] b,
 int off,
 int len)
               throws IOException

Specified by:

decompress in interface org.apache.hadoop.io.compress.Decompressor

Throws:

IOException

end

public void end()

Specified by:

end in interface org.apache.hadoop.io.compress.Decompressor

finished

public boolean finished()

Specified by:

finished in interface org.apache.hadoop.io.compress.Decompressor

getRemaining

public int getRemaining()

Specified by:

getRemaining in interface org.apache.hadoop.io.compress.Decompressor

needsDictionary

public boolean needsDictionary()

Specified by:

needsDictionary in interface org.apache.hadoop.io.compress.Decompressor

reset

public void reset()

Specified by:

reset in interface org.apache.hadoop.io.compress.Decompressor

needsInput

public boolean needsInput()

Specified by:

needsInput in interface org.apache.hadoop.io.compress.Decompressor

setDictionary

public void setDictionary(byte[] b,
 int off,
 int len)

Specified by:

setDictionary in interface org.apache.hadoop.io.compress.Decompressor

setInput

public void setInput(byte[] b,
 int off,
 int len)

Specified by:

setInput in interface org.apache.hadoop.io.compress.Decompressor

reinit

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

Specified by:

reinit in interface CanReinit