Uses of Class
org.apache.drill.exec.physical.impl.xsort.BatchGroup
-
Uses of BatchGroup in org.apache.drill.exec.physical.impl.xsort
Modifier 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.Modifier and TypeMethodDescriptionBufferedBatches.prepareSpill
(long targetSpillSize) static List<BatchGroup>
SpilledRuns.prepareSpillBatches
(LinkedList<? extends BatchGroup> source, int spillCount) Modifier 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.