java.lang.Object
org.elasticsearch.search.aggregations.matrix.stats.RunningStats
All Implemented Interfaces:
Cloneable, org.elasticsearch.common.io.stream.Writeable

public class RunningStats extends Object implements org.elasticsearch.common.io.stream.Writeable, Cloneable
Descriptive stats gathered per shard. Coordinating node computes final correlation and covariance stats based on these descriptive stats. This single pass, parallel approach is based on: http://prod.sandia.gov/techlib/access-control.cgi/2008/086212.pdf
  • Field Details

  • Constructor Details

    • RunningStats

      public RunningStats(org.elasticsearch.common.io.stream.StreamInput in) throws IOException
      Ctor to create an instance of running statistics
      Throws:
      IOException
  • Method Details

    • writeTo

      public void writeTo(org.elasticsearch.common.io.stream.StreamOutput out) throws IOException
      Specified by:
      writeTo in interface org.elasticsearch.common.io.stream.Writeable
      Throws:
      IOException
    • add

      public void add(String[] fieldNames, double[] fieldVals)
      updates running statistics with a documents field values
    • merge

      public void merge(RunningStats other)
      Merges the descriptive statistics of a second data set (e.g., per shard) running computations taken from: http://prod.sandia.gov/techlib/access-control.cgi/2008/086212.pdf
    • clone

      public RunningStats clone()
      Overrides:
      clone in class Object
    • equals

      public boolean equals(Object o)
      Overrides:
      equals in class Object
    • hashCode

      public int hashCode()
      Overrides:
      hashCode in class Object