Package ca.uqac.lif.cep.apache
Class ApacheLogFeeder
- java.lang.Object
-
- ca.uqac.lif.cep.Processor
-
- ca.uqac.lif.cep.SynchronousProcessor
-
- ca.uqac.lif.cep.UniformProcessor
-
- ca.uqac.lif.cep.functions.ApplyFunction
-
- ca.uqac.lif.cep.apache.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
-
-
Field Summary
-
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.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
-
-
-
-
Method Detail
-
duplicate
public ApacheLogFeeder duplicate(boolean with_state)
- Specified by:
duplicate
in interfaceca.uqac.lif.cep.Duplicable
- Overrides:
duplicate
in classca.uqac.lif.cep.functions.ApplyFunction
-
-