Package com.clickhouse.client.stream

Class WrappedOutputStream

java.lang.Object

java.io.OutputStream

com.clickhouse.client.ClickHouseOutputStream

com.clickhouse.client.stream.AbstractByteArrayOutputStream

com.clickhouse.client.stream.WrappedOutputStream

All Implemented Interfaces:

Closeable, Flushable, AutoCloseable

public class WrappedOutputStream
extends AbstractByteArrayOutputStream

Wrapper of OutputStream.

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
WrappedOutputStream(ClickHouseFile file, OutputStream stream, int bufferSize, Runnable postCloseAction)

Method Summary

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

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

flushBuffer, 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

WrappedOutputStream

public WrappedOutputStream(ClickHouseFile file,
                           OutputStream stream,
                           int bufferSize,
                           Runnable postCloseAction)

Method Detail

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