Package com.clickhouse.client.stream

Class IterableObjectInputStream<T>

java.lang.Object

java.io.InputStream

com.clickhouse.client.ClickHouseInputStream

com.clickhouse.client.stream.AbstractByteArrayInputStream

com.clickhouse.client.stream.IterableObjectInputStream<T>

All Implemented Interfaces:

Closeable, AutoCloseable

public class IterableObjectInputStream<T>
extends AbstractByteArrayInputStream

Field Summary

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

buffer, limit, position

Fields inherited from class com.clickhouse.client.ClickHouseInputStream

byteBuffer, closed, copyTo, EMPTY_BUFFER, EMPTY_BYTES, ERROR_INCOMPLETE_READ, ERROR_NULL_BYTES, ERROR_REUSE_BUFFER, ERROR_STREAM_CLOSED, file, postCloseAction

Constructor Summary

Constructors

Constructor	Description
IterableObjectInputStream(Iterable<T> source, Function<T,byte[]> converter, Runnable postCloseAction)

Method Summary

Modifier and Type	Method	Description
protected int	updateBuffer()	Update inner byte array along with position and limit as needed.

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

available, close, ensureOpen, peek, pipe, read, read, readBuffer, readByte, readBytes, readCustom, skip

Methods inherited from class com.clickhouse.client.ClickHouseInputStream

closeQuietly, empty, getUnderlyingFile, isClosed, of, of, of, of, of, of, of, of, of, of, of, of, of, of, of, of, pipe, pipe, readAsciiString, readAsciiString, readString, readString, readUnicodeString, readUnicodeString, readUnsignedByte, readVarInt, readVarLong, save, save, setCopyToTarget, wrap

Methods inherited from class java.io.InputStream

mark, markSupported, nullInputStream, read, readAllBytes, readNBytes, readNBytes, reset, transferTo

Methods inherited from class java.lang.Object

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

Constructor Detail

IterableObjectInputStream

public IterableObjectInputStream(Iterable<T> source,
                                 Function<T,byte[]> converter,
                                 Runnable postCloseAction)

Method Detail

updateBuffer

protected int updateBuffer()
                    throws IOException

Description copied from class: AbstractByteArrayInputStream

Update inner byte array along with position and limit as needed.

Specified by:

updateBuffer in class AbstractByteArrayInputStream

Returns:

remaining bytes in buffer

Throws:

IOException - when failed to read value