Package org.apache.drill.exec.physical.impl.aggregate

Interface StreamingAggregator

All Known Implementing Classes:

StreamingAggTemplate

public interface StreamingAggregator

Nested Class Summary

Nested Classes

Modifier and Type	Interface	Description
static enum	StreamingAggregator.AggOutcome	The Aggregator can return one of the following outcomes:

Field Summary

Fields

Modifier and Type	Field	Description
static final TemplateClassDefinition<StreamingAggregator>	TEMPLATE_DEFINITION

Method Summary

Modifier and Type	Method	Description
void	cleanup()
StreamingAggregator.AggOutcome	doWork(RecordBatch.IterOutcome outerOutcome)
RecordBatch.IterOutcome	getOutcome()
int	getOutputCount()
boolean	isDone()
boolean	previousBatchProcessed()
void	setup(OperatorContext context, RecordBatch incoming, StreamingAggBatch outgoing, int outputRowCount)

Field Details

TEMPLATE_DEFINITION

static final TemplateClassDefinition<StreamingAggregator> 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

StreamingAggregator.AggOutcome doWork(RecordBatch.IterOutcome outerOutcome)

isDone

boolean isDone()

cleanup

void cleanup()

previousBatchProcessed

boolean previousBatchProcessed()