Package org.apache.druid.frame.processor
package org.apache.druid.frame.processor
-
ClassDescriptionAn
OutputChannelFactorythat generatesBlockingQueueFrameChannel.Limiter for access to some resource.A channel factory which provides ordered composed channels.Processor that reads up to "maxFrames" frames from some input channels and combines them into a batch.Processor that hash-partitions rows from any number of input channels, and writes partitioned frames to output channels.Processor that merges already-sorted inputChannels and writes a fully-sorted stream to a single outputChannel.Processor that merges frames from inputChannels into a single outputChannel.A FrameProcessor is like an incremental version of Runnable that operates onReadableFrameChannelandWritableFrameChannel.Passed toSuperSorterto decorate the processors it launches.Manages execution ofFrameProcessorin anExecutorService.Exception that is conventionally thrown by workers when they callFrameWriter.addSelection()and it returns false on an empty frame, or in a situation where allocating a new frame is impractical.AColumnSelectorFactorythat wraps multipleColumnSelectorFactoryand delegates to one of them at any given time.Represents an output channel for some frame processor.Factory for generating channel pairs for output data from processors.A list ofOutputChannel.A channel which can contain multiple partitions of data.Instances of this class are returned byFrameProcessor.runIncrementally(it.unimi.dsi.fastutil.ints.IntSet), and are used byFrameProcessorExecutorto manage execution.RunAllFullyWidget<T,ResultType> Frame processor that simply runs aRunnable, once.Sorts and partitions a dataset using parallel, possibly-external merge sort.LikeSuperSorterProgressTracker, but immutable.A thread-safe class that keeps track of the progress of an n-way, multilevel merge sort.Tree-of-losers tournament tree used for K-way merging.