Class StreamingAggTemplate
java.lang.Object
org.apache.drill.exec.physical.impl.aggregate.StreamingAggTemplate
- All Implemented Interfaces:
StreamingAggregator
-
Nested Class Summary
Nested classes/interfaces inherited from interface org.apache.drill.exec.physical.impl.aggregate.StreamingAggregator
StreamingAggregator.AggOutcome
-
Field Summary
Fields inherited from interface org.apache.drill.exec.physical.impl.aggregate.StreamingAggregator
TEMPLATE_DEFINITION
-
Constructor Summary
-
Method Summary
Modifier and TypeMethodDescriptionabstract void
addRecord
(int index) void
cleanup()
doWork
(RecordBatch.IterOutcome outerOutcome) int
abstract int
getVectorIndex
(int recordIndex) boolean
isDone()
abstract boolean
isSame
(int index1, int index2) abstract boolean
isSamePrev
(int b1Index, InternalBatch b1, int b2Index) abstract void
outputRecordKeys
(int inIndex, int outIndex) abstract void
outputRecordKeysPrev
(InternalBatch previous, int previousIndex, int outIndex) abstract void
outputRecordValues
(int outIndex) boolean
abstract boolean
void
setup
(OperatorContext context, RecordBatch incoming, StreamingAggBatch outgoing, int outputRowCount) abstract void
setupInterior
(RecordBatch incoming, RecordBatch outgoing) toString()
-
Constructor Details
-
StreamingAggTemplate
public StreamingAggTemplate()
-
-
Method Details
-
setup
public void setup(OperatorContext context, RecordBatch incoming, StreamingAggBatch outgoing, int outputRowCount) throws SchemaChangeException - Specified by:
setup
in interfaceStreamingAggregator
- Throws:
SchemaChangeException
-
getOutcome
- Specified by:
getOutcome
in interfaceStreamingAggregator
-
getOutputCount
public int getOutputCount()- Specified by:
getOutputCount
in interfaceStreamingAggregator
-
doWork
- Specified by:
doWork
in interfaceStreamingAggregator
-
isDone
public boolean isDone()- Specified by:
isDone
in interfaceStreamingAggregator
-
cleanup
public void cleanup()- Specified by:
cleanup
in interfaceStreamingAggregator
-
toString
-
previousBatchProcessed
public boolean previousBatchProcessed()- Specified by:
previousBatchProcessed
in interfaceStreamingAggregator
-
setupInterior
public abstract void setupInterior(@Named("incoming") RecordBatch incoming, @Named("outgoing") RecordBatch outgoing) throws SchemaChangeException - Throws:
SchemaChangeException
-
isSame
public abstract boolean isSame(@Named("index1") int index1, @Named("index2") int index2) -
isSamePrev
public abstract boolean isSamePrev(@Named("b1Index") int b1Index, @Named("b1") InternalBatch b1, @Named("b2Index") int b2Index) -
addRecord
public abstract void addRecord(@Named("index") int index) -
outputRecordKeys
public abstract void outputRecordKeys(@Named("inIndex") int inIndex, @Named("outIndex") int outIndex) -
outputRecordKeysPrev
public abstract void outputRecordKeysPrev(@Named("previous") InternalBatch previous, @Named("previousIndex") int previousIndex, @Named("outIndex") int outIndex) -
outputRecordValues
public abstract void outputRecordValues(@Named("outIndex") int outIndex) -
getVectorIndex
public abstract int getVectorIndex(@Named("recordIndex") int recordIndex) -
resetValues
public abstract boolean resetValues()
-