public class LogStreamProcessor extends StreamProcessor<State>
attributeExpressionExecutors, attributeExpressionLength, complexEventPopulater, inputDefinition, metaStreamEvent, nextProcessor, siddhiQueryContext, stateHolder, streamEventClonerHolder
Constructor and Description |
---|
LogStreamProcessor() |
Modifier and Type | Method and Description |
---|---|
ProcessingMode |
getProcessingMode()
Defines the behaviour of the processing, will be called after the init
|
List<io.siddhi.query.api.definition.Attribute> |
getReturnAttributes() |
protected StateFactory |
init(MetaStreamEvent metaStreamEvent,
io.siddhi.query.api.definition.AbstractDefinition inputDefinition,
ExpressionExecutor[] attributeExpressionExecutors,
ConfigReader configReader,
StreamEventClonerHolder streamEventClonerHolder,
boolean outputExpectsExpiredEvents,
boolean findToBeExecuted,
SiddhiQueryContext siddhiQueryContext)
The init method of the StreamFunction
|
protected void |
process(ComplexEventChunk<StreamEvent> streamEventChunk,
Processor nextProcessor,
StreamEventCloner streamEventCloner,
ComplexEventPopulater complexEventPopulater,
State state)
The main processing method that will be called upon event arrival
|
void |
start()
This will be called only once and this can be used to acquire
required resources for the processing element.
|
void |
stop()
This will be called only once and this can be used to release
the acquired resources for processing.
|
processEventChunk
constructStreamEventPopulater, getNextProcessor, initProcessor, isStateful, process, process, setNextProcessor, setStreamEventCloner, setToLast
protected StateFactory init(MetaStreamEvent metaStreamEvent, io.siddhi.query.api.definition.AbstractDefinition inputDefinition, ExpressionExecutor[] attributeExpressionExecutors, ConfigReader configReader, StreamEventClonerHolder streamEventClonerHolder, boolean outputExpectsExpiredEvents, boolean findToBeExecuted, SiddhiQueryContext siddhiQueryContext)
init
in class AbstractStreamProcessor<State>
metaStreamEvent
- the stream event metainputDefinition
- the incoming stream definitionattributeExpressionExecutors
- the executors for the function parametersconfigReader
- this hold the LogStreamProcessor
configuration reader.streamEventClonerHolder
- streamEventCloner HolderfindToBeExecuted
- find will be executedsiddhiQueryContext
- current siddhi query contextoutputExpectsExpiredEvents
- is expired events sent as outputpublic List<io.siddhi.query.api.definition.Attribute> getReturnAttributes()
getReturnAttributes
in class AbstractStreamProcessor<State>
protected void process(ComplexEventChunk<StreamEvent> streamEventChunk, Processor nextProcessor, StreamEventCloner streamEventCloner, ComplexEventPopulater complexEventPopulater, State state)
StreamProcessor
process
in class StreamProcessor<State>
streamEventChunk
- the event chunk that need to be processednextProcessor
- the next processor to which the success events need to be passedstreamEventCloner
- helps to clone the incoming event for local storage or modificationcomplexEventPopulater
- helps to populate the events with the resultant attributesstate
- current processor statepublic void start()
ExternalReferencedHolder
public void stop()
ExternalReferencedHolder
public ProcessingMode getProcessingMode()
AbstractStreamProcessor
getProcessingMode
in class AbstractStreamProcessor<State>
Copyright © 2021. All rights reserved.