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 and Description
static class	HashAggregator.AggIterOutcome
static class	HashAggregator.AggOutcome

Field Summary

Fields

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

Method Summary

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

TEMPLATE_DEFINITION

static final TemplateClassDefinition<HashAggregator> TEMPLATE_DEFINITION

Method Detail

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)