NamedWriteable
, Writeable
AvgBucketPipelineAggregator
, ExtendedStatsBucketPipelineAggregator
, MaxBucketPipelineAggregator
, MinBucketPipelineAggregator
, PercentilesBucketPipelineAggregator
, StatsBucketPipelineAggregator
, SumBucketPipelineAggregator
public abstract class BucketMetricsPipelineAggregator extends SiblingPipelineAggregator
PipelineAggregator.Parser
Writeable.Reader<V>, Writeable.Writer<V>
Modifier and Type | Field | Description |
---|---|---|
protected DocValueFormat |
format |
|
protected BucketHelpers.GapPolicy |
gapPolicy |
Modifier | Constructor | Description |
---|---|---|
protected |
BucketMetricsPipelineAggregator(java.lang.String name,
java.lang.String[] bucketsPaths,
BucketHelpers.GapPolicy gapPolicy,
DocValueFormat format,
java.util.Map<java.lang.String,java.lang.Object> metaData) |
|
protected |
BucketMetricsPipelineAggregator(StreamInput in) |
Read from a stream.
|
Modifier and Type | Method | Description |
---|---|---|
protected abstract 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 abstract 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
|
InternalAggregation |
doReduce(Aggregations aggregations,
InternalAggregation.ReduceContext context) |
|
void |
doWriteTo(StreamOutput out) |
|
protected void |
innerWriteTo(StreamOutput out) |
|
protected void |
preCollection() |
Called before initial collection and between successive collection runs.
|
getWriteableName
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
bucketsPaths, metaData, name, writeTo
reduce
protected final DocValueFormat format
protected final BucketHelpers.GapPolicy gapPolicy
protected BucketMetricsPipelineAggregator(java.lang.String name, java.lang.String[] bucketsPaths, BucketHelpers.GapPolicy gapPolicy, DocValueFormat format, java.util.Map<java.lang.String,java.lang.Object> metaData)
protected BucketMetricsPipelineAggregator(StreamInput in) throws java.io.IOException
java.io.IOException
public final void doWriteTo(StreamOutput out) throws java.io.IOException
doWriteTo
in class PipelineAggregator
java.io.IOException
protected void innerWriteTo(StreamOutput out) throws java.io.IOException
java.io.IOException
public final InternalAggregation doReduce(Aggregations aggregations, InternalAggregation.ReduceContext context)
doReduce
in class SiblingPipelineAggregator
protected void preCollection()
protected abstract InternalAggregation buildAggregation(java.util.List<PipelineAggregator> pipelineAggregators, java.util.Map<java.lang.String,java.lang.Object> metadata)
pipelineAggregators
- the pipeline aggregators to add to the resulting aggregationmetadata
- the metadata to add to the resulting aggregationprotected abstract void collectBucketValue(java.lang.String bucketKey, java.lang.Double bucketValue)
bucketKey
- the key for this bucket as a StringbucketValue
- the value of the metric specified in bucketsPath
for this bucket