Class BucketMetricsPipelineAggregator

    • Constructor Detail

      • BucketMetricsPipelineAggregator

        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)
      • BucketMetricsPipelineAggregator

        protected BucketMetricsPipelineAggregator​(StreamInput in)
                                           throws java.io.IOException
        Read from a stream.
        Throws:
        java.io.IOException
    • Method Detail

      • innerWriteTo

        protected void innerWriteTo​(StreamOutput out)
                             throws java.io.IOException
        Throws:
        java.io.IOException
      • 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​(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.
        Parameters:
        pipelineAggregators - the pipeline aggregators to add to the resulting aggregation
        metadata - the metadata to add to the resulting aggregation
      • collectBucketValue

        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
        Parameters:
        bucketKey - the key for this bucket as a String
        bucketValue - the value of the metric specified in bucketsPath for this bucket