org.wso2.extension.siddhi.execution.unique

Class UniqueFirstLengthBatchWindowProcessor

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

org.wso2.extension.siddhi.execution.unique.UniqueFirstLengthBatchWindowProcessor

All Implemented Interfaces:

org.wso2.siddhi.core.query.processor.Processor, 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 UniqueFirstLengthBatchWindowProcessor
extends UniqueLengthBatchWindowProcessor

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

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

constructFinder, currentState, find, init, process, restoreState, 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

Constructor Detail

UniqueFirstLengthBatchWindowProcessor

public UniqueFirstLengthBatchWindowProcessor()

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 UniqueLengthBatchWindowProcessor