Package com.clickhouse.client.stream

Class BlockingInputStream

java.lang.Object

java.io.InputStream

com.clickhouse.client.ClickHouseInputStream

com.clickhouse.client.stream.AbstractByteBufferInputStream

com.clickhouse.client.stream.BlockingInputStream

All Implemented Interfaces:

Closeable, AutoCloseable

public class BlockingInputStream
extends AbstractByteBufferInputStream

ByteBuffer backed input stream with BlockingQueue.

Field Summary

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

buffer

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
BlockingInputStream(BlockingQueue<ByteBuffer> queue, int timeout, Runnable postCloseAction)

Method Summary

Modifier and Type	Method	Description
protected void	ensureOpen()	Checks whether the input stream has been closed and throw an exception if it is.
protected int	updateBuffer()	Update inner buffer as needed.

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

available, close, 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

BlockingInputStream

public BlockingInputStream(BlockingQueue<ByteBuffer> queue,
                           int timeout,
                           Runnable postCloseAction)

Method Detail

ensureOpen

protected void ensureOpen()
                   throws IOException

Description copied from class: ClickHouseInputStream

Checks whether the input stream has been closed and throw an exception if it is.

Overrides:

ensureOpen in class AbstractByteBufferInputStream

Throws:

IOException - when the input stream has been closed

updateBuffer

protected int updateBuffer()
                    throws IOException

Description copied from class: AbstractByteBufferInputStream

Update inner buffer as needed.

Specified by:

updateBuffer in class AbstractByteBufferInputStream

Returns:

remaining bytes in buffer

Throws:

IOException - when failed to update buffer