Package org.apache.nifi.remote.io

Class CompressionOutputStream

java.lang.Object

java.io.OutputStream

org.apache.nifi.remote.io.CompressionOutputStream

All Implemented Interfaces:

Closeable, Flushable, AutoCloseable

public class CompressionOutputStream
extends OutputStream

Field Summary

Fields

Modifier and Type	Field	Description
private final byte[]	buffer
private int	bufferIndex
private final byte[]	compressed
private boolean	dataWritten
static final int	DEFAULT_BUFFER_SIZE
static final int	DEFAULT_COMPRESSION_LEVEL
private final Deflater	deflater
static final int	MIN_BUFFER_SIZE
private final OutputStream	out
static final byte[]	SYNC_BYTES

Constructor Summary

Constructors

Constructor	Description
CompressionOutputStream(OutputStream outStream)
CompressionOutputStream(OutputStream outStream, int bufferSize)
CompressionOutputStream(OutputStream outStream, int bufferSize, int level, int strategy)

Method Summary

Modifier and Type	Method	Description
protected boolean	bufferFull()
void	close()	Flushes remaining buffer and calls Deflater.end() to free acquired memory to prevent OutOfMemory error.
protected void	compressAndWrite()	Compresses the currently buffered chunk of data and sends it to the output stream
void	flush()
void	write(byte[] b)
void	write(byte[] b, int off, int len)
void	write(int b)
private void	writeChunkHeader(int compressedBytes)
private void	writeInt(OutputStream out, int val)

Methods inherited from class java.io.OutputStream

nullOutputStream

Methods inherited from class java.lang.Object

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

Field Details

SYNC_BYTES

public static final byte[] SYNC_BYTES

DEFAULT_COMPRESSION_LEVEL

public static final int DEFAULT_COMPRESSION_LEVEL

See Also:

• Constant Field Values

DEFAULT_BUFFER_SIZE

public static final int DEFAULT_BUFFER_SIZE

See Also:

• Constant Field Values

MIN_BUFFER_SIZE

public static final int MIN_BUFFER_SIZE

See Also:

• Constant Field Values

out

private final OutputStream out

deflater

private final Deflater deflater

buffer

private final byte[] buffer

compressed

private final byte[] compressed

bufferIndex

private int bufferIndex

dataWritten

private boolean dataWritten

Constructor Details

CompressionOutputStream

public CompressionOutputStream(OutputStream outStream)

CompressionOutputStream

public CompressionOutputStream(OutputStream outStream,
 int bufferSize)

CompressionOutputStream

public CompressionOutputStream(OutputStream outStream,
 int bufferSize,
 int level,
 int strategy)

Method Details

compressAndWrite

protected void compressAndWrite()
                         throws IOException

Compresses the currently buffered chunk of data and sends it to the output stream

Throws:

IOException - if issues occur writing to stream

writeChunkHeader

private void writeChunkHeader(int compressedBytes)
                       throws IOException

Throws:

IOException

writeInt

private void writeInt(OutputStream out,
 int val)
               throws IOException

Throws:

IOException

bufferFull

protected boolean bufferFull()

write

public void write(int b)
           throws IOException

Specified by:

write in class OutputStream

Throws:

IOException

write

public void write(byte[] b)
           throws IOException

Overrides:

write in class OutputStream

Throws:

IOException

write

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

Overrides:

write in class OutputStream

Throws:

IOException

flush

public void flush()
           throws IOException

Specified by:

flush in interface Flushable

Overrides:

flush in class OutputStream

Throws:

IOException

close

public void close()
           throws IOException

Flushes remaining buffer and calls Deflater.end() to free acquired memory to prevent OutOfMemory error.

Specified by:

close in interface AutoCloseable

Specified by:

close in interface Closeable

Overrides:

close in class OutputStream

Throws:

IOException - for any issues closing underlying stream