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_DEFINITIONMethods in org.apache.drill.exec.physical.impl.aggregate that return StreamingAggregatorModifier and TypeMethodDescriptionprotected StreamingAggregatorStreamingAggBatch.createAggregatorInternal()Method parameters in org.apache.drill.exec.physical.impl.aggregate with type arguments of type StreamingAggregatorModifier and TypeMethodDescriptionprotected voidStreamingAggBatch.addRecordValues(ClassGenerator<StreamingAggregator> cg, LogicalExpression[] valueExprs) protected voidStreamingAggBatch.getIndex(ClassGenerator<StreamingAggregator> g) protected voidStreamingAggBatch.outputRecordKeys(ClassGenerator<StreamingAggregator> cg, TypedFieldId[] keyOutputIds, LogicalExpression[] keyExprs) protected voidStreamingAggBatch.outputRecordKeysPrev(ClassGenerator<StreamingAggregator> cg, TypedFieldId[] keyOutputIds, LogicalExpression[] keyExprs) protected voidStreamingAggBatch.setupIsSame(ClassGenerator<StreamingAggregator> cg, LogicalExpression[] keyExprs) protected voidStreamingAggBatch.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 StreamingAggregatorMetadataStreamAggBatch.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 StreamingAggregatorStatisticsAggBatch.createAggregatorInternal()