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

Class OrderedPartitionProjectorTemplate

java.lang.Object

org.apache.drill.exec.physical.impl.orderedpartitioner.OrderedPartitionProjectorTemplate

All Implemented Interfaces:

OrderedPartitionProjector

public abstract class OrderedPartitionProjectorTemplate
extends Object
implements OrderedPartitionProjector

Field Summary

Fields inherited from interface org.apache.drill.exec.physical.impl.orderedpartitioner.OrderedPartitionProjector

TEMPLATE_DEFINITION

Constructor Summary

Constructors

Constructor	Description
OrderedPartitionProjectorTemplate()

Method Summary

Modifier and Type	Method	Description
abstract int	doEval(int inIndex, int partitionIndex)
abstract void	doSetup(FragmentContext context, VectorAccessible incoming, RecordBatch outgoing, VectorContainer partitionVectors)
final int	projectRecords(int recordCount, int firstOutputIndex)
final void	setup(FragmentContext context, VectorAccessible incoming, RecordBatch outgoing, List<TransferPair> transfers, VectorContainer partitionVectors, int partitions, SchemaPath outputField)

Methods inherited from class java.lang.Object

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

Constructor Details

OrderedPartitionProjectorTemplate

public OrderedPartitionProjectorTemplate()
                                  throws SchemaChangeException

Throws:

SchemaChangeException

Method Details

projectRecords

public final int projectRecords(int recordCount,
 int firstOutputIndex)

Specified by:

projectRecords in interface OrderedPartitionProjector

setup

public final void setup(FragmentContext context,
 VectorAccessible incoming,
 RecordBatch outgoing,
 List<TransferPair> transfers,
 VectorContainer partitionVectors,
 int partitions,
 SchemaPath outputField)
                 throws SchemaChangeException

Specified by:

setup in interface OrderedPartitionProjector

Throws:

SchemaChangeException

doSetup

public abstract void doSetup(@Named("context")
 FragmentContext context,
 @Named("incoming")
 VectorAccessible incoming,
 @Named("outgoing")
 RecordBatch outgoing,
 @Named("partitionVectors")
 VectorContainer partitionVectors)
                      throws SchemaChangeException

Throws:

SchemaChangeException

doEval

public abstract int doEval(@Named("inIndex")
 int inIndex,
 @Named("partitionIndex")
 int partitionIndex)
                    throws SchemaChangeException

Throws:

SchemaChangeException