NamedWriteable
, Writeable
public class MovAvgPipelineAggregator extends PipelineAggregator
PipelineAggregator.Parser
Writeable.Reader<V>, Writeable.Writer<V>
Constructor | Description |
---|---|
MovAvgPipelineAggregator(java.lang.String name,
java.lang.String[] bucketsPaths,
DocValueFormat formatter,
BucketHelpers.GapPolicy gapPolicy,
int window,
int predict,
MovAvgModel model,
boolean minimize,
java.util.Map<java.lang.String,java.lang.Object> metadata) |
|
MovAvgPipelineAggregator(StreamInput in) |
Read from a stream.
|
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) |
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
bucketsPaths, metaData, name, writeTo
public MovAvgPipelineAggregator(java.lang.String name, java.lang.String[] bucketsPaths, DocValueFormat formatter, BucketHelpers.GapPolicy gapPolicy, int window, int predict, MovAvgModel model, boolean minimize, java.util.Map<java.lang.String,java.lang.Object> metadata)
public MovAvgPipelineAggregator(StreamInput in) throws java.io.IOException
java.io.IOException
public void doWriteTo(StreamOutput out) throws java.io.IOException
doWriteTo
in class PipelineAggregator
java.io.IOException
public java.lang.String getWriteableName()
NamedWriteable
public InternalAggregation reduce(InternalAggregation aggregation, InternalAggregation.ReduceContext reduceContext)
reduce
in class PipelineAggregator