Package org.apache.druid.frame.channel

package org.apache.druid.frame.channel

Related Packages

Package	Description
org.apache.druid.frame

Class	Description
BlockingQueueFrameChannel	In-memory channel backed by a limited-capacity Deque.
ByteTracker	Tracks the byte usage with an upper bound bytes limit.
ChannelClosedForWritesException	Exception thrown by ReadableByteChunksFrameChannel.addChunk(byte[]) when the channel has been closed for writes, i.e., after ReadableByteChunksFrameChannel.doneWriting() or ReadableByteChunksFrameChannel.close() has been called.
ComposingReadableFrameChannel	A composed readable channel to read frames.
ComposingWritableFrameChannel	A composed writable channel to write frames.
DurableStoragePartitionedReadableFrameChannel
FrameChannelSequence	Adapter that converts a ReadableFrameChannel into a Sequence of RowsAndColumns.
FrameChannelSequence.FrameChannelIterator
FrameWithPartition	Frame plus partition number.
PartitionedReadableFrameChannel	Provides an interface to read a partitioned frame channel.
ReadableByteChunksFrameChannel	Channel backed by a byte stream that is continuously streamed in using ReadableByteChunksFrameChannel.addChunk(byte[]).
ReadableConcatFrameChannel	Channel that concatenates a sequence of other channels that are provided by an iterator.
ReadableFileFrameChannel	Channel backed by a FrameFile.
ReadableFrameChannel	Interface for reading a sequence of batches of data.
ReadableInputStreamFrameChannel	Channel backed by an InputStream.
ReadableNilFrameChannel	Empty channel.
WritableFrameChannel	Interface for writing a sequence of result batches.
WritableFrameFileChannel	Frame channel backed by a FrameFileWriter.