Uses of Class
org.apache.drill.exec.physical.impl.xsort.BatchGroup
Packages that use BatchGroup
-
Uses of BatchGroup in org.apache.drill.exec.physical.impl.xsort
Subclasses of BatchGroup in org.apache.drill.exec.physical.impl.xsortModifier and TypeClassDescriptionclass
The input batch group gathers batches buffered in memory before spilling.class
Holds a set of spilled batches, represented by a file on disk.Methods in org.apache.drill.exec.physical.impl.xsort that return types with arguments of type BatchGroupModifier and TypeMethodDescriptionBufferedBatches.prepareSpill
(long targetSpillSize) static List<BatchGroup>
SpilledRuns.prepareSpillBatches
(LinkedList<? extends BatchGroup> source, int spillCount) Method parameters in org.apache.drill.exec.physical.impl.xsort with type arguments of type BatchGroupModifier and TypeMethodDescriptionstatic void
BatchGroup.closeAll
(Collection<? extends BatchGroup> groups) SpilledRuns.finalMerge
(List<? extends BatchGroup> bufferedBatches, VectorContainer container, int mergeRowCount, VectorInitializer allocHelper) void
SpilledRuns.mergeAndSpill
(List<BatchGroup> batchesToSpill, int spillBatchRowCount, VectorInitializer allocHelper) static List<BatchGroup>
SpilledRuns.prepareSpillBatches
(LinkedList<? extends BatchGroup> source, int spillCount) void
PriorityQueueCopier.setup
(BufferAllocator allocator, VectorAccessible hyperBatch, List<BatchGroup> batchGroups, VectorAccessible outgoing) void
PriorityQueueCopierTemplate.setup
(BufferAllocator allocator, VectorAccessible hyperBatch, List<BatchGroup> batchGroups, VectorAccessible outgoing) PriorityQueueCopierWrapper.startMerge
(BatchSchema schema, List<? extends BatchGroup> batchGroupList, VectorContainer outputContainer, int targetRecordCount, VectorInitializer allocHelper) Start a merge operation using the specified vector container.