Package com.linkedin.alpini.io

Class PigzDeflateCompressor

java.lang.Object

com.linkedin.alpini.io.PigzOutputStream.Compressor

com.linkedin.alpini.io.PigzDeflateCompressor

All Implemented Interfaces:

java.lang.Runnable

public class PigzDeflateCompressor
extends PigzOutputStream.Compressor

Field Summary

Fields inherited from class com.linkedin.alpini.io.PigzOutputStream.Compressor

LOG

Constructor Summary

Constructors

Constructor	Description
PigzDeflateCompressor(PigzOutputStream pigz, int compressionLevel, int blockSize)

Method Summary

Modifier and Type	Method	Description
protected void	deflate()
protected int	getInputAvailable()
protected byte[]	getInputBuffer()
protected int	getOutputAvailable()
protected byte[]	getOutputBuffer()
protected boolean	isInputBufferFull()
protected void	reinitDeflator()
protected void	resetDeflator()
protected void	setDeflateDictionary(byte[] dict, int dictLength)
protected int	write(byte[] b, int off, int len)

Methods inherited from class com.linkedin.alpini.io.PigzOutputStream.Compressor

getSequence, isFinalBlock, run, setDictionary

Methods inherited from class java.lang.Object

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

Constructor Detail

PigzDeflateCompressor

public PigzDeflateCompressor(@Nonnull
                             PigzOutputStream pigz,
                             int compressionLevel,
                             int blockSize)

Method Detail

setDeflateDictionary

protected void setDeflateDictionary(byte[] dict,
                                    int dictLength)

Specified by:

setDeflateDictionary in class PigzOutputStream.Compressor

resetDeflator

protected void resetDeflator()

Specified by:

resetDeflator in class PigzOutputStream.Compressor

reinitDeflator

protected void reinitDeflator()

Specified by:

reinitDeflator in class PigzOutputStream.Compressor

write

protected int write(@Nonnull
                    byte[] b,
                    int off,
                    int len)

Specified by:

write in class PigzOutputStream.Compressor

getInputAvailable

protected int getInputAvailable()

Specified by:

getInputAvailable in class PigzOutputStream.Compressor

isInputBufferFull

protected boolean isInputBufferFull()

Specified by:

isInputBufferFull in class PigzOutputStream.Compressor

getInputBuffer

@Nonnull
protected byte[] getInputBuffer()

Specified by:

getInputBuffer in class PigzOutputStream.Compressor

getOutputBuffer

@Nonnull
protected byte[] getOutputBuffer()

Specified by:

getOutputBuffer in class PigzOutputStream.Compressor

getOutputAvailable

protected int getOutputAvailable()

Specified by:

getOutputAvailable in class PigzOutputStream.Compressor

deflate

protected void deflate()
                throws java.io.IOException

Specified by:

deflate in class PigzOutputStream.Compressor

Throws:

java.io.IOException