Class PipelineAggregator
java.lang.Object
org.elasticsearch.search.aggregations.pipeline.PipelineAggregator
- All Implemented Interfaces:
NamedWriteable
,Writeable
- Direct Known Subclasses:
BucketScriptPipelineAggregator
,BucketSelectorPipelineAggregator
,BucketSortPipelineAggregator
,CumulativeSumPipelineAggregator
,DerivativePipelineAggregator
,MovAvgPipelineAggregator
,MovFnPipelineAggregator
,SerialDiffPipelineAggregator
,SiblingPipelineAggregator
public abstract class PipelineAggregator extends java.lang.Object implements NamedWriteable
-
Nested Class Summary
Nested Classes Modifier and Type Class Description static interface
PipelineAggregator.Parser
Parse thePipelineAggregationBuilder
from aXContentParser
.Nested classes/interfaces inherited from interface org.elasticsearch.common.io.stream.Writeable
Writeable.Reader<V>, Writeable.Writer<V>
-
Constructor Summary
Constructors Modifier Constructor Description protected
PipelineAggregator(java.lang.String name, java.lang.String[] bucketsPaths, java.util.Map<java.lang.String,java.lang.Object> metaData)
protected
PipelineAggregator(StreamInput in)
Read from a stream. -
Method Summary
Modifier and Type Method Description java.lang.String[]
bucketsPaths()
protected abstract void
doWriteTo(StreamOutput out)
java.util.Map<java.lang.String,java.lang.Object>
metaData()
java.lang.String
name()
abstract InternalAggregation
reduce(InternalAggregation aggregation, InternalAggregation.ReduceContext reduceContext)
void
writeTo(StreamOutput out)
Write this into the StreamOutput.
-
Constructor Details
-
PipelineAggregator
protected PipelineAggregator(java.lang.String name, java.lang.String[] bucketsPaths, java.util.Map<java.lang.String,java.lang.Object> metaData) -
PipelineAggregator
Read from a stream.- Throws:
java.io.IOException
-
-
Method Details
-
writeTo
Description copied from interface:Writeable
Write this into the StreamOutput. -
doWriteTo
- Throws:
java.io.IOException
-
name
public java.lang.String name() -
bucketsPaths
public java.lang.String[] bucketsPaths() -
metaData
public java.util.Map<java.lang.String,java.lang.Object> metaData() -
reduce
public abstract InternalAggregation reduce(InternalAggregation aggregation, InternalAggregation.ReduceContext reduceContext)
-