public class PercentilesBucketPipelineAggregator extends BucketMetricsPipelineAggregator
PipelineAggregator.Parser
Writeable.Reader<V>, Writeable.Writer<V>
Modifier and Type | Field and Description |
---|---|
ParseField |
PERCENTS_FIELD |
format, gapPolicy
Modifier | Constructor and Description |
---|---|
|
PercentilesBucketPipelineAggregator(StreamInput in)
Read from a stream.
|
protected |
PercentilesBucketPipelineAggregator(java.lang.String name,
double[] percents,
java.lang.String[] bucketsPaths,
BucketHelpers.GapPolicy gapPolicy,
DocValueFormat formatter,
java.util.Map<java.lang.String,java.lang.Object> metaData) |
Modifier and Type | Method and Description |
---|---|
protected InternalAggregation |
buildAggregation(java.util.List<PipelineAggregator> pipelineAggregators,
java.util.Map<java.lang.String,java.lang.Object> metadata)
Called after a collection run is finished to build the aggregation for
the collected state.
|
protected void |
collectBucketValue(java.lang.String bucketKey,
java.lang.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
|
java.lang.String |
getWriteableName()
Returns the name of the writeable object
|
void |
innerWriteTo(StreamOutput out) |
protected void |
preCollection()
Called before initial collection and between successive collection runs.
|
doReduce, doWriteTo
reduce
bucketsPaths, metaData, name, writeTo
public final ParseField PERCENTS_FIELD
protected PercentilesBucketPipelineAggregator(java.lang.String name, double[] percents, java.lang.String[] bucketsPaths, BucketHelpers.GapPolicy gapPolicy, DocValueFormat formatter, java.util.Map<java.lang.String,java.lang.Object> metaData)
public PercentilesBucketPipelineAggregator(StreamInput in) throws java.io.IOException
java.io.IOException
public void innerWriteTo(StreamOutput out) throws java.io.IOException
innerWriteTo
in class BucketMetricsPipelineAggregator
java.io.IOException
public java.lang.String getWriteableName()
NamedWriteable
protected void preCollection()
BucketMetricsPipelineAggregator
preCollection
in class BucketMetricsPipelineAggregator
protected void collectBucketValue(java.lang.String bucketKey, java.lang.Double bucketValue)
BucketMetricsPipelineAggregator
collectBucketValue
in class BucketMetricsPipelineAggregator
bucketKey
- the key for this bucket as a StringbucketValue
- the value of the metric specified in bucketsPath
for this bucketprotected InternalAggregation buildAggregation(java.util.List<PipelineAggregator> pipelineAggregators, java.util.Map<java.lang.String,java.lang.Object> metadata)
BucketMetricsPipelineAggregator
buildAggregation
in class BucketMetricsPipelineAggregator
pipelineAggregators
- the pipeline aggregators to add to the resulting aggregationmetadata
- the metadata to add to the resulting aggregation