Package ca.uqac.lif.cep.tuples

Class From

java.lang.Object
ca.uqac.lif.cep.Processor
ca.uqac.lif.cep.SynchronousProcessor
ca.uqac.lif.cep.UniformProcessor
ca.uqac.lif.cep.functions.ApplyFunction
ca.uqac.lif.cep.tuples.From
All Implemented Interfaces:
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.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

    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
    From(FromFunction comp)
     

  • Method Summary

    Modifier and Type
    Method
    Description
    static void
    build(ArrayDeque<Object> stack)
     
    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.Processor

    allNotifiedEndOfTrace, allNull, copyInputQueue, copyOutputQueue, duplicate, duplicateInto, equals, getAt, getContext, getContext, getEmptyQueue, getId, getInputArity, getInputQueue, getInputType, getOutputArity, getOutputQueue, getPullableInput, getPullableOutput, getPushableInput, getPushableOutput, hashCode, leftShift, newContext, or, or, or, rightShift, setContext, setContext, setPullableInput, setPushableOutput, start, startAll, stop, stopAll

    Methods inherited from class java.lang.Object

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

  • Constructor Details

  • Method Details

    • build

      public static void build(ArrayDeque<Object> stack)

    • toString

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