Package com.clickhouse.client.stream

Class AbstractByteArrayOutputStream

java.lang.Object

java.io.OutputStream

com.clickhouse.client.ClickHouseOutputStream

com.clickhouse.client.stream.AbstractByteArrayOutputStream

All Implemented Interfaces:

Closeable, Flushable, AutoCloseable

Direct Known Subclasses:

Lz4OutputStream, WrappedOutputStream

public abstract class AbstractByteArrayOutputStream
extends ClickHouseOutputStream

Field Summary

Fields

Modifier and Type	Field	Description
protected byte[]	buffer
protected int	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

Modifier	Constructor	Description
protected	AbstractByteArrayOutputStream(ClickHouseFile file, int bufferSize, Runnable postCloseAction)

Method Summary

Modifier and Type	Method	Description
protected void	flushBuffer()
protected abstract void	flushBuffer(byte[] bytes, int offset, int length)
ClickHouseOutputStream	transferBytes(byte[] bytes, int offset, int length)	Transfers the given bytes into output stream, without creating a copy as in ClickHouseOutputStream.writeBytes(byte[], int, int).
ClickHouseOutputStream	writeByte(byte b)	Writes a single byte into output stream.
ClickHouseOutputStream	writeBytes(byte[] bytes, int offset, int length)	Writes copy of given bytes into output stream.
ClickHouseOutputStream	writeCustom(ClickHouseDataUpdater writer)	Writes bytes using custom writer.

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

flush, nullOutputStream

Methods inherited from class java.lang.Object

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

Field Detail

buffer

protected final byte[] buffer

position

protected int position

Constructor Detail

AbstractByteArrayOutputStream

protected AbstractByteArrayOutputStream(ClickHouseFile file,
                                        int bufferSize,
                                        Runnable postCloseAction)

Method Detail

flushBuffer

protected void flushBuffer()
                    throws IOException

Throws:

IOException

flushBuffer

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

Throws:

IOException

transferBytes

public ClickHouseOutputStream transferBytes(byte[] bytes,
                                            int offset,
                                            int length)
                                     throws IOException

Description copied from class: ClickHouseOutputStream

Transfers the given bytes into output stream, without creating a copy as in ClickHouseOutputStream.writeBytes(byte[], int, int).

Specified by:

transferBytes in class ClickHouseOutputStream

Parameters:

bytes - non-null byte array

offset - offset of the byte array

length - bytes to write

Returns:

current output stream

Throws:

IOException - when failed to write value into output stream, not able to sent all bytes, or opereate on a closed stream

writeByte

public ClickHouseOutputStream writeByte(byte b)
                                 throws IOException

Description copied from class: ClickHouseOutputStream

Writes a single byte into output stream.

Specified by:

writeByte in class ClickHouseOutputStream

Parameters:

b - byte to write

Returns:

current output stream

Throws:

IOException - when failed to write value into output stream, not able to sent all bytes, or opereate on a closed stream

writeBytes

public ClickHouseOutputStream writeBytes(byte[] bytes,
                                         int offset,
                                         int length)
                                  throws IOException

Description copied from class: ClickHouseOutputStream

Writes copy of given bytes into output stream.

Specified by:

writeBytes in class ClickHouseOutputStream

Parameters:

bytes - non-null byte array

offset - offset of the byte array

length - bytes to write

Returns:

current output stream

Throws:

IOException - when failed to write value into output stream, not able to sent all bytes, or opereate on a closed stream

writeCustom

public ClickHouseOutputStream writeCustom(ClickHouseDataUpdater writer)
                                   throws IOException

Description copied from class: ClickHouseOutputStream

Writes bytes using custom writer.

Specified by:

writeCustom in class ClickHouseOutputStream

Parameters:

writer - non-null data writer

Returns:

current output stream

Throws:

IOException - when failed to write value into output stream, not able to sent all bytes, or opereate on a closed stream