Uses of Class
org.apache.druid.frame.processor.PartitionedOutputChannel
Packages that use PartitionedOutputChannel
-
Uses of PartitionedOutputChannel in org.apache.druid.frame.processor
Methods in org.apache.druid.frame.processor that return PartitionedOutputChannelModifier and TypeMethodDescriptionPartitionedOutputChannel.mapWritableChannel(Function<WritableFrameChannel, WritableFrameChannel> mapFn) BlockingQueueOutputChannelFactory.openPartitionedChannel(String name, boolean deleteAfterRead) ComposingOutputChannelFactory.openPartitionedChannel(String name, boolean deleteAfterRead) FileOutputChannelFactory.openPartitionedChannel(String name, boolean deleteAfterRead) OutputChannelFactory.openPartitionedChannel(String name, boolean deleteAfterRead) Create a channel pair tagged with a particular name and a flag to delete the channel data after its read.static PartitionedOutputChannelPartitionedOutputChannel.pair(WritableFrameChannel writableChannel, MemoryAllocator frameMemoryAllocator, Supplier<PartitionedReadableFrameChannel> readableChannelSupplier) Creates a partitioned output channel pair.PartitionedOutputChannel.readOnly()Returns a read-only version of this instance.