org.wso2.extension.siddhi.execution.unique

Class UniqueExternalTimeBatchWindowProcessor

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.unique.UniqueExternalTimeBatchWindowProcessor

All Implemented Interfaces:

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

public class UniqueExternalTimeBatchWindowProcessor
extends org.wso2.siddhi.core.query.processor.stream.window.WindowProcessor
implements org.wso2.siddhi.core.query.processor.SchedulingProcessor, org.wso2.siddhi.core.query.processor.stream.window.FindableProcessor

Field Summary

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

outputExpectsExpiredEvents

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

additionalAttributes, attributeExpressionExecutors, attributeExpressionLength, complexEventPopulater, elementId, executionPlanContext, inputDefinition, log, nextProcessor, streamEventCloner

Constructor Summary

Constructors

Constructor and Description
UniqueExternalTimeBatchWindowProcessor()

Method Summary

Methods

Modifier and Type	Method and Description
org.wso2.siddhi.core.util.collection.operator.Finder	constructFinder(org.wso2.siddhi.query.api.expression.Expression expression, org.wso2.siddhi.core.util.collection.operator.MatchingMetaStateHolder matchingMetaStateHolder, org.wso2.siddhi.core.config.ExecutionPlanContext executionPlanContext, List<org.wso2.siddhi.core.executor.VariableExpressionExecutor> variableExpressionExecutors, Map<String,org.wso2.siddhi.core.table.EventTable> eventTableMap)
Object[]	currentState()
org.wso2.siddhi.core.event.stream.StreamEvent	find(org.wso2.siddhi.core.event.state.StateEvent matchingEvent, org.wso2.siddhi.core.util.collection.operator.Finder finder)
org.wso2.siddhi.core.util.Scheduler	getScheduler()
protected void	init(org.wso2.siddhi.core.executor.ExpressionExecutor[] attributeExpressionExecutors, org.wso2.siddhi.core.config.ExecutionPlanContext executionPlanContext)
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) Here an assumption is taken: Parameter: timestamp: The time which the window determines as current time and will act upon, the value of this parameter should be monotonically increasing.
void	restoreState(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

UniqueExternalTimeBatchWindowProcessor

public UniqueExternalTimeBatchWindowProcessor()

Method Detail

init

protected void init(org.wso2.siddhi.core.executor.ExpressionExecutor[] attributeExpressionExecutors,
        org.wso2.siddhi.core.config.ExecutionPlanContext executionPlanContext)

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)

Here an assumption is taken: Parameter: timestamp: The time which the window determines as current time and will act upon, the value of this parameter should be monotonically increasing. from https://docs.wso2.com/display/CEP400/Inbuilt+Windows#InbuiltWindows-externalTime

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 Object[] currentState()

Specified by:

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

restoreState

public void restoreState(Object[] state)

Specified by:

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

setScheduler

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

Specified by:

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

getScheduler

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

Specified by:

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

find

public org.wso2.siddhi.core.event.stream.StreamEvent find(org.wso2.siddhi.core.event.state.StateEvent matchingEvent,
                                                 org.wso2.siddhi.core.util.collection.operator.Finder finder)

Specified by:

find in interface org.wso2.siddhi.core.query.processor.stream.window.FindableProcessor

constructFinder

public org.wso2.siddhi.core.util.collection.operator.Finder constructFinder(org.wso2.siddhi.query.api.expression.Expression expression,
                                                                   org.wso2.siddhi.core.util.collection.operator.MatchingMetaStateHolder matchingMetaStateHolder,
                                                                   org.wso2.siddhi.core.config.ExecutionPlanContext executionPlanContext,
                                                                   List<org.wso2.siddhi.core.executor.VariableExpressionExecutor> variableExpressionExecutors,
                                                                   Map<String,org.wso2.siddhi.core.table.EventTable> eventTableMap)

Specified by:

constructFinder in interface org.wso2.siddhi.core.query.processor.stream.window.FindableProcessor