A C F G I O P R S U

A

addUniqueEvent(Map<Object, StreamEvent>, VariableExpressionExecutor, StreamEvent) - Method in class org.wso2.extension.siddhi.execution.unique.UniqueFirstLengthBatchWindowProcessor

addUniqueEvent(Map<Object, StreamEvent>, VariableExpressionExecutor, StreamEvent) - Method in class org.wso2.extension.siddhi.execution.unique.UniqueFirstTimeBatchWindowProcessor

addUniqueEvent(Map<Object, StreamEvent>, VariableExpressionExecutor, StreamEvent) - Method in class org.wso2.extension.siddhi.execution.unique.UniqueLengthBatchWindowProcessor

addUniqueEvent(Map<Object, StreamEvent>, VariableExpressionExecutor, StreamEvent) - Method in class org.wso2.extension.siddhi.execution.unique.UniqueTimeBatchWindowProcessor

C

constructFinder(Expression, MatchingMetaStateHolder, ExecutionPlanContext, List<VariableExpressionExecutor>, Map<String, EventTable>) - Method in class org.wso2.extension.siddhi.execution.unique.UniqueEverWindowProcessor

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.

constructFinder(Expression, MatchingMetaStateHolder, ExecutionPlanContext, List<VariableExpressionExecutor>, Map<String, EventTable>) - Method in class org.wso2.extension.siddhi.execution.unique.UniqueExternalTimeBatchWindowProcessor

constructFinder(Expression, MatchingMetaStateHolder, ExecutionPlanContext, List<VariableExpressionExecutor>, Map<String, EventTable>) - Method in class org.wso2.extension.siddhi.execution.unique.UniqueFirstWindowProcessor

constructFinder(Expression, MatchingMetaStateHolder, ExecutionPlanContext, List<VariableExpressionExecutor>, Map<String, EventTable>) - Method in class org.wso2.extension.siddhi.execution.unique.UniqueLengthBatchWindowProcessor

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.

constructFinder(Expression, MatchingMetaStateHolder, ExecutionPlanContext, List<VariableExpressionExecutor>, Map<String, EventTable>) - Method in class org.wso2.extension.siddhi.execution.unique.UniqueLengthWindowProcessor

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.

constructFinder(Expression, MatchingMetaStateHolder, ExecutionPlanContext, List<VariableExpressionExecutor>, Map<String, EventTable>) - Method in class org.wso2.extension.siddhi.execution.unique.UniqueTimeBatchWindowProcessor

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.

constructFinder(Expression, MatchingMetaStateHolder, ExecutionPlanContext, List<VariableExpressionExecutor>, Map<String, EventTable>) - Method in class org.wso2.extension.siddhi.execution.unique.UniqueTimeWindowProcessor

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.

currentState() - Method in class org.wso2.extension.siddhi.execution.unique.UniqueEverWindowProcessor

Used to collect the serializable state of the processing element, that need to be persisted for the reconstructing the element to the same state on a different point of time

currentState() - Method in class org.wso2.extension.siddhi.execution.unique.UniqueExternalTimeBatchWindowProcessor

currentState() - Method in class org.wso2.extension.siddhi.execution.unique.UniqueFirstWindowProcessor

currentState() - Method in class org.wso2.extension.siddhi.execution.unique.UniqueLengthBatchWindowProcessor

Used to collect the serializable state of the processing element, that need to be persisted for the reconstructing the element to the same state on a different point of time.

currentState() - Method in class org.wso2.extension.siddhi.execution.unique.UniqueLengthWindowProcessor

Used to collect the serializable state of the processing element, that need to be persisted for the reconstructing the element to the same state on a different point of time

currentState() - Method in class org.wso2.extension.siddhi.execution.unique.UniqueTimeBatchWindowProcessor

Used to collect the serializable state of the processing element, that need to be persisted for the reconstructing the element to the same state on a different point of time.

