Class StatsBucketPipelineAggregator

    • Constructor Detail

      • StatsBucketPipelineAggregator

        protected StatsBucketPipelineAggregator​(java.lang.String name,
                                                java.lang.String[] bucketsPaths,
                                                BucketHelpers.GapPolicy gapPolicy,
                                                DocValueFormat formatter,
                                                java.util.Map<java.lang.String,java.lang.Object> metaData)
      • StatsBucketPipelineAggregator

        public StatsBucketPipelineAggregator​(StreamInput in)
                                      throws java.io.IOException
        Throws:
        java.io.IOException
    • Method Detail

      • getWriteableName

        public java.lang.String getWriteableName()
        Description copied from interface: NamedWriteable
        Returns the name of the writeable object
      • collectBucketValue

        protected void collectBucketValue​(java.lang.String bucketKey,
                                          java.lang.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