public class InternalMatrixStats extends InternalAggregation implements MatrixStats
InternalAggregation.ReduceContext
Aggregation.CommonFields
ToXContent.DelegatingMapParams, ToXContent.MapParams, ToXContent.Params
Writeable.Reader<V>, Writeable.Writer<V>
metaData, name
TYPED_KEYS_DELIMITER
EMPTY_PARAMS
Modifier | Constructor and Description |
---|---|
|
InternalMatrixStats(StreamInput in)
Read from a stream.
|
protected |
InternalMatrixStats(java.lang.String name,
long count,
RunningStats multiFieldStatsResults,
org.elasticsearch.search.aggregations.matrix.stats.MatrixStatsResults results,
java.util.List<PipelineAggregator> pipelineAggregators,
java.util.Map<java.lang.String,java.lang.Object> metaData)
per shard ctor
|
Modifier and Type | Method and Description |
---|---|
InternalAggregation |
doReduce(java.util.List<InternalAggregation> aggregations,
InternalAggregation.ReduceContext reduceContext) |
protected void |
doWriteTo(StreamOutput out) |
XContentBuilder |
doXContentBody(XContentBuilder builder,
ToXContent.Params params) |
double |
getCorrelation(java.lang.String fieldX,
java.lang.String fieldY)
get the correlation between the two fields
|
double |
getCovariance(java.lang.String fieldX,
java.lang.String fieldY)
get the covariance between the two fields
|
long |
getDocCount()
get the number of documents
|
long |
getFieldCount(java.lang.String field)
get the number of samples for the given field.
|
double |
getKurtosis(java.lang.String field)
get the distribution shape for the given field
|
double |
getMean(java.lang.String field)
get the mean for the given field
|
java.lang.Object |
getProperty(java.util.List<java.lang.String> path) |
double |
getSkewness(java.lang.String field)
get the distribution skewness for the given field
|
double |
getVariance(java.lang.String field)
get the variance for the given field
|
java.lang.String |
getWriteableName() |
getMetaData, getName, getProperty, getType, pipelineAggregators, readSize, reduce, toXContent, writeSize, writeTo
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
getMetaData, getName, getType
isFragment, toXContent
protected InternalMatrixStats(java.lang.String name, long count, RunningStats multiFieldStatsResults, org.elasticsearch.search.aggregations.matrix.stats.MatrixStatsResults results, java.util.List<PipelineAggregator> pipelineAggregators, java.util.Map<java.lang.String,java.lang.Object> metaData)
public InternalMatrixStats(StreamInput in) throws java.io.IOException
java.io.IOException
protected void doWriteTo(StreamOutput out) throws java.io.IOException
doWriteTo
in class InternalAggregation
java.io.IOException
public java.lang.String getWriteableName()
getWriteableName
in interface NamedWriteable
public long getDocCount()
getDocCount
in interface MatrixStats
public long getFieldCount(java.lang.String field)
getFieldCount
in interface MatrixStats
public double getMean(java.lang.String field)
getMean
in interface MatrixStats
public double getVariance(java.lang.String field)
getVariance
in interface MatrixStats
public double getSkewness(java.lang.String field)
getSkewness
in interface MatrixStats
public double getKurtosis(java.lang.String field)
getKurtosis
in interface MatrixStats
public double getCovariance(java.lang.String fieldX, java.lang.String fieldY)
getCovariance
in interface MatrixStats
public double getCorrelation(java.lang.String fieldX, java.lang.String fieldY)
getCorrelation
in interface MatrixStats
public XContentBuilder doXContentBody(XContentBuilder builder, ToXContent.Params params) throws java.io.IOException
doXContentBody
in class InternalAggregation
java.io.IOException
public java.lang.Object getProperty(java.util.List<java.lang.String> path)
getProperty
in class InternalAggregation
public InternalAggregation doReduce(java.util.List<InternalAggregation> aggregations, InternalAggregation.ReduceContext reduceContext)
doReduce
in class InternalAggregation