Class FirstOrderQuantifier

java.lang.Object
ca.uqac.lif.cep.Processor
ca.uqac.lif.cep.SynchronousProcessor
ca.uqac.lif.cep.ltl.FirstOrderQuantifier
All Implemented Interfaces:
ca.uqac.lif.cep.Contextualizable, ca.uqac.lif.cep.Duplicable, ca.uqac.lif.cep.DuplicableProcessor
Direct Known Subclasses:
BooleanFirstOrderQuantifier, Every, Exists, ForAll, Some

public abstract class FirstOrderQuantifier 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 ca.uqac.lif.cep.tmf.SinkLast
     
    protected FirstOrderSlice
     
    protected ca.uqac.lif.cep.Pushable
     

    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
    Modifier
    Constructor
    Description
    protected
     
     
    FirstOrderQuantifier(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
    abstract Object
    combineValues(List<?> values)
     
    protected boolean
    compute(Object[] inputs, Queue<Object[]> outputs)
     
    void
    duplicateInto(ca.uqac.lif.cep.Processor p)
     
    void
     
    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, duplicate, 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_slicer

      protected FirstOrderSlice m_slicer
    • m_slicerPushable

      protected ca.uqac.lif.cep.Pushable m_slicerPushable
    • m_sink

      protected ca.uqac.lif.cep.tmf.SinkLast m_sink
  • Constructor Details

    • FirstOrderQuantifier

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

      protected FirstOrderQuantifier(FirstOrderSlice fos)
  • Method Details

    • 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
    • duplicateInto

      public void duplicateInto(ca.uqac.lif.cep.Processor p)
      Overrides:
      duplicateInto 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
    • combineValues

      public abstract Object combineValues(List<?> values)