Uses of Interface
org.apache.drill.exec.physical.impl.aggregate.StreamingAggregator
Packages that use StreamingAggregator
Package
Description
-
Uses of StreamingAggregator in org.apache.drill.exec.physical.impl.aggregate
Classes in org.apache.drill.exec.physical.impl.aggregate that implement StreamingAggregatorFields in org.apache.drill.exec.physical.impl.aggregate declared as StreamingAggregatorFields in org.apache.drill.exec.physical.impl.aggregate with type parameters of type StreamingAggregatorModifier and TypeFieldDescriptionstatic final TemplateClassDefinition<StreamingAggregator>
StreamingAggregator.TEMPLATE_DEFINITION
Methods in org.apache.drill.exec.physical.impl.aggregate that return StreamingAggregatorModifier and TypeMethodDescriptionprotected StreamingAggregator
StreamingAggBatch.createAggregatorInternal()
Method parameters in org.apache.drill.exec.physical.impl.aggregate with type arguments of type StreamingAggregatorModifier 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
Methods in org.apache.drill.exec.physical.impl.metadata that return StreamingAggregatorModifier and TypeMethodDescriptionprotected StreamingAggregator
MetadataStreamAggBatch.createAggregatorInternal()
-
Uses of StreamingAggregator in org.apache.drill.exec.physical.impl.statistics
Methods in org.apache.drill.exec.physical.impl.statistics that return StreamingAggregatorModifier and TypeMethodDescriptionprotected StreamingAggregator
StatisticsAggBatch.createAggregatorInternal()