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

Class PriorityQueueCopierTemplate

java.lang.Object

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

All Implemented Interfaces:

AutoCloseable, PriorityQueueCopier

public abstract class PriorityQueueCopierTemplate
extends Object
implements PriorityQueueCopier

Field Summary

Fields inherited from interface org.apache.drill.exec.physical.impl.xsort.PriorityQueueCopier

TEMPLATE_DEFINITION

Constructor Summary

Constructors

Constructor	Description
PriorityQueueCopierTemplate()

Method Summary

Modifier and Type	Method	Description
void	close()
int	compare(int leftIndex, int rightIndex)
abstract void	doCopy(int inIndex, int outIndex)
abstract int	doEval(int leftIndex, int rightIndex)
abstract void	doSetup(VectorAccessible incoming, VectorAccessible outgoing)
int	next(int targetRecordCount)
void	setup(BufferAllocator allocator, VectorAccessible hyperBatch, List<BatchGroup> batchGroups, VectorAccessible outgoing)
void	swap(int sv0, int sv1)

Methods inherited from class java.lang.Object

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

Constructor Details

PriorityQueueCopierTemplate

public PriorityQueueCopierTemplate()

Method Details

setup

public void setup(BufferAllocator allocator,
 VectorAccessible hyperBatch,
 List<BatchGroup> batchGroups,
 VectorAccessible outgoing)
           throws SchemaChangeException

Specified by:

setup in interface PriorityQueueCopier

Throws:

SchemaChangeException

next

public int next(int targetRecordCount)

Specified by:

next in interface PriorityQueueCopier

close

public void close()
           throws IOException

Specified by:

close in interface AutoCloseable

Specified by:

close in interface PriorityQueueCopier

Throws:

IOException

swap

public void swap(int sv0,
 int sv1)

compare

public int compare(int leftIndex,
 int rightIndex)
            throws SchemaChangeException

Throws:

SchemaChangeException

doSetup

public abstract void doSetup(@Named("incoming")
 VectorAccessible incoming,
 @Named("outgoing")
 VectorAccessible outgoing)
                      throws SchemaChangeException

Throws:

SchemaChangeException

doEval

public abstract int doEval(@Named("leftIndex")
 int leftIndex,
 @Named("rightIndex")
 int rightIndex)
                    throws SchemaChangeException

Throws:

SchemaChangeException

doCopy

public abstract void doCopy(@Named("inIndex")
 int inIndex,
 @Named("outIndex")
 int outIndex)
                     throws SchemaChangeException

Throws:

SchemaChangeException