public class CronWindowProcessor extends BatchingWindowProcessor<io.siddhi.core.query.processor.stream.window.CronWindowProcessor.WindowState> implements org.quartz.Job
WindowProcessor
which represent a Window operating based on a cron expression.attributeExpressionExecutors, attributeExpressionLength, complexEventPopulater, inputDefinition, metaStreamEvent, nextProcessor, siddhiQueryContext, stateHolder
Constructor and Description |
---|
CronWindowProcessor() |
Modifier and Type | Method and Description |
---|---|
void |
dispatchEvents() |
void |
execute(org.quartz.JobExecutionContext jobExecutionContext) |
protected StateFactory<io.siddhi.core.query.processor.stream.window.CronWindowProcessor.WindowState> |
init(ExpressionExecutor[] attributeExpressionExecutors,
ConfigReader configReader,
StreamEventClonerHolder streamEventClonerHolder,
boolean outputExpectsExpiredEvents,
boolean findToBeExecuted,
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.CronWindowProcessor.WindowState 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.
|
getProcessingMode, init, processEventChunk
getReturnAttributes
constructStreamEventPopulater, getNextProcessor, initProcessor, isStateful, process, process, setNextProcessor, setStreamEventCloner, setToLast
protected StateFactory<io.siddhi.core.query.processor.stream.window.CronWindowProcessor.WindowState> init(ExpressionExecutor[] attributeExpressionExecutors, ConfigReader configReader, StreamEventClonerHolder streamEventClonerHolder, boolean outputExpectsExpiredEvents, boolean findToBeExecuted, SiddhiQueryContext siddhiQueryContext)
BatchingWindowProcessor
init
in class BatchingWindowProcessor<io.siddhi.core.query.processor.stream.window.CronWindowProcessor.WindowState>
attributeExpressionExecutors
- the executors of each function parametersconfigReader
- the config reader of windowstreamEventClonerHolder
- stream event cloner holderoutputExpectsExpiredEvents
- is expired events sent as outputfindToBeExecuted
- find operation will be performedsiddhiQueryContext
- the context of the siddhi queryprotected void process(ComplexEventChunk<StreamEvent> streamEventChunk, Processor nextProcessor, StreamEventCloner streamEventCloner, io.siddhi.core.query.processor.stream.window.CronWindowProcessor.WindowState state)
BatchingWindowProcessor
process
in class BatchingWindowProcessor<io.siddhi.core.query.processor.stream.window.CronWindowProcessor.WindowState>
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 modificationstate
- current state of the processorpublic void start()
ExternalReferencedHolder
start
in interface ExternalReferencedHolder
public void stop()
ExternalReferencedHolder
stop
in interface ExternalReferencedHolder
public void dispatchEvents()
public void execute(org.quartz.JobExecutionContext jobExecutionContext) throws org.quartz.JobExecutionException
execute
in interface org.quartz.Job
org.quartz.JobExecutionException
Copyright © 2021. All rights reserved.