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