Package org.elasticsearch.search.aggregations.pipeline.cumulativesum

Class CumulativeSumPipelineAggregator

java.lang.Object

org.elasticsearch.search.aggregations.pipeline.PipelineAggregator

org.elasticsearch.search.aggregations.pipeline.cumulativesum.CumulativeSumPipelineAggregator

All Implemented Interfaces:

NamedWriteable, Writeable

public class CumulativeSumPipelineAggregator
extends PipelineAggregator

Nested Class Summary

Nested classes/interfaces inherited from class org.elasticsearch.search.aggregations.pipeline.PipelineAggregator

PipelineAggregator.Parser

Nested classes/interfaces inherited from interface org.elasticsearch.common.io.stream.Writeable

Writeable.Reader<V>, Writeable.Writer<V>

Constructor Summary

Constructors

Constructor	Description
CumulativeSumPipelineAggregator(java.lang.String name, java.lang.String[] bucketsPaths, DocValueFormat formatter, java.util.Map<java.lang.String,java.lang.Object> metadata)
CumulativeSumPipelineAggregator(StreamInput in)	Read from a stream.

Method Summary

Modifier and Type	Method	Description
void	doWriteTo(StreamOutput out)
java.lang.String	getWriteableName()	Returns the name of the writeable object
InternalAggregation	reduce(InternalAggregation aggregation, InternalAggregation.ReduceContext reduceContext)

Methods inherited from class org.elasticsearch.search.aggregations.pipeline.PipelineAggregator

bucketsPaths, metaData, name, writeTo

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

CumulativeSumPipelineAggregator

public CumulativeSumPipelineAggregator(java.lang.String name,
                                       java.lang.String[] bucketsPaths,
                                       DocValueFormat formatter,
                                       java.util.Map<java.lang.String,java.lang.Object> metadata)

CumulativeSumPipelineAggregator

public CumulativeSumPipelineAggregator(StreamInput in)
                                throws java.io.IOException

Read from a stream.

Throws:

java.io.IOException

Method Detail

doWriteTo

public void doWriteTo(StreamOutput out)
               throws java.io.IOException

Specified by:

doWriteTo in class PipelineAggregator

Throws:

java.io.IOException

getWriteableName

public java.lang.String getWriteableName()

Description copied from interface: NamedWriteable

Returns the name of the writeable object

reduce

public InternalAggregation reduce(InternalAggregation aggregation,
                                  InternalAggregation.ReduceContext reduceContext)

Specified by:

reduce in class PipelineAggregator