- Direct Known Subclasses:
public abstract class BucketMetricsPipelineAggregator extends SiblingPipelineAggregator
A class of sibling pipeline aggregations which calculate metrics across the buckets of a sibling aggregation
Nested Class Summary
Nested classes/interfaces inherited from class org.elasticsearch.search.aggregations.pipeline.PipelineAggregator
Method SummaryModifier and TypeMethodDescription
protected abstract InternalAggregationCalled after a collection run is finished to build the aggregation for the collected state.
protected abstract voidCalled for each bucket with a value so the state can be modified based on the key and metric value for this bucket
StreamOutput out)(Write the body of the aggregation to the wire.
()Called before initial collection and between successive collection runs.
Methods inherited from class org.elasticsearch.search.aggregations.pipeline.SiblingPipelineAggregator
Methods inherited from class org.elasticsearch.search.aggregations.pipeline.PipelineAggregator
bucketsPaths, getWriteableName, metadata, name, writeTo
doWriteToDescription copied from class:
PipelineAggregatorWrite the body of the aggregation to the wire.
doReducepublic final InternalAggregation doReduce(Aggregations aggregations, InternalAggregation.ReduceContext context)
preCollectionprotected void preCollection()Called before initial collection and between successive collection runs. A chance to initialize or re-initialize state
buildAggregationCalled after a collection run is finished to build the aggregation for the collected state.
metadata- the metadata to add to the resulting aggregation
collectBucketValueCalled for each bucket with a value so the state can be modified based on the key and metric value for this bucket
bucketKey- the key for this bucket as a String
bucketValue- the value of the metric specified in
bucketsPathfor this bucket