Package ca.uqac.lif.cep.mtnp

Class UpdateTableStream

java.lang.Object
ca.uqac.lif.cep.Processor
ca.uqac.lif.cep.SynchronousProcessor
ca.uqac.lif.cep.UniformProcessor
ca.uqac.lif.cep.mtnp.UpdateTable
ca.uqac.lif.cep.mtnp.UpdateTableStream
All Implemented Interfaces:
ca.uqac.lif.cep.Contextualizable, ca.uqac.lif.cep.Duplicable, ca.uqac.lif.cep.DuplicableProcessor
public class UpdateTableStream extends UpdateTable
Adds contents to a table from multiple streams. A new line in the table is added for every event front received by the 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.mtnp.UpdateTable

    m_table

    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
    UpdateTableStream(ca.uqac.lif.mtnp.table.HardTable t, String... column_names)
    Creates a new instance of the processor.
    UpdateTableStream(String... column_names)
    Creates a new instance of the processor.
    UpdateTableStream(List<String> column_names)
    Creates a new instance of the processor.

  • Method Summary

    Modifier and Type
    Method
    Description
    protected boolean
    compute(Object[] inputs, Object[] outputs)
     
    UpdateTableStream
    duplicate(boolean with_state)
     

    Methods inherited from class ca.uqac.lif.cep.mtnp.UpdateTable

    createEntry, 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, getInputTypesFor, getOutputArity, getOutputQueue, getOutputType, getPullableInput, getPullableOutput, getPushableInput, getPushableOutput, hashCode, leftShift, newContext, or, or, or, printState, readState, 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

  • Constructor Details

    • UpdateTableStream

      public UpdateTableStream(String... column_names)
      Creates a new instance of the processor.
      Parameters:
      column_names - The names of the columns of the table to update. Each input stream will correspond to the value of an attribute at the corresponding position.

    • UpdateTableStream

      public UpdateTableStream(List<String> column_names)
      Creates a new instance of the processor.
      Parameters:
      column_names - The names of the columns of the table to update. Each input stream will correspond to the value of an attribute at the corresponding position.

    • UpdateTableStream

      public UpdateTableStream(ca.uqac.lif.mtnp.table.HardTable t, String... column_names)
      Creates a new instance of the processor.
      Parameters:
      t - The table where entries will be added from incoming events
      column_names - The names of the columns of the table to update. Each input stream will correspond to the value of an attribute at the corresponding position.

  • Method Details

    • compute

      protected boolean compute(Object[] inputs, Object[] outputs) throws ca.uqac.lif.cep.ProcessorException
      Specified by:
      compute in class ca.uqac.lif.cep.UniformProcessor
      Throws:
      ca.uqac.lif.cep.ProcessorException

    • duplicate

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