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 and Description
OrderedPartitionProjectorTemplate()

Method Summary

Modifier and Type	Method and Description
abstract int	doEval(int inIndex, int partitionIndex)
abstract void	doSetup(FragmentContext context, VectorAccessible incoming, RecordBatch outgoing, VectorContainer partitionVectors)
int	projectRecords(int recordCount, int firstOutputIndex)
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 Detail

OrderedPartitionProjectorTemplate

public OrderedPartitionProjectorTemplate()
                                  throws SchemaChangeException

Throws:

SchemaChangeException

Method Detail

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(value="context")
                             FragmentContext context,
                             @Named(value="incoming")
                             VectorAccessible incoming,
                             @Named(value="outgoing")
                             RecordBatch outgoing,
                             @Named(value="partitionVectors")
                             VectorContainer partitionVectors)
                      throws SchemaChangeException

Throws:

SchemaChangeException

doEval

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

Throws:

SchemaChangeException