fact.filter

Class MovingAverage

java.lang.Object

fact.filter.MovingAverage

All Implemented Interfaces:

stream.Processor, stream.StatefulProcessor

public class MovingAverage
extends Object
implements stream.StatefulProcessor

This is processor applies a central moving average to the time series in the camera raw data (NPIX*ROI). This is essentially a smoothing operation. It takes the mean value within a given window of the timeseries and applies that value to the pivot element.

Central means it has one pivot element in the center of the window and the same number of elements left and right to it. This implies that only uneven window lengths are supported.

This is a somewhat naive implementation which could be made much faster. See the Wikipedia article at https://en.wikipedia.org/wiki/Moving_average

Author:

Kai Bruegge <kai.bruegge@tu-dortmund.de>

Field Summary

Fields

Modifier and Type	Field and Description
String	key
int	length
String	outputKey

Constructor Summary

Constructors

Constructor and Description
MovingAverage()

Method Summary

Modifier and Type	Method and Description
void	finish()
void	init(stream.ProcessContext context)
stream.Data	process(stream.Data item)
void	resetState()

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Field Detail

key

@Parameter(required=true)
public String key

outputKey

@Parameter(required=true)
public String outputKey

length

@Parameter(required=true)
public int length

Constructor Detail

MovingAverage

public MovingAverage()

Method Detail

process

public stream.Data process(stream.Data item)

Specified by:

process in interface stream.Processor

init

public void init(stream.ProcessContext context)
          throws Exception

Specified by:

init in interface stream.StatefulProcessor

Throws:

Exception

resetState

public void resetState()
                throws Exception

Specified by:

resetState in interface stream.StatefulProcessor

Throws:

Exception

finish

public void finish()
            throws Exception

Specified by:

finish in interface stream.StatefulProcessor

Throws:

Exception