Class MovFnPipelineAggregator

  • All Implemented Interfaces:
    NamedWriteable, Writeable

    public class MovFnPipelineAggregator
    extends PipelineAggregator
    This pipeline aggregation gives the user the ability to script functions that "move" across a window of data, instead of single data points. It is the scripted version of MovingAvg pipeline agg. Through custom script contexts, we expose a number of convenience methods: - max - min - sum - unweightedAvg - linearWeightedAvg - ewma - holt - holtWintersMovAvg The user can also define any arbitrary logic via their own scripting, or combine with the above methods.