Package ca.uqac.lif.cep.tuples

Class From

  • All Implemented Interfaces:
    ca.uqac.lif.azrael.Printable, ca.uqac.lif.azrael.Readable, ca.uqac.lif.cep.Contextualizable, ca.uqac.lif.cep.Duplicable, ca.uqac.lif.cep.DuplicableProcessor, ca.uqac.lif.cep.Stateful
    public class From
extends ca.uqac.lif.cep.functions.ApplyFunction
    Creates an TupleExpression from a set of input tuples and an array of names. This performs roughly the same function as the FROM clause in an SQL statement.

    Caveat emptor: The input processors of FROM must be distinct. If the same processor instance occurs multiple times, it will be pulled more than once. (Note though that this applies to any n-ary processor.)

    Author:
    Sylvain Hallé

    • Nested Class Summary

      • Nested classes/interfaces inherited from class ca.uqac.lif.cep.functions.ApplyFunction

        ca.uqac.lif.cep.functions.ApplyFunction.ShiftTracker

      • 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 inherited from class ca.uqac.lif.cep.functions.ApplyFunction

        m_function, m_shiftTracker

      • 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_eventTracker, m_hasBeenNotifiedOfEndOfTrace, m_inputArity, m_inputCount, m_inputPullables, m_inputQueues, m_notifiedEndOfTraceDownstream, m_outputArity, m_outputCount, m_outputPushables, m_outputQueues, MAX_PULL_RETRIES, s_versionString

    • Constructor Summary

      Constructors 
      Constructor Description
      From​(FromFunction comp)  

    • Method Summary

      All Methods Static Methods Instance Methods Concrete Methods 
      Modifier and Type Method Description
      static void build​(java.util.ArrayDeque<java.lang.Object> stack)  
      java.lang.String toString()  

      • Methods inherited from class ca.uqac.lif.cep.functions.ApplyFunction

        cloneInto, compute, duplicate, getFunction, getInputTypesFor, getOutputType, getState, printState, readState, reset

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

        compute, getPullableOutput, getPushableInput, onEndOfTrace, onEndOfTrace

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

        setEventTracker

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

        allNotifiedEndOfTrace, allNull, associateTo, associateToInput, associateToOutput, copyInputQueue, copyOutputQueue, duplicate, duplicateInto, equals, getAt, getContext, getContext, getEmptyQueue, getEventTracker, getId, getInputArity, getInputCount, getInputQueue, getInputType, getLeaves, getLeaves, getOutputArity, getOutputCount, getOutputQueue, getPullableInput, getPullableOutput, getPushableInput, getPushableOutput, hashCode, leftShift, newContext, or, or, print, read, rightShift, setContext, setContext, setPullableInput, setPushableOutput, start, startAll, stop, stopAll

      • Methods inherited from class java.lang.Object

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

    • Method Detail

      • build

        public static void build​(java.util.ArrayDeque<java.lang.Object> stack)

      • toString

        public java.lang.String toString()
        Overrides:
        toString in class ca.uqac.lif.cep.functions.ApplyFunction