public class FirstGroupByPerTimeOutputRateLimiter extends OutputRateLimiter<io.siddhi.core.query.output.ratelimit.time.FirstGroupByPerTimeOutputRateLimiter.RateLimiterState> implements Schedulable
OutputRateLimiter
which will collect pre-defined time period and the emit only first
event. This implementation specifically represent GroupBy queries.latencyTracker, lockWrapper, outputCallback, queryCallbacks, siddhiQueryContext, stateHolder
Constructor and Description |
---|
FirstGroupByPerTimeOutputRateLimiter(String id,
Long value) |
Modifier and Type | Method and Description |
---|---|
protected StateFactory<io.siddhi.core.query.output.ratelimit.time.FirstGroupByPerTimeOutputRateLimiter.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.time.FirstGroupByPerTimeOutputRateLimiter.RateLimiterState> init()
init
in class OutputRateLimiter<io.siddhi.core.query.output.ratelimit.time.FirstGroupByPerTimeOutputRateLimiter.RateLimiterState>
public void process(ComplexEventChunk complexEventChunk)
process
in interface Schedulable
process
in class OutputRateLimiter<io.siddhi.core.query.output.ratelimit.time.FirstGroupByPerTimeOutputRateLimiter.RateLimiterState>
public void partitionCreated()
PartitionCreationListener
partitionCreated
in interface PartitionCreationListener
Copyright © 2021. All rights reserved.