public class MovingMinimum extends Object implements stream.StatefulProcessor
Similar to a moving average, this processor calculates a moving minimum. When moving the window over the time series, the processor calculates the minimum inside the window for every time and returns it.
This can be used, when answering the question: What is the highest signal with a given width. In conjuction with extraction.MaxAmplitude, the position and the height of the highest signal with a given width (i.e. the window size) can be found.
Constructor and Description |
---|
MovingMinimum() |
Modifier and Type | Method and Description |
---|---|
void |
finish() |
void |
init(stream.ProcessContext context) |
stream.Data |
process(stream.Data item) |
void |
resetState() |
@Parameter(required=true) public String key
@Parameter(required=true) public String outputKey
@Parameter(required=true) public int length
public stream.Data process(stream.Data item)
process
in interface stream.Processor
public void init(stream.ProcessContext context) throws Exception
init
in interface stream.StatefulProcessor
Exception
public void resetState() throws Exception
resetState
in interface stream.StatefulProcessor
Exception
Copyright © 2019. All rights reserved.