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

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, inputDefinition, log, nextProcessor, streamEventCloner

Constructor Summary

Constructors

Constructor and Description
UniqueFirstTimeBatchWindowProcessor()

Method Summary

Methods

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

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

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

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

UniqueFirstTimeBatchWindowProcessor

public UniqueFirstTimeBatchWindowProcessor()

Method Detail

addUniqueEvent

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

Overrides:

addUniqueEvent in class UniqueTimeBatchWindowProcessor