io.siddhi.extension.execution.unique

Class UniqueFirstTimeBatchWindowProcessor

java.lang.Object

io.siddhi.core.query.processor.stream.AbstractStreamProcessor<S>

io.siddhi.core.query.processor.stream.window.WindowProcessor<io.siddhi.extension.execution.unique.UniqueTimeBatchWindowProcessor.WindowState>

io.siddhi.extension.execution.unique.UniqueTimeBatchWindowProcessor

io.siddhi.extension.execution.unique.UniqueFirstTimeBatchWindowProcessor

All Implemented Interfaces:

io.siddhi.core.query.processor.Processor, io.siddhi.core.query.processor.SchedulingProcessor, io.siddhi.core.query.processor.stream.window.FindableProcessor, io.siddhi.core.util.extension.holder.ExternalReferencedHolder

public class UniqueFirstTimeBatchWindowProcessor
extends UniqueTimeBatchWindowProcessor

Class representing unique first time batch Window processor implementation.

Field Summary

Fields inherited from class io.siddhi.core.query.processor.stream.AbstractStreamProcessor

attributeExpressionExecutors, attributeExpressionLength, complexEventPopulater, inputDefinition, metaStreamEvent, nextProcessor, siddhiQueryContext, stateHolder, streamEventClonerHolder

Constructor Summary

Constructors

Constructor and Description
UniqueFirstTimeBatchWindowProcessor()

Method Summary

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

Methods inherited from class io.siddhi.extension.execution.unique.UniqueTimeBatchWindowProcessor

compileCondition, find, getProcessingMode, getScheduler, init, processEventChunk, setScheduler, start, stop

Methods inherited from class io.siddhi.core.query.processor.stream.window.WindowProcessor

getReturnAttributes

Methods inherited from class io.siddhi.core.query.processor.stream.AbstractStreamProcessor

constructStreamEventPopulater, 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 io.siddhi.core.query.processor.Processor

getNextProcessor, process, setNextProcessor, setToLast

Constructor Detail

UniqueFirstTimeBatchWindowProcessor

public UniqueFirstTimeBatchWindowProcessor()

Method Detail

addUniqueEvent

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

Overrides:

addUniqueEvent in class UniqueTimeBatchWindowProcessor