Package com.clickhouse.client.stream

Class IterableMultipleInputStream<T>

java.lang.Object

java.io.InputStream

com.clickhouse.client.ClickHouseInputStream

com.clickhouse.client.stream.AbstractByteArrayInputStream

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

All Implemented Interfaces:

Closeable, AutoCloseable

public final class IterableMultipleInputStream<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
IterableMultipleInputStream(Iterable<T> source, Function<T,InputStream> converter, Runnable postCloseAction)

Method Summary

Modifier and Type	Method	Description
void	close()
long	pipe(ClickHouseOutputStream output)	Reads all remaining bytes and write into given output stream.
ClickHouseByteBuffer	readCustom(ClickHouseDataUpdater reader)	Reads bytes using custom reader.
long	skip(long n)
protected int	updateBuffer()	Update inner byte array along with position and limit as needed.

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

available, ensureOpen, peek, read, read, readBuffer, readByte, readBytes

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

IterableMultipleInputStream

public IterableMultipleInputStream(Iterable<T> source,
                                   Function<T,InputStream> 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

close

public void close()
           throws IOException

Specified by:

close in interface AutoCloseable

Specified by:

close in interface Closeable

Overrides:

close in class AbstractByteArrayInputStream

Throws:

IOException

readCustom

public ClickHouseByteBuffer readCustom(ClickHouseDataUpdater reader)
                                throws IOException

Description copied from class: ClickHouseInputStream

Reads bytes using custom reader. Stream will be closed automatically when it reached end of stream. However, unlike ClickHouseInputStream.readBuffer(int), this method will never throw EOFException.

Overrides:

readCustom in class AbstractByteArrayInputStream

Parameters:

reader - non-null data reader

Returns:

non-null byte buffer

Throws:

IOException - when failed to read bytes from input stream, not able to retrieve all bytes, or reached end of the stream

pipe

public long pipe(ClickHouseOutputStream output)
          throws IOException

Description copied from class: ClickHouseInputStream

Reads all remaining bytes and write into given output stream. Current input stream will be closed automatically at the end of writing, but output will remain open.

Overrides:

pipe in class AbstractByteArrayInputStream

Parameters:

output - non-null output stream

Returns:

bytes being written into output stream

Throws:

IOException - when failed to read value from input stream or reached end of the stream

skip

public long skip(long n)
          throws IOException

Overrides:

skip in class AbstractByteArrayInputStream

Throws:

IOException