currentState() - Method in class org.wso2.extension.siddhi.execution.unique.UniqueTimeWindowProcessor

Used to collect the serializable state of the processing element, that need to be persisted for the reconstructing the element to the same state on a different point of time

F

find(StateEvent, Finder) - Method in class org.wso2.extension.siddhi.execution.unique.UniqueEverWindowProcessor

To find events from the processor event pool, that the matches the matchingEvent based on finder logic.

find(StateEvent, Finder) - Method in class org.wso2.extension.siddhi.execution.unique.UniqueExternalTimeBatchWindowProcessor

find(StateEvent, Finder) - Method in class org.wso2.extension.siddhi.execution.unique.UniqueFirstWindowProcessor

find(StateEvent, Finder) - Method in class org.wso2.extension.siddhi.execution.unique.UniqueLengthBatchWindowProcessor

To find events from the processor event pool, that the matches the matchingEvent based on finder logic.

find(StateEvent, Finder) - Method in class org.wso2.extension.siddhi.execution.unique.UniqueLengthWindowProcessor

To find events from the processor event pool, that the matches the matchingEvent based on finder logic.

find(StateEvent, Finder) - Method in class org.wso2.extension.siddhi.execution.unique.UniqueTimeBatchWindowProcessor

To find events from the processor event pool, that the matches the matchingEvent based on finder logic.

find(StateEvent, Finder) - Method in class org.wso2.extension.siddhi.execution.unique.UniqueTimeWindowProcessor

To find events from the processor event pool, that the matches the matchingEvent based on finder logic.

G

getScheduler() - Method in class org.wso2.extension.siddhi.execution.unique.UniqueExternalTimeBatchWindowProcessor

getScheduler() - Method in class org.wso2.extension.siddhi.execution.unique.UniqueTimeBatchWindowProcessor

The getScheduler method of the TimeWindowProcessor, As scheduler is private variable, to access publicly we use this getter method.

getScheduler() - Method in class org.wso2.extension.siddhi.execution.unique.UniqueTimeWindowProcessor

The getScheduler method of the TimeWindowProcessor, As scheduler is private variable, to access publicly we use this getter method.

I

init(ExpressionExecutor[], ExecutionPlanContext) - Method in class org.wso2.extension.siddhi.execution.unique.UniqueEverWindowProcessor

The init method of the WindowProcessor, this method will be called before other methods

init(ExpressionExecutor[], ExecutionPlanContext) - Method in class org.wso2.extension.siddhi.execution.unique.UniqueExternalTimeBatchWindowProcessor

init(ExpressionExecutor[], ExecutionPlanContext) - Method in class org.wso2.extension.siddhi.execution.unique.UniqueFirstWindowProcessor

init(ExpressionExecutor[], ExecutionPlanContext) - Method in class org.wso2.extension.siddhi.execution.unique.UniqueLengthBatchWindowProcessor

The init method of the WindowProcessor, this method will be called before other methods.

init(ExpressionExecutor[], ExecutionPlanContext) - Method in class org.wso2.extension.siddhi.execution.unique.UniqueLengthWindowProcessor

The init method of the WindowProcessor, this method will be called before other methods

init(ExpressionExecutor[], ExecutionPlanContext) - Method in class org.wso2.extension.siddhi.execution.unique.UniqueTimeBatchWindowProcessor

The init method of the WindowProcessor, this method will be called before other methods.

init(ExpressionExecutor[], ExecutionPlanContext) - Method in class org.wso2.extension.siddhi.execution.unique.UniqueTimeWindowProcessor

The init method of the WindowProcessor, this method will be called before other methods

O

org.wso2.extension.siddhi.execution.unique - package org.wso2.extension.siddhi.execution.unique

P

process(ComplexEventChunk<StreamEvent>, Processor, StreamEventCloner) - Method in class org.wso2.extension.siddhi.execution.unique.UniqueEverWindowProcessor

The main processing method that will be called upon event arrival

