Uses of Class
org.apache.druid.frame.key.ClusterByPartitions
Packages that use ClusterByPartitions
-
Uses of ClusterByPartitions in org.apache.druid.frame.key
Methods in org.apache.druid.frame.key that return ClusterByPartitionsModifier and TypeMethodDescriptionstatic ClusterByPartitionsClusterByPartitions.oneUniversalPartition() -
Uses of ClusterByPartitions in org.apache.druid.frame.processor
Constructors in org.apache.druid.frame.processor with parameters of type ClusterByPartitionsModifierConstructorDescriptionFrameChannelMerger(List<ReadableFrameChannel> inputChannels, FrameReader frameReader, WritableFrameChannel outputChannel, FrameWriterFactory frameWriterFactory, List<KeyColumn> sortKey, ClusterByPartitions partitions, long rowLimit) Constructor parameters in org.apache.druid.frame.processor with type arguments of type ClusterByPartitionsModifierConstructorDescriptionSuperSorter(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.