Uses of Interface
org.apache.drill.exec.physical.impl.aggregate.StreamingAggregator
Package
Description
-
Uses of StreamingAggregator in org.apache.drill.exec.physical.impl.aggregate
Modifier and TypeFieldDescriptionstatic final TemplateClassDefinition<StreamingAggregator>
StreamingAggregator.TEMPLATE_DEFINITION
Modifier and TypeMethodDescriptionprotected StreamingAggregator
StreamingAggBatch.createAggregatorInternal()
Modifier and TypeMethodDescriptionprotected void
StreamingAggBatch.addRecordValues
(ClassGenerator<StreamingAggregator> cg, LogicalExpression[] valueExprs) protected void
StreamingAggBatch.getIndex
(ClassGenerator<StreamingAggregator> g) protected void
StreamingAggBatch.outputRecordKeys
(ClassGenerator<StreamingAggregator> cg, TypedFieldId[] keyOutputIds, LogicalExpression[] keyExprs) protected void
StreamingAggBatch.outputRecordKeysPrev
(ClassGenerator<StreamingAggregator> cg, TypedFieldId[] keyOutputIds, LogicalExpression[] keyExprs) protected void
StreamingAggBatch.setupIsSame
(ClassGenerator<StreamingAggregator> cg, LogicalExpression[] keyExprs) protected void
StreamingAggBatch.setupIsSameApart
(ClassGenerator<StreamingAggregator> cg, LogicalExpression[] keyExprs) -
Uses of StreamingAggregator in org.apache.drill.exec.physical.impl.metadata
Modifier and TypeMethodDescriptionprotected StreamingAggregator
MetadataStreamAggBatch.createAggregatorInternal()
-
Uses of StreamingAggregator in org.apache.drill.exec.physical.impl.statistics
Modifier and TypeMethodDescriptionprotected StreamingAggregator
StatisticsAggBatch.createAggregatorInternal()