Package org.apache.druid.frame.channel

Class ReadableInputStreamFrameChannel

java.lang.Object

org.apache.druid.frame.channel.ReadableInputStreamFrameChannel

All Implemented Interfaces:

Closeable, AutoCloseable, ReadableFrameChannel

public class ReadableInputStreamFrameChannel
extends Object
implements ReadableFrameChannel

Channel backed by an InputStream.

Frame channels are expected to be nonblocking, but InputStreams cannot be read in nonblocking fashion. This implementation deals with that by using an ExecutorService to read from the stream in a separate thread.

Method Summary

Modifier and Type	Method	Description
boolean	canRead()	Returns whether this channel has a batch of data or error condition currently available.
void	close()	Releases any resources associated with this readable channel.
boolean	isFinished()	Returns whether this channel is finished.
static ReadableInputStreamFrameChannel	open(InputStream inputStream, String id, ExecutorService executorService, boolean framesOnly, WireTransferableContext wireTransferableContext)	Create an instance of this class and immediately start reading from the provided InputStream.
RowsAndColumns	read()	Returns the next available batch of data from this channel as a RowsAndColumns.
com.google.common.util.concurrent.ListenableFuture<?>	readabilityFuture()	Returns a future that will resolve when either ReadableFrameChannel.isFinished() or ReadableFrameChannel.canRead() would return true.

Methods inherited from class java.lang.Object

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

Methods inherited from interface org.apache.druid.frame.channel.ReadableFrameChannel

readFrame

Method Details

open

public static ReadableInputStreamFrameChannel open(InputStream inputStream,
 String id,
 ExecutorService executorService,
 boolean framesOnly,
 @Nullable
 WireTransferableContext wireTransferableContext)

Create an instance of this class and immediately start reading from the provided InputStream.

Parameters:

inputStream - the input stream to read from

id - identifier for this channel

executorService - executor service for reading from the stream

framesOnly - if true, expects stream to start at FRAMES part (no MAGIC header)

wireTransferableContext - context for wire transfer deserialization; may be null if all data uses legacy frames

isFinished

public boolean isFinished()

Description copied from interface: ReadableFrameChannel

Returns whether this channel is finished. Finished channels will not generate any further data batches or errors. Generally, once you discover that a channel is finished, you should call ReadableFrameChannel.close() and then discard it. Note that it is possible for a channel to be unfinished and also have no available data batches or errors. This happens when it is not in a ready-for-reading state. See ReadableFrameChannel.readabilityFuture() for details.

Specified by:

isFinished in interface ReadableFrameChannel

canRead

public boolean canRead()

Description copied from interface: ReadableFrameChannel

Returns whether this channel has a batch of data or error condition currently available. If this method returns true, then you can call ReadableFrameChannel.readFrame() or ReadableFrameChannel.read() to retrieve the batch or error. Note that it is possible for a channel to be unfinished and also have no available batches or errors. This happens when it is not in a ready-for-reading state. See ReadableFrameChannel.readabilityFuture() for details.

Specified by:

canRead in interface ReadableFrameChannel

read

public RowsAndColumns read()

Description copied from interface: ReadableFrameChannel

Returns the next available batch of data from this channel as a RowsAndColumns. Before calling this method, you should check ReadableFrameChannel.canRead() to ensure there is a batch of data or error available.

Specified by:

read in interface ReadableFrameChannel

readabilityFuture

public com.google.common.util.concurrent.ListenableFuture<?> readabilityFuture()

Description copied from interface: ReadableFrameChannel

Returns a future that will resolve when either ReadableFrameChannel.isFinished() or ReadableFrameChannel.canRead() would return true. The future will never resolve to an exception. If something exceptional has happened, the exception can be retrieved from ReadableFrameChannel.readFrame() or ReadableFrameChannel.read().

Specified by:

readabilityFuture in interface ReadableFrameChannel

close

public void close()

Description copied from interface: ReadableFrameChannel

Releases any resources associated with this readable channel. After calling this, you should not call any other methods on the channel.

Specified by:

close in interface AutoCloseable

Specified by:

close in interface Closeable

Specified by:

close in interface ReadableFrameChannel