Uses of Interface
org.apache.druid.frame.channel.ReadableFrameChannel

Packages that use ReadableFrameChannel

Package	Description
org.apache.druid.frame.channel
org.apache.druid.frame.processor

Uses of ReadableFrameChannel in org.apache.druid.frame.channel

Classes in org.apache.druid.frame.channel that implement ReadableFrameChannel

Modifier and Type	Class	Description
class	ComposingReadableFrameChannel	A composed readable channel to read frames.
class	ReadableByteChunksFrameChannel	Channel backed by a byte stream that is continuously streamed in using ReadableByteChunksFrameChannel.addChunk(byte[]).
class	ReadableConcatFrameChannel	Channel that concatenates a sequence of other channels that are provided by an iterator.
class	ReadableFileFrameChannel	Channel backed by a FrameFile.
class	ReadableInputStreamFrameChannel	Channel backed by an InputStream.
class	ReadableNilFrameChannel	Empty channel.

Methods in org.apache.druid.frame.channel that return ReadableFrameChannel

Modifier and Type	Method	Description
ReadableFrameChannel	DurableStoragePartitionedReadableFrameChannel.getReadableFrameChannel(int partitionNumber)
ReadableFrameChannel	PartitionedReadableFrameChannel.getReadableFrameChannel(int partitionNumber)	Allows reading a particular partition in the channel
ReadableFrameChannel	BlockingQueueFrameChannel.readable()	Returns the readable side of this channel.

Method parameters in org.apache.druid.frame.channel with type arguments of type ReadableFrameChannel

Modifier and Type	Method	Description
static ReadableConcatFrameChannel	ReadableConcatFrameChannel.open(Iterator<ReadableFrameChannel> channelIterator)	Creates a new concatenated channel.

Constructors in org.apache.druid.frame.channel with parameters of type ReadableFrameChannel

Modifier	Constructor	Description
	FrameChannelSequence(ReadableFrameChannel channel)

Constructor parameters in org.apache.druid.frame.channel with type arguments of type ReadableFrameChannel

Modifier	Constructor	Description
	ComposingReadableFrameChannel(int partition, List<Supplier<ReadableFrameChannel>> channels, HashSet<Integer> validChannels)

Uses of ReadableFrameChannel in org.apache.druid.frame.processor

Methods in org.apache.druid.frame.processor that return ReadableFrameChannel

Modifier and Type	Method	Description
ReadableFrameChannel	OutputChannel.getReadableChannel()	Returns the readable channel of this pair.

Methods in org.apache.druid.frame.processor that return types with arguments of type ReadableFrameChannel

Modifier and Type	Method	Description
List<ReadableFrameChannel>	OutputChannels.getAllReadableChannels()	Returns all channels, as readable channels.
Supplier<ReadableFrameChannel>	OutputChannel.getReadableChannelSupplier()
List<ReadableFrameChannel>	FrameChannelBatcher.inputChannels()
List<ReadableFrameChannel>	FrameChannelHashPartitioner.inputChannels()
List<ReadableFrameChannel>	FrameChannelMerger.inputChannels()
List<ReadableFrameChannel>	FrameChannelMixer.inputChannels()
List<ReadableFrameChannel>	FrameProcessor.inputChannels()	List of input channels.
List<ReadableFrameChannel>	RunnableFrameProcessor.inputChannels()

Methods in org.apache.druid.frame.processor with parameters of type ReadableFrameChannel

Modifier and Type	Method	Description
static OutputChannel	OutputChannel.immediatelyReadablePair(WritableFrameChannel writableChannel, MemoryAllocator frameMemoryAllocator, ReadableFrameChannel readableChannel, int partitionNumber)	Creates an output channel pair, where the readable channel is usable before writing is complete.
static OutputChannel	OutputChannel.readOnly(ReadableFrameChannel readableChannel, int partitionNumber)	Creates a read-only output channel.

Method parameters in org.apache.druid.frame.processor with type arguments of type ReadableFrameChannel

Modifier and Type	Method	Description
static void	FrameProcessors.closeAll(List<ReadableFrameChannel> readableFrameChannels, List<WritableFrameChannel> writableFrameChannels, Closeable... otherCloseables)	Helper method for implementing FrameProcessor.cleanup().
static OutputChannel	OutputChannel.pair(WritableFrameChannel writableChannel, MemoryAllocator frameMemoryAllocator, Supplier<ReadableFrameChannel> readableChannelSupplier, int partitionNumber)	Creates an output channel pair, where the readable channel is not usable until writing is complete.
static OutputChannel	OutputChannel.readOnly(Supplier<ReadableFrameChannel> readableChannelSupplier, int partitionNumber)	Creates a read-only output channel.

Constructor parameters in org.apache.druid.frame.processor with type arguments of type ReadableFrameChannel

Modifier	Constructor	Description
	AwaitAnyWidget(List<ReadableFrameChannel> channels)
	FrameChannelBatcher(List<ReadableFrameChannel> channels, int maxFrames)
	FrameChannelHashPartitioner(List<ReadableFrameChannel> inputChannels, List<WritableFrameChannel> outputChannels, FrameReader frameReader, int keyFieldCount, FrameWriterFactory frameWriterFactory)
	FrameChannelMerger(List<ReadableFrameChannel> inputChannels, FrameReader frameReader, WritableFrameChannel outputChannel, FrameWriterFactory frameWriterFactory, List<KeyColumn> sortKey, ClusterByPartitions partitions, long rowLimit)
	FrameChannelMixer(List<ReadableFrameChannel> inputChannels, WritableFrameChannel outputChannel)
	SuperSorter(List<ReadableFrameChannel> inputChannels, FrameReader frameReader, List<KeyColumn> sortKey, com.google.common.util.concurrent.ListenableFuture<ClusterByPartitions> outputPartitionsFuture, FrameProcessorExecutor exec, FrameProcessorDecorator processorDecorator, OutputChannelFactory outputChannelFactory, OutputChannelFactory intermediateOutputChannelFactory, FrameType outputFrameType, int maxActiveProcessors, int maxChannelsPerMerger, long rowLimit, String cancellationId, SuperSorterProgressTracker superSorterProgressTracker, boolean removeNullBytes)	Initializes a SuperSorter.