process(ComplexEventChunk<StreamEvent>, Processor, StreamEventCloner) - Method in class org.wso2.extension.siddhi.execution.unique.UniqueExternalTimeBatchWindowProcessor

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.

process(ComplexEventChunk<StreamEvent>, Processor, StreamEventCloner) - Method in class org.wso2.extension.siddhi.execution.unique.UniqueFirstWindowProcessor

process(ComplexEventChunk<StreamEvent>, Processor, StreamEventCloner) - Method in class org.wso2.extension.siddhi.execution.unique.UniqueLengthBatchWindowProcessor

The main processing method that will be called upon event arrival.

process(ComplexEventChunk<StreamEvent>, Processor, StreamEventCloner) - Method in class org.wso2.extension.siddhi.execution.unique.UniqueLengthWindowProcessor

The main processing method that will be called upon event arrival

process(ComplexEventChunk<StreamEvent>, Processor, StreamEventCloner) - Method in class org.wso2.extension.siddhi.execution.unique.UniqueTimeBatchWindowProcessor

The main processing method that will be called upon event arrival

process(ComplexEventChunk<StreamEvent>, Processor, StreamEventCloner) - Method in class org.wso2.extension.siddhi.execution.unique.UniqueTimeWindowProcessor

The main processing method that will be called upon event arrival

R

restoreState(Object[]) - Method in class org.wso2.extension.siddhi.execution.unique.UniqueEverWindowProcessor

Used to restore serialized state of the processing element, for reconstructing the element to the same state as if was on a previous point of time.

restoreState(Object[]) - Method in class org.wso2.extension.siddhi.execution.unique.UniqueExternalTimeBatchWindowProcessor

restoreState(Object[]) - Method in class org.wso2.extension.siddhi.execution.unique.UniqueFirstWindowProcessor

restoreState(Object[]) - Method in class org.wso2.extension.siddhi.execution.unique.UniqueLengthBatchWindowProcessor

Used to restore serialized state of the processing element, for reconstructing the element to the same state as if was on a previous point of time.

restoreState(Object[]) - Method in class org.wso2.extension.siddhi.execution.unique.UniqueLengthWindowProcessor

Used to restore serialized state of the processing element, for reconstructing the element to the same state as if was on a previous point of time.

restoreState(Object[]) - Method in class org.wso2.extension.siddhi.execution.unique.UniqueTimeBatchWindowProcessor

Used to restore serialized state of the processing element, for reconstructing the element to the same state as if was on a previous point of time.

restoreState(Object[]) - Method in class org.wso2.extension.siddhi.execution.unique.UniqueTimeWindowProcessor

Used to restore serialized state of the processing element, for reconstructing the element to the same state as if was on a previous point of time.

S

setScheduler(Scheduler) - Method in class org.wso2.extension.siddhi.execution.unique.UniqueExternalTimeBatchWindowProcessor

setScheduler(Scheduler) - Method in class org.wso2.extension.siddhi.execution.unique.UniqueTimeBatchWindowProcessor

The setScheduler method of the TimeWindowProcessor, As scheduler is private variable, to access publicly we use this setter method.

setScheduler(Scheduler) - Method in class org.wso2.extension.siddhi.execution.unique.UniqueTimeWindowProcessor

The setScheduler method of the TimeWindowProcessor, As scheduler is private variable, to access publicly we use this setter method.

start() - Method in class org.wso2.extension.siddhi.execution.unique.UniqueEverWindowProcessor

This will be called only once and this can be used to acquire required resources for the processing element.

start() - Method in class org.wso2.extension.siddhi.execution.unique.UniqueExternalTimeBatchWindowProcessor

start() - Method in class org.wso2.extension.siddhi.execution.unique.UniqueFirstWindowProcessor

start() - Method in class org.wso2.extension.siddhi.execution.unique.UniqueLengthBatchWindowProcessor

This will be called after initializing the system and before starting to process the events.

