NamedWriteable
, Writeable
BucketMetricsPipelineAggregator
public abstract class SiblingPipelineAggregator extends PipelineAggregator
PipelineAggregator.Parser
Writeable.Reader<V>, Writeable.Writer<V>
Modifier | Constructor | Description |
---|---|---|
protected |
SiblingPipelineAggregator(java.lang.String name,
java.lang.String[] bucketsPaths,
java.util.Map<java.lang.String,java.lang.Object> metaData) |
|
protected |
SiblingPipelineAggregator(StreamInput in) |
Read from a stream.
|
Modifier and Type | Method | Description |
---|---|---|
abstract InternalAggregation |
doReduce(Aggregations aggregations,
InternalAggregation.ReduceContext context) |
|
InternalAggregation |
reduce(InternalAggregation aggregation,
InternalAggregation.ReduceContext reduceContext) |
getWriteableName
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
bucketsPaths, doWriteTo, metaData, name, writeTo
protected SiblingPipelineAggregator(java.lang.String name, java.lang.String[] bucketsPaths, java.util.Map<java.lang.String,java.lang.Object> metaData)
protected SiblingPipelineAggregator(StreamInput in) throws java.io.IOException
java.io.IOException
public InternalAggregation reduce(InternalAggregation aggregation, InternalAggregation.ReduceContext reduceContext)
reduce
in class PipelineAggregator
public abstract InternalAggregation doReduce(Aggregations aggregations, InternalAggregation.ReduceContext context)