Package ca.uqac.lif.cep.tuples

Class TupleFeeder

  • 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 TupleFeeder
extends ca.uqac.lif.cep.SynchronousProcessor
    Creates a feed of events from CRLF-separated string chunks. Note that the input feed must have a trailing CRLF for all elements, including the last.
    Author:
    Sylvain Hallé

    • 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 FixedTupleBuilder m_builder
      The builder object used to create tuples
      protected java.lang.String m_separator
      The character used to separate the text lines into fields

      • 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
      TupleFeeder()
      Create a new tuple feeder
      TupleFeeder​(FixedTupleBuilder builder)
      Create a new tuple feeder using a predefined tuple builder

    • Method Summary

      All Methods Instance Methods Concrete Methods 
      Modifier and Type Method Description
      protected boolean compute​(java.lang.Object[] inputs, java.util.Queue<java.lang.Object[]> outputs)  
      TupleFeeder duplicate​(boolean with_state)  
      TupleFeeder setSeparator​(java.lang.String separator)
      Sets the character used to separate the text lines into fields

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

        getPullableOutput, getPushableInput, 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, onEndOfTrace, or, or, print, printState, read, 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 Detail

      • m_builder

        protected FixedTupleBuilder m_builder
        The builder object used to create tuples

      • m_separator

        protected java.lang.String m_separator
        The character used to separate the text lines into fields

    • Constructor Detail

      • TupleFeeder

        public TupleFeeder()
        Create a new tuple feeder

      • TupleFeeder

        public TupleFeeder​(FixedTupleBuilder builder)
        Create a new tuple feeder using a predefined tuple builder
        Parameters:
        builder - The tuple buidler

    • Method Detail

      • setSeparator

        public TupleFeeder setSeparator​(java.lang.String separator)
        Sets the character used to separate the text lines into fields
        Parameters:
        separator - The separator
        Returns:
        This tuple feeder

      • duplicate

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

      • compute

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