org.wso2.extension.siddhi.execution.unique

Class UniqueFirstTimeBatchWindowProcessor

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.UniqueTimeBatchWindowProcessor

org.wso2.extension.siddhi.execution.unique.UniqueFirstTimeBatchWindowProcessor

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 UniqueFirstTimeBatchWindowProcessor
extends UniqueTimeBatchWindowProcessor

Class representing unique first time batch Window processor implementation.

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
UniqueFirstTimeBatchWindowProcessor()

Method Summary

Modifier and Type	Method and Description
protected void	addUniqueEvent(Map<Object,org.wso2.siddhi.core.event.stream.StreamEvent> uniqueEventMap, org.wso2.siddhi.core.executor.ExpressionExecutor uniqueKeyExpressionExecutor, org.wso2.siddhi.core.event.stream.StreamEvent clonedStreamEvent)

Methods inherited from class org.wso2.extension.siddhi.execution.unique.UniqueTimeBatchWindowProcessor

compileCondition, currentState, find, getScheduler, init, process, restoreState, setScheduler, start, 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

clean, 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

clean, cloneProcessor, getNextProcessor, process, setNextProcessor, setToLast

Constructor Detail

UniqueFirstTimeBatchWindowProcessor

public UniqueFirstTimeBatchWindowProcessor()

Method Detail

addUniqueEvent

protected void addUniqueEvent(Map<Object,org.wso2.siddhi.core.event.stream.StreamEvent> uniqueEventMap,
                              org.wso2.siddhi.core.executor.ExpressionExecutor uniqueKeyExpressionExecutor,
                              org.wso2.siddhi.core.event.stream.StreamEvent clonedStreamEvent)

Overrides:

addUniqueEvent in class UniqueTimeBatchWindowProcessor