org.apache.drill.exec.physical.impl.project

Class ProjectorTemplate

java.lang.Object

org.apache.drill.exec.physical.impl.project.ProjectorTemplate

All Implemented Interfaces:

Projector

public abstract class ProjectorTemplate
extends Object
implements Projector

Field Summary

Fields inherited from interface org.apache.drill.exec.physical.impl.project.Projector

TEMPLATE_DEFINITION

Constructor Summary

Constructors

Constructor and Description
ProjectorTemplate()

Method Summary

Modifier and Type	Method and Description
abstract void	doEval(int inIndex, int outIndex)
abstract void	doSetup(FragmentContext context, RecordBatch incoming, RecordBatch outgoing)
int	projectRecords(RecordBatch incomingRecordBatch, int startIndex, int recordCount, int firstOutputIndex)
void	setup(FragmentContext context, RecordBatch incoming, RecordBatch outgoing, List<TransferPair> transfers)
String	toString()

Methods inherited from class java.lang.Object

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

Constructor Detail

ProjectorTemplate

public ProjectorTemplate()

Method Detail

projectRecords

public final int projectRecords(RecordBatch incomingRecordBatch,
                                int startIndex,
                                int recordCount,
                                int firstOutputIndex)

Specified by:

projectRecords in interface Projector

setup

public final void setup(FragmentContext context,
                        RecordBatch incoming,
                        RecordBatch outgoing,
                        List<TransferPair> transfers)
                 throws SchemaChangeException

Specified by:

setup in interface Projector

Throws:

SchemaChangeException

doSetup

public abstract void doSetup(@Named(value="context")
                             FragmentContext context,
                             @Named(value="incoming")
                             RecordBatch incoming,
                             @Named(value="outgoing")
                             RecordBatch outgoing)
                      throws SchemaChangeException

Throws:

SchemaChangeException

doEval

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

Throws:

SchemaChangeException

toString

public String toString()

Overrides:

toString in class Object