org.apache.drill.exec.physical.impl.union

Class UnionAllerTemplate

java.lang.Object

org.apache.drill.exec.physical.impl.union.UnionAllerTemplate

All Implemented Interfaces:

UnionAller

public abstract class UnionAllerTemplate
extends Object
implements UnionAller

Field Summary

Fields inherited from interface org.apache.drill.exec.physical.impl.union.UnionAller

TEMPLATE_DEFINITION

Constructor Summary

Constructors

Constructor and Description
UnionAllerTemplate()

Method Summary

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

Methods inherited from class java.lang.Object

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

Constructor Detail

UnionAllerTemplate

public UnionAllerTemplate()

Method Detail

unionRecords

public final int unionRecords(int startIndex,
                              int recordCount,
                              int firstOutputIndex)

Specified by:

unionRecords in interface UnionAller

setup

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

Specified by:

setup in interface UnionAller

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