start() - Method in class org.wso2.extension.siddhi.execution.unique.UniqueLengthWindowProcessor

This will be called only once and this can be used to acquire required resources for the processing element.

start() - Method in class org.wso2.extension.siddhi.execution.unique.UniqueTimeBatchWindowProcessor

This will be called after initializing the system and before starting to process the events.

start() - Method in class org.wso2.extension.siddhi.execution.unique.UniqueTimeWindowProcessor

This will be called only once and this can be used to acquire required resources for the processing element.

stop() - Method in class org.wso2.extension.siddhi.execution.unique.UniqueEverWindowProcessor

This will be called only once and this can be used to release the acquired resources for processing.

stop() - Method in class org.wso2.extension.siddhi.execution.unique.UniqueExternalTimeBatchWindowProcessor

stop() - Method in class org.wso2.extension.siddhi.execution.unique.UniqueFirstWindowProcessor

stop() - Method in class org.wso2.extension.siddhi.execution.unique.UniqueLengthBatchWindowProcessor

This will be called before shutting down the system.

stop() - Method in class org.wso2.extension.siddhi.execution.unique.UniqueLengthWindowProcessor

This will be called only once and this can be used to release the acquired resources for processing.

stop() - Method in class org.wso2.extension.siddhi.execution.unique.UniqueTimeBatchWindowProcessor

This will be called before shutting down the system.

stop() - Method in class org.wso2.extension.siddhi.execution.unique.UniqueTimeWindowProcessor

This will be called only once and this can be used to release the acquired resources for processing.

U

UniqueEverWindowProcessor - Class in org.wso2.extension.siddhi.execution.unique

UniqueEverWindowProcessor() - Constructor for class org.wso2.extension.siddhi.execution.unique.UniqueEverWindowProcessor

UniqueExternalTimeBatchWindowProcessor - Class in org.wso2.extension.siddhi.execution.unique

UniqueExternalTimeBatchWindowProcessor() - Constructor for class org.wso2.extension.siddhi.execution.unique.UniqueExternalTimeBatchWindowProcessor

UniqueFirstLengthBatchWindowProcessor - Class in org.wso2.extension.siddhi.execution.unique

UniqueFirstLengthBatchWindowProcessor() - Constructor for class org.wso2.extension.siddhi.execution.unique.UniqueFirstLengthBatchWindowProcessor

UniqueFirstTimeBatchWindowProcessor - Class in org.wso2.extension.siddhi.execution.unique

UniqueFirstTimeBatchWindowProcessor() - Constructor for class org.wso2.extension.siddhi.execution.unique.UniqueFirstTimeBatchWindowProcessor

UniqueFirstWindowProcessor - Class in org.wso2.extension.siddhi.execution.unique

UniqueFirstWindowProcessor() - Constructor for class org.wso2.extension.siddhi.execution.unique.UniqueFirstWindowProcessor

UniqueLengthBatchWindowProcessor - Class in org.wso2.extension.siddhi.execution.unique

UniqueLengthBatchWindowProcessor() - Constructor for class org.wso2.extension.siddhi.execution.unique.UniqueLengthBatchWindowProcessor

UniqueLengthWindowProcessor - Class in org.wso2.extension.siddhi.execution.unique

UniqueLengthWindowProcessor() - Constructor for class org.wso2.extension.siddhi.execution.unique.UniqueLengthWindowProcessor

UniqueTimeBatchWindowProcessor - Class in org.wso2.extension.siddhi.execution.unique

UniqueTimeBatchWindowProcessor() - Constructor for class org.wso2.extension.siddhi.execution.unique.UniqueTimeBatchWindowProcessor

UniqueTimeWindowProcessor - Class in org.wso2.extension.siddhi.execution.unique

UniqueTimeWindowProcessor() - Constructor for class org.wso2.extension.siddhi.execution.unique.UniqueTimeWindowProcessor

A C F G I O P R S U