org.wso2.extension.siddhi.execution.env

Class ResourceBatchWindowProcessor

java.lang.Object

org.wso2.siddhi.core.query.processor.stream.AbstractStreamProcessor

org.wso2.siddhi.core.query.processor.stream.window.WindowProcessor

org.wso2.extension.siddhi.execution.env.ResourceBatchWindowProcessor

All Implemented Interfaces:

org.wso2.siddhi.core.query.processor.Processor, org.wso2.siddhi.core.query.processor.SchedulingProcessor, org.wso2.siddhi.core.util.extension.holder.EternalReferencedHolder, org.wso2.siddhi.core.util.snapshot.Snapshotable

public class ResourceBatchWindowProcessor
extends org.wso2.siddhi.core.query.processor.stream.window.WindowProcessor
implements org.wso2.siddhi.core.query.processor.SchedulingProcessor

Implementation of WindowProcessor which represent a Resource Batch Window operating based on the inferred resources count from env:resourceIdentify extension as length.

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
static class	ResourceBatchWindowProcessor.ResourceStreamEventList Resource Stream Event List internal data structure.

Field Summary

Fields inherited from class org.wso2.siddhi.core.query.processor.stream.AbstractStreamProcessor

additionalAttributes, attributeExpressionExecutors, attributeExpressionLength, complexEventPopulater, elementId, inputDefinition, nextProcessor, queryName, streamEventCloner, streamEventClonerHolder

Constructor Summary

Constructors

Constructor and Description
ResourceBatchWindowProcessor()

Method Summary

Modifier and Type	Method and Description
Map<String,Object>	currentState()
org.wso2.siddhi.core.util.Scheduler	getScheduler()
protected void	init(org.wso2.siddhi.core.executor.ExpressionExecutor[] attributeExpressionExecutors, org.wso2.siddhi.core.util.config.ConfigReader configReader, boolean outputExpectsExpiredEvents, org.wso2.siddhi.core.config.SiddhiAppContext siddhiAppContext)
protected void	process(org.wso2.siddhi.core.event.ComplexEventChunk<org.wso2.siddhi.core.event.stream.StreamEvent> streamEventChunk, org.wso2.siddhi.core.query.processor.Processor nextProcessor, org.wso2.siddhi.core.event.stream.StreamEventCloner streamEventCloner)
void	restoreState(Map<String,Object> state)
void	setScheduler(org.wso2.siddhi.core.util.Scheduler scheduler)
void	start()
void	stop()

Methods inherited from class org.wso2.siddhi.core.query.processor.stream.window.WindowProcessor

init, processEventChunk

Methods inherited from class org.wso2.siddhi.core.query.processor.stream.AbstractStreamProcessor

cloneProcessor, constructStreamEventPopulater, getElementId, getNextProcessor, initProcessor, process, setNextProcessor, setStreamEventCloner, setToLast

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Methods inherited from interface org.wso2.siddhi.core.query.processor.Processor

cloneProcessor, getNextProcessor, process, setNextProcessor, setToLast

Constructor Detail

ResourceBatchWindowProcessor

public ResourceBatchWindowProcessor()

Method Detail

init

protected void init(org.wso2.siddhi.core.executor.ExpressionExecutor[] attributeExpressionExecutors,
                    org.wso2.siddhi.core.util.config.ConfigReader configReader,
                    boolean outputExpectsExpiredEvents,
                    org.wso2.siddhi.core.config.SiddhiAppContext siddhiAppContext)

Specified by:

init in class org.wso2.siddhi.core.query.processor.stream.window.WindowProcessor

process

protected void process(org.wso2.siddhi.core.event.ComplexEventChunk<org.wso2.siddhi.core.event.stream.StreamEvent> streamEventChunk,
                       org.wso2.siddhi.core.query.processor.Processor nextProcessor,
                       org.wso2.siddhi.core.event.stream.StreamEventCloner streamEventCloner)

Specified by:

process in class org.wso2.siddhi.core.query.processor.stream.window.WindowProcessor

start

public void start()

Specified by:

start in interface org.wso2.siddhi.core.util.extension.holder.EternalReferencedHolder

stop

public void stop()

Specified by:

stop in interface org.wso2.siddhi.core.util.extension.holder.EternalReferencedHolder

currentState

public Map<String,Object> currentState()

Specified by:

currentState in interface org.wso2.siddhi.core.util.snapshot.Snapshotable

restoreState

public void restoreState(Map<String,Object> state)

Specified by:

restoreState in interface org.wso2.siddhi.core.util.snapshot.Snapshotable

getScheduler

public org.wso2.siddhi.core.util.Scheduler getScheduler()

Specified by:

getScheduler in interface org.wso2.siddhi.core.query.processor.SchedulingProcessor

setScheduler

public void setScheduler(org.wso2.siddhi.core.util.Scheduler scheduler)

Specified by:

setScheduler in interface org.wso2.siddhi.core.query.processor.SchedulingProcessor