Package ca.uqac.lif.cep.tuples

Class TupleFeeder

java.lang.Object
ca.uqac.lif.cep.Processor
ca.uqac.lif.cep.SynchronousProcessor
ca.uqac.lif.cep.tuples.TupleFeeder
All Implemented Interfaces:
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 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_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
    TupleFeeder()
    Create a new tuple feeder
    TupleFeeder(FixedTupleBuilder builder)
    Create a new tuple feeder using a predefined tuple builder

  • Method Summary

    Modifier and Type
    Method
    Description
    protected boolean
    compute(Object[] inputs, Queue<Object[]> outputs)
     
    TupleFeeder
    duplicate(boolean with_state)
     
    TupleFeeder
    setSeparator(String separator)
    Sets the character used to separate the text lines into fields

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

    getPullableOutput, getPushableInput

    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, onEndOfTrace, or, or, or, printState, 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 Details

    • m_builder

      protected FixedTupleBuilder m_builder
      The builder object used to create tuples

    • m_separator

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

  • Constructor Details

    • 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 Details

    • setSeparator

      public TupleFeeder setSeparator(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(Object[] inputs, Queue<Object[]> outputs)
      Specified by:
      compute in class ca.uqac.lif.cep.SynchronousProcessor