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 and Description
static class	StreamingAggregator.AggOutcome The Aggregator can return one of the following outcomes:

Field Summary

Fields

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

Method Summary

Modifier and Type	Method and 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 Detail

TEMPLATE_DEFINITION

static final TemplateClassDefinition<StreamingAggregator> TEMPLATE_DEFINITION

Method Detail

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()