Class ApacheLogFeeder

  • 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, ca.uqac.lif.cep.Stateful

    public class ApacheLogFeeder
    extends ca.uqac.lif.cep.functions.ApplyFunction
    Converts a stream of lines from an Apache log into a stream of HTTP request objects
    Author:
    Sylvain Hallé
    • Nested Class Summary

      • Nested classes/interfaces inherited from class ca.uqac.lif.cep.functions.ApplyFunction

        ca.uqac.lif.cep.functions.ApplyFunction.ShiftTracker
      • 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.functions.ApplyFunction

        m_function, m_shiftTracker
      • 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
      ApacheLogFeeder()  
    • Method Summary

      All Methods Instance Methods Concrete Methods 
      Modifier and Type Method Description
      ApacheLogFeeder duplicate​(boolean with_state)  
      • Methods inherited from class ca.uqac.lif.cep.functions.ApplyFunction

        cloneInto, compute, getFunction, getInputTypesFor, getOutputType, getState, printState, readState, reset, toString
      • 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, getLeaves, getLeaves, getOutputArity, getOutputCount, getOutputQueue, getPullableInput, getPullableOutput, getPushableInput, getPushableOutput, hashCode, leftShift, newContext, or, or, print, read, rightShift, setContext, setContext, setPullableInput, setPushableOutput, start, startAll, stop, stopAll
      • Methods inherited from class java.lang.Object

        clone, finalize, getClass, notify, notifyAll, wait, wait, wait
    • Constructor Detail

      • ApacheLogFeeder

        public ApacheLogFeeder()
    • Method Detail

      • duplicate

        public ApacheLogFeeder duplicate​(boolean with_state)
        Specified by:
        duplicate in interface ca.uqac.lif.cep.Duplicable
        Overrides:
        duplicate in class ca.uqac.lif.cep.functions.ApplyFunction