Interface StreamingAggregator
- All Known Implementing Classes:
StreamingAggTemplate
public interface StreamingAggregator
-
Nested Class Summary
Modifier and TypeInterfaceDescriptionstatic enum
The Aggregator can return one of the following outcomes: -
Field Summary
-
Method Summary
Modifier and TypeMethodDescriptionvoid
cleanup()
doWork
(RecordBatch.IterOutcome outerOutcome) int
boolean
isDone()
boolean
void
setup
(OperatorContext context, RecordBatch incoming, StreamingAggBatch outgoing, int outputRowCount)
-
Field Details
-
TEMPLATE_DEFINITION
-
-
Method Details
-
setup
void setup(OperatorContext context, RecordBatch incoming, StreamingAggBatch outgoing, int outputRowCount) throws SchemaChangeException - Throws:
SchemaChangeException
-
getOutcome
RecordBatch.IterOutcome getOutcome() -
getOutputCount
int getOutputCount() -
doWork
-
isDone
boolean isDone() -
cleanup
void cleanup() -
previousBatchProcessed
boolean previousBatchProcessed()
-