public class DelayWindowProcessor extends TimeWindowProcessor
WindowProcessor
which represent a Window operating based on delay time.attributeExpressionExecutors, attributeExpressionLength, complexEventPopulater, inputDefinition, metaStreamEvent, nextProcessor, stateHolder, streamEventClonerHolder
Constructor and Description |
---|
DelayWindowProcessor() |
Modifier and Type | Method and Description |
---|---|
CompiledCondition |
compileCondition(io.siddhi.query.api.expression.Expression condition,
MatchingMetaInfoHolder matchingMetaInfoHolder,
List<VariableExpressionExecutor> variableExpressionExecutors,
Map<String,Table> tableMap,
io.siddhi.core.query.processor.stream.window.TimeWindowProcessor.WindowState state,
SiddhiQueryContext siddhiQueryContext)
To construct a finder having the capability of finding events at the processor that corresponds to the incoming
matchingEvent and the given matching expression logic.
|
StreamEvent |
find(StateEvent matchingEvent,
CompiledCondition compiledCondition,
StreamEventCloner streamEventCloner,
io.siddhi.core.query.processor.stream.window.TimeWindowProcessor.WindowState state)
To find events from the processor event pool, that the matches the matchingEvent based on finder logic.
|
protected StateFactory |
init(ExpressionExecutor[] attributeExpressionExecutors,
ConfigReader configReader,
SiddhiQueryContext siddhiQueryContext)
The init method of the WindowProcessor, this method will be called before other methods
|
protected void |
process(ComplexEventChunk<StreamEvent> streamEventChunk,
Processor nextProcessor,
StreamEventCloner streamEventCloner,
io.siddhi.core.query.processor.stream.window.TimeWindowProcessor.WindowState windowState)
The main processing method that will be called upon event arrival
|
getScheduler, setScheduler, start, stop
compileCondition, find
getProcessingMode, init, processEventChunk
getReturnAttributes
constructStreamEventPopulater, getNextProcessor, initProcessor, process, setNextProcessor, setStreamEventCloner, setToLast
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
getNextProcessor, process, setNextProcessor, setToLast
protected StateFactory init(ExpressionExecutor[] attributeExpressionExecutors, ConfigReader configReader, SiddhiQueryContext siddhiQueryContext)
SlidingWindowProcessor
init
in class TimeWindowProcessor
attributeExpressionExecutors
- the executors of each function parametersconfigReader
- the config reader of windowsiddhiQueryContext
- the context of the siddhi queryprotected void process(ComplexEventChunk<StreamEvent> streamEventChunk, Processor nextProcessor, StreamEventCloner streamEventCloner, io.siddhi.core.query.processor.stream.window.TimeWindowProcessor.WindowState windowState)
SlidingWindowProcessor
process
in class TimeWindowProcessor
streamEventChunk
- the stream 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 modificationwindowState
- current query statepublic StreamEvent find(StateEvent matchingEvent, CompiledCondition compiledCondition, StreamEventCloner streamEventCloner, io.siddhi.core.query.processor.stream.window.TimeWindowProcessor.WindowState state)
SlidingFindableWindowProcessor
find
in class TimeWindowProcessor
matchingEvent
- the event to be matched with the events at the processorcompiledCondition
- the execution element responsible for matching the corresponding events that matches
the matchingEvent based on pool of events at ProcessorstreamEventCloner
- stream event clonerstate
- current query state @return the matched eventspublic CompiledCondition compileCondition(io.siddhi.query.api.expression.Expression condition, MatchingMetaInfoHolder matchingMetaInfoHolder, List<VariableExpressionExecutor> variableExpressionExecutors, Map<String,Table> tableMap, io.siddhi.core.query.processor.stream.window.TimeWindowProcessor.WindowState state, SiddhiQueryContext siddhiQueryContext)
SlidingFindableWindowProcessor
compileCondition
in class TimeWindowProcessor
condition
- the matching conditionmatchingMetaInfoHolder
- the meta structure of the incoming matchingEventvariableExpressionExecutors
- the list of variable ExpressionExecutors already createdtableMap
- map of event tablesstate
- current query statesiddhiQueryContext
- current siddhi query contextCopyright © 2019. All rights reserved.