Package org.elasticsearch.search.aggregations.pipeline

Class SumBucketPipelineAggregator

java.lang.Object

org.elasticsearch.search.aggregations.pipeline.PipelineAggregator

org.elasticsearch.search.aggregations.pipeline.SiblingPipelineAggregator

org.elasticsearch.search.aggregations.pipeline.BucketMetricsPipelineAggregator

org.elasticsearch.search.aggregations.pipeline.SumBucketPipelineAggregator

public class SumBucketPipelineAggregator
extends BucketMetricsPipelineAggregator

Nested Class Summary

Nested classes/interfaces inherited from class org.elasticsearch.search.aggregations.pipeline.PipelineAggregator

PipelineAggregator.Parser, PipelineAggregator.PipelineTree

Field Summary

Fields inherited from class org.elasticsearch.search.aggregations.pipeline.BucketMetricsPipelineAggregator

format, gapPolicy

Method Summary

Modifier and Type	Method	Description
protected InternalAggregation	buildAggregation(Map<String,Object> metadata)	Called after a collection run is finished to build the aggregation for the collected state.
protected 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
protected void	preCollection()	Called before initial collection and between successive collection runs.

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

doReduce

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

Method Details

preCollection

protected void preCollection()

Description copied from class: BucketMetricsPipelineAggregator

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

Overrides:

preCollection in class BucketMetricsPipelineAggregator

collectBucketValue

protected void collectBucketValue(String bucketKey,
 Double bucketValue)

Description copied from class: BucketMetricsPipelineAggregator

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

Specified by:

collectBucketValue in class BucketMetricsPipelineAggregator

Parameters:

bucketKey - the key for this bucket as a String

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

buildAggregation

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

Description copied from class: BucketMetricsPipelineAggregator

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

Specified by:

buildAggregation in class BucketMetricsPipelineAggregator

Parameters:

metadata - the metadata to add to the resulting aggregation