Package org.elasticsearch.search.aggregations.pipeline

Class BucketMetricsPipelineAggregator

java.lang.Object

org.elasticsearch.search.aggregations.pipeline.PipelineAggregator

org.elasticsearch.search.aggregations.pipeline.SiblingPipelineAggregator

org.elasticsearch.search.aggregations.pipeline.BucketMetricsPipelineAggregator

Direct Known Subclasses:

AvgBucketPipelineAggregator, ExtendedStatsBucketPipelineAggregator, MaxBucketPipelineAggregator, MinBucketPipelineAggregator, PercentilesBucketPipelineAggregator, StatsBucketPipelineAggregator, SumBucketPipelineAggregator

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

PipelineAggregator.Parser, PipelineAggregator.PipelineTree

Field Summary

Fields

Modifier and Type	Field	Description
protected final DocValueFormat	format
protected final BucketHelpers.GapPolicy	gapPolicy

Method Summary

Modifier and Type	Method	Description
protected abstract InternalAggregation	buildAggregation(Map<String,Object> metadata)	Called after a collection run is finished to build the aggregation for the collected state.
protected abstract void	collectBucketValue(String bucketKey, Double bucketValue)	Called for each bucket with a value so the state can be modified based on the key and metric value for this bucket
final InternalAggregation	doReduce(Aggregations aggregations, AggregationReduceContext context)
protected void	preCollection()	Called before initial collection and between successive collection runs.

Methods inherited from class org.elasticsearch.search.aggregations.pipeline.SiblingPipelineAggregator

reduce

Methods inherited from class org.elasticsearch.search.aggregations.pipeline.PipelineAggregator

bucketsPaths, metadata, name

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Field Details

format

protected final DocValueFormat format

gapPolicy

protected final BucketHelpers.GapPolicy gapPolicy

Method Details

doReduce

public final InternalAggregation doReduce(Aggregations aggregations,
 AggregationReduceContext context)

Specified by:

doReduce in class SiblingPipelineAggregator

preCollection

protected void preCollection()

Called before initial collection and between successive collection runs. A chance to initialize or re-initialize state

buildAggregation

protected abstract InternalAggregation buildAggregation(Map<String,Object> metadata)

Called after a collection run is finished to build the aggregation for the collected state.

Parameters:

metadata - the metadata to add to the resulting aggregation

collectBucketValue

protected abstract void collectBucketValue(String bucketKey,
 Double bucketValue)

Called for each bucket with a value so the state can be modified based on the key and metric value for this bucket

Parameters:

bucketKey - the key for this bucket as a String

bucketValue - the value of the metric specified in bucketsPath for this bucket