@InterfaceAudience.Private public class HadoopDecompressor<T extends io.airlift.compress.Decompressor> extends Object implements org.apache.hadoop.io.compress.Decompressor
Modifier and Type | Field and Description |
---|---|
protected T |
decompressor |
protected boolean |
finished |
protected ByteBuffer |
inBuf |
protected int |
inLen |
protected ByteBuffer |
outBuf |
Constructor and Description |
---|
HadoopDecompressor(T decompressor,
int bufferSize) |
Modifier and Type | Method and Description |
---|---|
int |
decompress(byte[] b,
int off,
int len) |
void |
end() |
boolean |
finished() |
int |
getRemaining() |
boolean |
needsDictionary() |
boolean |
needsInput() |
void |
reset() |
void |
setDictionary(byte[] b,
int off,
int len) |
void |
setInput(byte[] b,
int off,
int len) |
protected T extends io.airlift.compress.Decompressor decompressor
protected ByteBuffer inBuf
protected ByteBuffer outBuf
protected int inLen
protected boolean finished
HadoopDecompressor(T decompressor, int bufferSize)
public int decompress(byte[] b, int off, int len) throws IOException
decompress
in interface org.apache.hadoop.io.compress.Decompressor
IOException
public void end()
end
in interface org.apache.hadoop.io.compress.Decompressor
public boolean finished()
finished
in interface org.apache.hadoop.io.compress.Decompressor
public int getRemaining()
getRemaining
in interface org.apache.hadoop.io.compress.Decompressor
public boolean needsDictionary()
needsDictionary
in interface org.apache.hadoop.io.compress.Decompressor
public void reset()
reset
in interface org.apache.hadoop.io.compress.Decompressor
public boolean needsInput()
needsInput
in interface org.apache.hadoop.io.compress.Decompressor
public void setDictionary(byte[] b, int off, int len)
setDictionary
in interface org.apache.hadoop.io.compress.Decompressor
public void setInput(byte[] b, int off, int len)
setInput
in interface org.apache.hadoop.io.compress.Decompressor
Copyright © 2007–2020 The Apache Software Foundation. All rights reserved.