Package ca.uqac.lif.cep.signal

Class Persist

java.lang.Object
ca.uqac.lif.cep.Processor
ca.uqac.lif.cep.SynchronousProcessor
ca.uqac.lif.cep.UniformProcessor
ca.uqac.lif.cep.signal.Persist
All Implemented Interfaces:
ca.uqac.lif.cep.Contextualizable, ca.uqac.lif.cep.Duplicable, ca.uqac.lif.cep.DuplicableProcessor
public class Persist extends ca.uqac.lif.cep.UniformProcessor
Persists a locally maximal value for a certain amount of time.
Author:
Sylvain Hallé

  • Nested Class Summary

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

    ca.uqac.lif.cep.UniformProcessor.UnaryPullable, ca.uqac.lif.cep.UniformProcessor.UnaryPushable

    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_lastValue
     
    protected int
    m_timeSinceLast
     
    protected int
    m_width
     

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

    m_outputArray

    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
    Persist(int width)
    Creates a new decay processor

  • Method Summary

    Modifier and Type
    Method
    Description
    protected boolean
    compute(Object[] inputs, Object[] outputs)
     
    Persist
    duplicate(boolean with_state)
     
    void
    reset()
     

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

    compute, getPullableOutput, getPushableInput, onEndOfTrace, onEndOfTrace

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

    allNotifiedEndOfTrace, allNull, copyInputQueue, copyOutputQueue, duplicate, duplicateInto, equals, getAt, getContext, getContext, getEmptyQueue, getId, getInputArity, getInputQueue, getInputType, getInputTypesFor, getOutputArity, getOutputQueue, getOutputType, getPullableInput, getPullableOutput, getPushableInput, getPushableOutput, hashCode, leftShift, newContext, 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

    • m_width

      protected int m_width

    • m_lastValue

      protected float m_lastValue

    • m_timeSinceLast

      protected int m_timeSinceLast

  • Constructor Details

    • Persist

      public Persist(int width)
      Creates a new decay processor
      Parameters:
      width - The width of the window

  • Method Details

    • compute

      protected boolean compute(Object[] inputs, Object[] outputs)
      Specified by:
      compute in class ca.uqac.lif.cep.UniformProcessor

    • duplicate

      public Persist duplicate(boolean with_state)
      Specified by:
      duplicate in interface ca.uqac.lif.cep.Duplicable
      Specified by:
      duplicate in class ca.uqac.lif.cep.Processor

    • reset

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