Package ca.uqac.lif.cep.signal

Class WindowProcessor

java.lang.Object
ca.uqac.lif.cep.Processor
ca.uqac.lif.cep.SynchronousProcessor
ca.uqac.lif.cep.signal.WindowProcessor
All Implemented Interfaces:
ca.uqac.lif.cep.Contextualizable, ca.uqac.lif.cep.Duplicable, ca.uqac.lif.cep.DuplicableProcessor
Direct Known Subclasses:
PeakFinderLocalMaximum, PeakFinderTravelRise, PlateauFinder
public abstract class WindowProcessor extends ca.uqac.lif.cep.SynchronousProcessor

  • Nested Class Summary

    Nested classes/interfaces inherited from class ca.uqac.lif.cep.SynchronousProcessor

    ca.uqac.lif.cep.SynchronousProcessor.InputPushable, ca.uqac.lif.cep.SynchronousProcessor.OutputPullable

    Nested classes/interfaces inherited from class ca.uqac.lif.cep.Processor

    ca.uqac.lif.cep.Processor.InternalProcessorState

  • Field Summary

    Fields
    Modifier and Type
    Field
    Description
    protected float
    m_maxValue
    The maximum value encountered so far
    protected float
    m_minValue
    The minimum value encountered so far
    protected Vector<Float>
    m_values
    The window of values to remember
    protected final int
    m_windowWidth
    The width of the window to process
    protected static final double
    s_precision
    The precision used to for the equality between double precision numbers

    Fields inherited from class ca.uqac.lif.cep.SynchronousProcessor

    m_inputPushables, m_outputPullables, m_tempQueue

    Fields inherited from class ca.uqac.lif.cep.Processor

    m_context, m_hasBeenNotifiedOfEndOfTrace, m_inputArity, m_inputPullables, m_inputQueues, m_notifiedEndOfTraceDownstream, m_outputArity, m_outputPushables, m_outputQueues, MAX_PULL_RETRIES, s_versionString

  • Constructor Summary

    Constructors
    Constructor
    Description
    WindowProcessor()
     
    WindowProcessor(int width)
     

  • Method Summary

    Modifier and Type
    Method
    Description
    protected abstract Float
    computeOutputValue()
     
    protected static boolean
    doubleEquals(double d1, double d2)
     
    protected float
    getMaxValue()
     
    protected float
    getMinValue()
     
    void
    reset()
     

    Methods inherited from class ca.uqac.lif.cep.SynchronousProcessor

    compute, getPullableOutput, getPushableInput

    Methods inherited from class ca.uqac.lif.cep.Processor

    allNotifiedEndOfTrace, allNull, copyInputQueue, copyOutputQueue, duplicate, duplicate, duplicateInto, equals, getAt, getContext, getContext, getEmptyQueue, getId, getInputArity, getInputQueue, getInputType, getInputTypesFor, getOutputArity, getOutputQueue, getOutputType, getPullableInput, getPullableOutput, getPushableInput, getPushableOutput, hashCode, leftShift, newContext, onEndOfTrace, or, or, or, printState, readState, rightShift, setContext, setContext, setPullableInput, setPushableOutput, start, startAll, stop, stopAll

    Methods inherited from class java.lang.Object

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

  • Field Details

    • s_precision

      protected static final double s_precision
      The precision used to for the equality between double precision numbers
      See Also:

    • m_values

      protected Vector<Float> m_values
      The window of values to remember

    • m_windowWidth

      protected final int m_windowWidth
      The width of the window to process

    • m_maxValue

      protected float m_maxValue
      The maximum value encountered so far

    • m_minValue

      protected float m_minValue
      The minimum value encountered so far

  • Constructor Details

    • WindowProcessor

      public WindowProcessor()

    • WindowProcessor

      public WindowProcessor(int width)

  • Method Details

    • reset

      public void reset()
      Overrides:
      reset in class ca.uqac.lif.cep.Processor

    • getMaxValue

      protected float getMaxValue()

    • getMinValue

      protected float getMinValue()

    • doubleEquals

      protected static boolean doubleEquals(double d1, double d2)

    • computeOutputValue

      protected abstract Float computeOutputValue()