Package ca.uqac.lif.cep.ltl

Class FirstOrderSlice

java.lang.Object
ca.uqac.lif.cep.Processor
ca.uqac.lif.cep.SynchronousProcessor
ca.uqac.lif.cep.ltl.FirstOrderSlice
All Implemented Interfaces:
ca.uqac.lif.cep.Contextualizable, ca.uqac.lif.cep.Duplicable, ca.uqac.lif.cep.DuplicableProcessor
public class FirstOrderSlice 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 boolean
    m_boolean
     
    protected ca.uqac.lif.cep.Processor
    m_expression
     
    protected ca.uqac.lif.cep.functions.Function
    m_function
     
    protected int
    m_inputCount
     
    protected List<ca.uqac.lif.cep.Pushable>
    m_pushables
     
    protected List<ca.uqac.lif.cep.tmf.SinkLast>
    m_sinks
     
    protected List<ca.uqac.lif.cep.Processor>
    m_slices
     
    protected String
    m_varName
     

    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
    FirstOrderSlice(String var_name, ca.uqac.lif.cep.functions.Function dom_function, ca.uqac.lif.cep.Processor expression, boolean is_boolean)
     

  • Method Summary

    Modifier and Type
    Method
    Description
    protected boolean
    compute(Object[] inputs, Queue<Object[]> outputs)
     
    FirstOrderSlice
    duplicate(boolean with_state)
     
    void
    reset()
     
    void
    setContext(ca.uqac.lif.cep.Context c)
     
    void
    setContext(String key, Object value)
     

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

    getPullableOutput, getPushableInput

    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, onEndOfTrace, or, or, or, printState, readState, rightShift, 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_boolean

      protected boolean m_boolean

    • m_varName

      protected String m_varName

    • m_function

      protected ca.uqac.lif.cep.functions.Function m_function

    • m_expression

      protected ca.uqac.lif.cep.Processor m_expression

    • m_slices

      protected List<ca.uqac.lif.cep.Processor> m_slices

    • m_pushables

      protected List<ca.uqac.lif.cep.Pushable> m_pushables

    • m_sinks

      protected List<ca.uqac.lif.cep.tmf.SinkLast> m_sinks

    • m_inputCount

      protected int m_inputCount

  • Constructor Details

    • FirstOrderSlice

      public FirstOrderSlice(String var_name, ca.uqac.lif.cep.functions.Function dom_function, ca.uqac.lif.cep.Processor expression, boolean is_boolean)

  • Method Details

    • duplicate

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

    • setContext

      public void setContext(String key, Object value)
      Specified by:
      setContext in interface ca.uqac.lif.cep.Contextualizable
      Overrides:
      setContext in class ca.uqac.lif.cep.Processor

    • setContext

      public void setContext(ca.uqac.lif.cep.Context c)
      Specified by:
      setContext in interface ca.uqac.lif.cep.Contextualizable
      Overrides:
      setContext in class ca.uqac.lif.cep.Processor

    • reset

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

    • compute

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