io.siddhi.extension.execution.unique

Class UniqueFirstLengthBatchWindowProcessor

java.lang.Object

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

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

io.siddhi.extension.execution.unique.UniqueLengthBatchWindowProcessor

io.siddhi.extension.execution.unique.UniqueFirstLengthBatchWindowProcessor

All Implemented Interfaces:

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

public class UniqueFirstLengthBatchWindowProcessor
extends UniqueLengthBatchWindowProcessor

Class representing unique first length 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
UniqueFirstLengthBatchWindowProcessor()

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

compileCondition, find, getProcessingMode, init, processEventChunk, 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

Constructor Detail

UniqueFirstLengthBatchWindowProcessor

public UniqueFirstLengthBatchWindowProcessor()

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 UniqueLengthBatchWindowProcessor