| Package | Description |
|---|---|
| org.apache.drill.exec.physical.impl.xsort |
| Modifier and Type | Class and Description |
|---|---|
class |
InputBatch
The input batch group gathers batches buffered in memory before
spilling.
|
class |
SpilledRun
Holds a set of spilled batches, represented by a file on disk.
|
| Modifier and Type | Method and Description |
|---|---|
List<BatchGroup> |
BufferedBatches.prepareSpill(long targetSpillSize) |
static List<BatchGroup> |
SpilledRuns.prepareSpillBatches(LinkedList<? extends BatchGroup> source,
int spillCount) |
| Modifier and Type | Method and Description |
|---|---|
static void |
BatchGroup.closeAll(Collection<? extends BatchGroup> groups) |
SortImpl.SortResults |
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 |
PriorityQueueCopierTemplate.setup(BufferAllocator allocator,
VectorAccessible hyperBatch,
List<BatchGroup> batchGroups,
VectorAccessible outgoing) |
void |
PriorityQueueCopier.setup(BufferAllocator allocator,
VectorAccessible hyperBatch,
List<BatchGroup> batchGroups,
VectorAccessible outgoing) |
PriorityQueueCopierWrapper.BatchMerger |
PriorityQueueCopierWrapper.startMerge(BatchSchema schema,
List<? extends BatchGroup> batchGroupList,
VectorContainer outputContainer,
int targetRecordCount,
VectorInitializer allocHelper)
Start a merge operation using the specified vector container.
|
Copyright © 2021 The Apache Software Foundation. All rights reserved.