Class StatsBucketPipelineAggregator
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.StatsBucketPipelineAggregator
- All Implemented Interfaces:
NamedWriteable
,Writeable
-
Nested Class Summary
Nested classes/interfaces inherited from class org.elasticsearch.search.aggregations.pipeline.PipelineAggregator
PipelineAggregator.Parser, PipelineAggregator.PipelineTree
Nested classes/interfaces inherited from interface org.elasticsearch.common.io.stream.Writeable
Writeable.Reader<V>, Writeable.Writer<V>
-
Field Summary
Fields inherited from class org.elasticsearch.search.aggregations.pipeline.BucketMetricsPipelineAggregator
format, gapPolicy
-
Constructor Summary
-
Method Summary
Modifier and TypeMethodDescriptionprotected 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 bucketThe name of the writeable object.protected void
Called before initial collection and between successive collection runs.Methods inherited from class org.elasticsearch.search.aggregations.pipeline.BucketMetricsPipelineAggregator
doReduce, doWriteTo, innerWriteTo
Methods inherited from class org.elasticsearch.search.aggregations.pipeline.SiblingPipelineAggregator
reduce
Methods inherited from class org.elasticsearch.search.aggregations.pipeline.PipelineAggregator
bucketsPaths, metadata, name, writeTo
-
Constructor Details
-
StatsBucketPipelineAggregator
- Throws:
IOException
-
-
Method Details
-
getWriteableName
Description copied from class:PipelineAggregator
The name of the writeable object.- Specified by:
getWriteableName
in interfaceNamedWriteable
- Overrides:
getWriteableName
in classPipelineAggregator
-
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 classBucketMetricsPipelineAggregator
-
collectBucketValue
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 classBucketMetricsPipelineAggregator
- Parameters:
bucketKey
- the key for this bucket as a StringbucketValue
- the value of the metric specified inbucketsPath
for this bucket
-
buildAggregation
Description copied from class:BucketMetricsPipelineAggregator
Called after a collection run is finished to build the aggregation for the collected state.- Specified by:
buildAggregation
in classBucketMetricsPipelineAggregator
- Parameters:
metadata
- the metadata to add to the resulting aggregation
-