Package org.apache.drill.exec.physical.impl.xsort

Class PriorityQueueCopierWrapper

java.lang.Object

org.apache.drill.exec.physical.impl.xsort.BaseWrapper

org.apache.drill.exec.physical.impl.xsort.BaseSortWrapper

org.apache.drill.exec.physical.impl.xsort.PriorityQueueCopierWrapper

public class PriorityQueueCopierWrapper
extends BaseSortWrapper

Manages a PriorityQueueCopier instance produced from code generation. Provides a wrapper around a copier "session" to simplify reading batches from the copier.

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
static class	PriorityQueueCopierWrapper.BatchMerger	We've gathered a set of batches, each of which has been sorted.

Field Summary

Fields inherited from class org.apache.drill.exec.physical.impl.xsort.BaseSortWrapper

LEFT_MAPPING, MAIN_MAPPING, RIGHT_MAPPING

Fields inherited from class org.apache.drill.exec.physical.impl.xsort.BaseWrapper

context

Constructor Summary

Constructors

Constructor	Description
PriorityQueueCopierWrapper(OperatorContext opContext)

Method Summary

Modifier and Type	Method	Description
void	close()
BufferAllocator	getAllocator()
PriorityQueueCopier	getCopier(VectorAccessible batch)
PriorityQueueCopierWrapper.BatchMerger	startMerge(BatchSchema schema, List<? extends BatchGroup> batchGroupList, VectorContainer outputContainer, int targetRecordCount, VectorInitializer allocHelper)	Start a merge operation using the specified vector container.

Methods inherited from class org.apache.drill.exec.physical.impl.xsort.BaseSortWrapper

generateComparisons

Methods inherited from class org.apache.drill.exec.physical.impl.xsort.BaseWrapper

getInstance

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Details

PriorityQueueCopierWrapper

public PriorityQueueCopierWrapper(OperatorContext opContext)

Method Details

getCopier

public PriorityQueueCopier getCopier(VectorAccessible batch)

startMerge

public PriorityQueueCopierWrapper.BatchMerger startMerge(BatchSchema schema,
 List<? extends BatchGroup> batchGroupList,
 VectorContainer outputContainer,
 int targetRecordCount,
 VectorInitializer allocHelper)

Start a merge operation using the specified vector container. Used for the final merge operation.

Parameters:

schema -

batchGroupList -

outputContainer -

targetRecordCount -

allocHelper -

Returns:

getAllocator

public BufferAllocator getAllocator()

close

public void close()