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

Interface HashAggregator

All Known Implementing Classes:

HashAggTemplate

public interface HashAggregator

Nested Class Summary

Nested Classes

Modifier and Type	Interface	Description
static enum	HashAggregator.AggIterOutcome
static enum	HashAggregator.AggOutcome

Field Summary

Fields

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

Method Summary

Modifier and Type	Method	Description
void	adjustOutputCount(int outputBatchSize, int oldRowWidth, int newRowWidth)
boolean	allFlushed()
boolean	buildComplete()
void	cleanup()
HashAggregator.AggOutcome	doWork()
boolean	earlyOutput()
RecordBatch	getNewIncoming()
RecordBatch.IterOutcome	getOutcome()
int	getOutputCount()
boolean	handlingEmit()
HashAggregator.AggIterOutcome	outputCurrentBatch()
void	setup(HashAggregate hashAggrConfig, HashTableConfig htConfig, FragmentContext context, OperatorContext oContext, RecordBatch incoming, HashAggBatch outgoing, LogicalExpression[] valueExprs, List<TypedFieldId> valueFieldIds, ClassGenerator<?> cg, TypedFieldId[] keyFieldIds, VectorContainer outContainer, int extraRowBytes)

Field Details

TEMPLATE_DEFINITION

static final TemplateClassDefinition<HashAggregator> TEMPLATE_DEFINITION

Method Details

setup

void setup(HashAggregate hashAggrConfig,
 HashTableConfig htConfig,
 FragmentContext context,
 OperatorContext oContext,
 RecordBatch incoming,
 HashAggBatch outgoing,
 LogicalExpression[] valueExprs,
 List<TypedFieldId> valueFieldIds,
 ClassGenerator<?> cg,
 TypedFieldId[] keyFieldIds,
 VectorContainer outContainer,
 int extraRowBytes)

getOutcome

RecordBatch.IterOutcome getOutcome()

getOutputCount

int getOutputCount()

doWork

HashAggregator.AggOutcome doWork()

cleanup

void cleanup()

allFlushed

boolean allFlushed()

buildComplete

boolean buildComplete()

handlingEmit

boolean handlingEmit()

outputCurrentBatch

HashAggregator.AggIterOutcome outputCurrentBatch()

earlyOutput

boolean earlyOutput()

getNewIncoming

RecordBatch getNewIncoming()

adjustOutputCount

void adjustOutputCount(int outputBatchSize,
 int oldRowWidth,
 int newRowWidth)