Class MinBucketPipelineAggregator

    • Constructor Detail

      • MinBucketPipelineAggregator

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

        public MinBucketPipelineAggregator​(StreamInput in)
                                    throws java.io.IOException
        Read from a stream.
        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
      • buildAggregation

        protected InternalAggregation buildAggregation​(java.util.List<PipelineAggregator> pipelineAggregators,
                                                       java.util.Map<java.lang.String,​java.lang.Object> metadata)
        Description copied from class: BucketMetricsPipelineAggregator
        Called after a collection run is finished to build the aggregation for the collected state.
        Specified by:
        buildAggregation in class BucketMetricsPipelineAggregator
        Parameters:
        pipelineAggregators - the pipeline aggregators to add to the resulting aggregation
        metadata - the metadata to add to the resulting aggregation