Uses of Class
org.apache.druid.frame.processor.OutputChannel

Packages that use OutputChannel

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

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

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

Modifier	Constructor	Description
	ComposingWritableFrameChannel(Integer partitionNumber, List<Supplier<OutputChannel>> outputChannelSuppliers, List<Supplier<PartitionedOutputChannel>> partitionedOutputChannelSuppliers, List<Supplier<WritableFrameChannel>> writableChannelSuppliers, Map<Integer,HashSet<Integer>> partitionToChannelMap)	Create a new channel.

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

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

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.
OutputChannel	OutputChannel.mapWritableChannel(Function<WritableFrameChannel,WritableFrameChannel> mapFn)
static OutputChannel	OutputChannel.nil(int partitionNumber)	Create a nil output channel, representing a processor that writes nothing.
OutputChannel	BlockingQueueOutputChannelFactory.openChannel(int partitionNumber)
OutputChannel	ComposingOutputChannelFactory.openChannel(int partitionNumber)
OutputChannel	FileOutputChannelFactory.openChannel(int partitionNumber)
OutputChannel	OutputChannelFactory.openChannel(int partitionNumber)	Create a channel pair tagged with a particular partition number.
OutputChannel	BlockingQueueOutputChannelFactory.openNilChannel(int partitionNumber)
OutputChannel	ComposingOutputChannelFactory.openNilChannel(int partitionNumber)
OutputChannel	FileOutputChannelFactory.openNilChannel(int partitionNumber)
OutputChannel	OutputChannelFactory.openNilChannel(int partitionNumber)	Create a non-writable, always-empty channel pair tagged with a particular partition number.
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.
OutputChannel	OutputChannel.readOnly()	Returns a read-only version of this instance.
static OutputChannel	OutputChannel.readOnly(Supplier<ReadableFrameChannel> readableChannelSupplier, int partitionNumber)	Creates a read-only output channel.
static OutputChannel	OutputChannel.readOnly(ReadableFrameChannel readableChannel, int partitionNumber)	Creates a read-only output channel.

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

Modifier and Type	Method	Description
List<OutputChannel>	OutputChannels.getAllChannels()	Returns all channels.
List<OutputChannel>	OutputChannels.getChannelsForPartition(int partitionNumber)	Returns channels for which getPartitionNumber() returns partitionNumber.

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

Modifier and Type	Method	Description
static OutputChannels	OutputChannels.wrap(List<OutputChannel> outputChannels)	Creates an instance wrapping all the provided channels.