Package ca.uqac.lif.cep.ltl

Class NewQuantifier

java.lang.Object
ca.uqac.lif.cep.Processor
ca.uqac.lif.cep.SynchronousProcessor
ca.uqac.lif.cep.ltl.NewQuantifier
All Implemented Interfaces:
ca.uqac.lif.cep.Contextualizable, ca.uqac.lif.cep.Duplicable, ca.uqac.lif.cep.DuplicableProcessor
Direct Known Subclasses:
NewForAll, NewTrooleanForAll
public abstract class NewQuantifier 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.functions.Function
    m_domainFunction
     
    protected ca.uqac.lif.cep.Processor
    m_expression
     
    protected List<ca.uqac.lif.cep.Pushable>
    m_pushables
     
    protected List<ca.uqac.lif.cep.tmf.SinkLast>
    m_sinks
     
    protected String
    m_variableName
     

    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
    NewQuantifier(String variable_name, ca.uqac.lif.cep.functions.Function domain_function, ca.uqac.lif.cep.Processor expression)
     

  • Method Summary

    Modifier and Type
    Method
    Description
    protected abstract boolean
    canClean(Object o)
     
    protected abstract Object
    collectValues(List<?> values)
     
    protected boolean
    compute(Object[] inputs, Queue<Object[]> outputs)
     

    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, 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, reset, 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_variableName

      protected String m_variableName

    • m_expression

      protected ca.uqac.lif.cep.Processor m_expression

    • m_domainFunction

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

    • m_pushables

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

    • m_sinks

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

  • Constructor Details

    • NewQuantifier

      public NewQuantifier(String variable_name, ca.uqac.lif.cep.functions.Function domain_function, ca.uqac.lif.cep.Processor expression)

  • Method Details

    • compute

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

    • collectValues

      protected abstract Object collectValues(List<?> values)

    • canClean

      protected abstract boolean canClean(Object o)