org.apache.drill.exec.physical.impl.flatten

Class FlattenTemplate

java.lang.Object

org.apache.drill.exec.physical.impl.flatten.FlattenTemplate

All Implemented Interfaces:

Flattener

public abstract class FlattenTemplate
extends Object
implements Flattener

Nested Class Summary

Nested classes/interfaces inherited from interface org.apache.drill.exec.physical.impl.flatten.Flattener

Flattener.Monitor

Field Summary

Fields inherited from interface org.apache.drill.exec.physical.impl.flatten.Flattener

TEMPLATE_DEFINITION

Constructor Summary

Constructors

Constructor and Description
FlattenTemplate()

Method Summary

Modifier and Type	Method and Description
abstract boolean	doEval(int inIndex, int outIndex)
abstract void	doSetup(FragmentContext context, RecordBatch incoming, RecordBatch outgoing)
int	flattenRecords(int recordCount, int firstOutputIndex, Flattener.Monitor monitor)
RepeatedValueVector	getFlattenField()
void	resetGroupIndex()
void	setFlattenField(RepeatedValueVector flattenField)
void	setOutputCount(int outputCount)
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

FlattenTemplate

public FlattenTemplate()

Method Detail

setFlattenField

public void setFlattenField(RepeatedValueVector flattenField)

Specified by:

setFlattenField in interface Flattener

getFlattenField

public RepeatedValueVector getFlattenField()

Specified by:

getFlattenField in interface Flattener

setOutputCount

public void setOutputCount(int outputCount)

Specified by:

setOutputCount in interface Flattener

flattenRecords

public final int flattenRecords(int recordCount,
                                int firstOutputIndex,
                                Flattener.Monitor monitor)

Specified by:

flattenRecords in interface Flattener

setup

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

Specified by:

setup in interface Flattener

Throws:

SchemaChangeException

resetGroupIndex

public void resetGroupIndex()

Specified by:

resetGroupIndex in interface Flattener

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 boolean doEval(@Named(value="inIndex")
                               int inIndex,
                               @Named(value="outIndex")
                               int outIndex)
                        throws SchemaChangeException

Throws:

SchemaChangeException

toString

public String toString()

Overrides:

toString in class Object