Package com.clickhouse.client.stream

Class Lz4OutputStream

java.lang.Object

java.io.OutputStream

com.clickhouse.client.ClickHouseOutputStream

com.clickhouse.client.stream.AbstractByteArrayOutputStream

com.clickhouse.client.stream.Lz4OutputStream

All Implemented Interfaces:

Closeable, Flushable, AutoCloseable

public class Lz4OutputStream
extends AbstractByteArrayOutputStream

Field Summary

Fields inherited from class com.clickhouse.client.stream.AbstractByteArrayOutputStream

buffer, position

Fields inherited from class com.clickhouse.client.ClickHouseOutputStream

closed, ERROR_INCOMPLETE_READ, ERROR_NULL_BYTES, ERROR_REUSE_BUFFER, ERROR_STREAM_CLOSED, file, postCloseAction

Constructor Summary

Constructors

Constructor	Description
Lz4OutputStream(ClickHouseFile file, OutputStream stream, int maxCompressBlockSize, Runnable postCloseAction)
Lz4OutputStream(OutputStream stream, int maxCompressBlockSize, Runnable postCloseAction)

Method Summary

Modifier and Type	Method	Description
void	flush()
protected void	flushBuffer()
protected void	flushBuffer(byte[] bytes, int offset, int length)

Methods inherited from class com.clickhouse.client.stream.AbstractByteArrayOutputStream

transferBytes, writeByte, writeBytes, writeCustom

Methods inherited from class com.clickhouse.client.ClickHouseOutputStream

close, empty, ensureOpen, getUnderlyingFile, isClosed, of, of, of, of, transferBytes, transferBytes, write, write, write, writeAsciiString, writeBuffer, writeBytes, writeBytes, writeString, writeUnicodeString, writeUnsignedVarInt, writeVarInt

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

Constructor Detail

Lz4OutputStream

public Lz4OutputStream(OutputStream stream,
                       int maxCompressBlockSize,
                       Runnable postCloseAction)

Lz4OutputStream

public Lz4OutputStream(ClickHouseFile file,
                       OutputStream stream,
                       int maxCompressBlockSize,
                       Runnable postCloseAction)

Method Detail

flushBuffer

protected void flushBuffer()
                    throws IOException

Overrides:

flushBuffer in class AbstractByteArrayOutputStream

Throws:

IOException

flushBuffer

protected void flushBuffer(byte[] bytes,
                           int offset,
                           int length)
                    throws IOException

Specified by:

flushBuffer in class AbstractByteArrayOutputStream

Throws:

IOException

flush

public void flush()
           throws IOException

Specified by:

flush in interface Flushable

Overrides:

flush in class OutputStream

Throws:

IOException