Package com.linkedin.alpini.io

Class PigzOutputStream.Compressor

java.lang.Object

com.linkedin.alpini.io.PigzOutputStream.Compressor

All Implemented Interfaces:

java.lang.Runnable

Direct Known Subclasses:

PigzDeflateCompressor

Enclosing class:

PigzOutputStream

public abstract static class PigzOutputStream.Compressor
extends java.lang.Object
implements java.lang.Runnable

Field Summary

Fields

Modifier and Type	Field	Description
protected static org.apache.logging.log4j.Logger	LOG

Constructor Summary

Constructors

Modifier	Constructor	Description
protected	Compressor(PigzOutputStream pigz)

Method Summary

Modifier and Type	Method	Description
protected abstract void	deflate()
protected abstract int	getInputAvailable()
protected abstract byte[]	getInputBuffer()
protected abstract int	getOutputAvailable()
protected abstract byte[]	getOutputBuffer()
int	getSequence()
boolean	isFinalBlock()
protected abstract boolean	isInputBufferFull()
protected abstract void	reinitDeflator()
protected abstract void	resetDeflator()
void	run()
protected abstract void	setDeflateDictionary(byte[] dict, int dictLength)
void	setDictionary(byte[] dict, int dictLength)
protected abstract int	write(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 Detail

LOG

protected static final org.apache.logging.log4j.Logger LOG

Constructor Detail

Compressor

protected Compressor(@Nonnull
                     PigzOutputStream pigz)

Method Detail

isFinalBlock

public final boolean isFinalBlock()

getSequence

public final int getSequence()

setDictionary

public final void setDictionary(byte[] dict,
                                int dictLength)

setDeflateDictionary

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

resetDeflator

protected abstract void resetDeflator()

reinitDeflator

protected abstract void reinitDeflator()

write

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

getInputAvailable

protected abstract int getInputAvailable()

isInputBufferFull

protected abstract boolean isInputBufferFull()

getInputBuffer

@Nonnull
protected abstract byte[] getInputBuffer()

getOutputBuffer

@Nonnull
protected abstract byte[] getOutputBuffer()

getOutputAvailable

protected abstract int getOutputAvailable()

deflate

protected abstract void deflate()
                         throws java.io.IOException

Throws:

java.io.IOException

run

public final void run()

Specified by:

run in interface java.lang.Runnable