Package org.elasticsearch.search.aggregations.pipeline.bucketselector

Class BucketSelectorPipelineAggregator

java.lang.Object

org.elasticsearch.search.aggregations.pipeline.PipelineAggregator

org.elasticsearch.search.aggregations.pipeline.bucketselector.BucketSelectorPipelineAggregator

All Implemented Interfaces:

NamedWriteable, Writeable

public class BucketSelectorPipelineAggregator
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
BucketSelectorPipelineAggregator(java.lang.String name, java.util.Map<java.lang.String,java.lang.String> bucketsPathsMap, Script script, BucketHelpers.GapPolicy gapPolicy, java.util.Map<java.lang.String,java.lang.Object> metadata)
BucketSelectorPipelineAggregator(StreamInput in)	Read from a stream.

Method Summary

Modifier and Type	Method	Description
protected 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

BucketSelectorPipelineAggregator

public BucketSelectorPipelineAggregator(java.lang.String name,
                                        java.util.Map<java.lang.String,java.lang.String> bucketsPathsMap,
                                        Script script,
                                        BucketHelpers.GapPolicy gapPolicy,
                                        java.util.Map<java.lang.String,java.lang.Object> metadata)

BucketSelectorPipelineAggregator

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

Read from a stream.

Throws:

java.io.IOException

Method Detail

doWriteTo

protected 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