public class FirstGroupByPerEventOutputRateLimiter extends OutputRateLimiter<io.siddhi.core.query.output.ratelimit.event.FirstGroupByPerEventOutputRateLimiter.RateLimiterState>
OutputRateLimiter
which will collect pre-defined number of events and the emit only the
first event. This implementation specifically handle queries with group by.latencyTracker, lockWrapper, outputCallback, queryCallbacks, siddhiQueryContext, stateHolder
Constructor and Description |
---|
FirstGroupByPerEventOutputRateLimiter(String id,
Integer value) |
Modifier and Type | Method and Description |
---|---|
protected StateFactory<io.siddhi.core.query.output.ratelimit.event.FirstGroupByPerEventOutputRateLimiter.RateLimiterState> |
init() |
void |
partitionCreated()
Get called when partition is created
|
void |
process(ComplexEventChunk complexEventChunk) |
addQueryCallback, getOutputCallback, hasCallBack, init, process, removeQueryCallback, sendToCallBacks, setOutputCallback
protected StateFactory<io.siddhi.core.query.output.ratelimit.event.FirstGroupByPerEventOutputRateLimiter.RateLimiterState> init()
init
in class OutputRateLimiter<io.siddhi.core.query.output.ratelimit.event.FirstGroupByPerEventOutputRateLimiter.RateLimiterState>
public void process(ComplexEventChunk complexEventChunk)
process
in class OutputRateLimiter<io.siddhi.core.query.output.ratelimit.event.FirstGroupByPerEventOutputRateLimiter.RateLimiterState>
public void partitionCreated()
PartitionCreationListener
Copyright © 2021. All rights reserved.