Package ca.uqac.lif.cep.diagnostics

Class PrintThrough

java.lang.Object
ca.uqac.lif.cep.Processor
ca.uqac.lif.cep.SynchronousProcessor
ca.uqac.lif.cep.UniformProcessor
ca.uqac.lif.cep.tmf.Passthrough
ca.uqac.lif.cep.diagnostics.PrintThrough
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 PrintThrough extends ca.uqac.lif.cep.tmf.Passthrough
A Passthrough processor that prints every event it receives to the standard output.
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
    Modifier and Type
    Field
    Description
    protected String
    m_separator
    The separator between each event

    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
    PrintThrough()
     

  • Method Summary

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

    Methods inherited from class ca.uqac.lif.cep.tmf.Passthrough

    duplicate, getState, printState, readState

    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, 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_separator

      protected String m_separator
      The separator between each event

  • Constructor Details

    • PrintThrough

      public PrintThrough()

  • Method Details

    • compute

      protected boolean compute(Object[] inputs, Object[] outputs)
      Overrides:
      compute in class ca.uqac.lif.cep.tmf.Passthrough