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.Processorpublic void init(stream.ProcessContext context)
throws Exception
init in interface stream.StatefulProcessorExceptionpublic void resetState()
throws Exception
resetState in interface stream.StatefulProcessorExceptionCopyright © 2019. All rights reserved.