Package ca.uqac.lif.cep.mtnp

Class UpdateTableArray

  • 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
    public class UpdateTableArray
extends UpdateTable
    Adds contents to a table from a stream of arrays. Each array represents a new line to add to the table.
    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.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
      UpdateTableArray​(ca.uqac.lif.mtnp.table.HardTable t)
      Creates a new instance of the processor.
      UpdateTableArray​(java.lang.String... column_names)
      Creates a new instance of the processor.
      UpdateTableArray​(java.util.List<java.lang.String> column_names)
      Creates a new instance of the processor.

    • Method Summary

      All Methods Instance Methods Concrete Methods 
      Modifier and Type Method Description
      protected boolean compute​(java.lang.Object[] inputs, java.lang.Object[] outputs)  
      UpdateTableArray duplicate​(boolean with_state)  

      • 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, getInputTypesFor, getLeaves, getLeaves, getOutputArity, getOutputCount, getOutputQueue, getOutputType, getPullableInput, getPullableOutput, getPushableInput, getPushableOutput, hashCode, leftShift, newContext, or, or, print, printState, read, 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 Detail

      • UpdateTableArray

        public UpdateTableArray​(java.lang.String... column_names)
        Creates a new instance of the processor.
        Parameters:
        column_names - The names of the columns of the table to update. Each element of an array will be the value of the attribute at the corresponding position.

      • UpdateTableArray

        public UpdateTableArray​(java.util.List<java.lang.String> column_names)
        Creates a new instance of the processor.
        Parameters:
        column_names - The names of the columns of the table to update. Each element of an array will be the value of the attribute at the corresponding position.

      • UpdateTableArray

        public UpdateTableArray​(ca.uqac.lif.mtnp.table.HardTable t)
        Creates a new instance of the processor.
        Parameters:
        t - The table where entries will be added from incoming events

    • Method Detail

      • compute

        protected boolean compute​(java.lang.Object[] inputs,
                          java.lang.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 UpdateTableArray duplicate​(boolean with_state)
        Specified by:
        duplicate in interface ca.uqac.lif.cep.Duplicable
        Specified by:
        duplicate in class ca.uqac.lif.cep.Processor