public class AllPerEventOutputRateLimiter extends OutputRateLimiter<io.siddhi.core.query.output.ratelimit.event.AllPerEventOutputRateLimiter.RateLimiterState>
OutputRateLimiter
which will collect pre-defined number of events and the emit all
collected events as a batch.latencyTracker, lockWrapper, outputCallback, queryCallbacks, siddhiQueryContext, stateHolder
Constructor and Description |
---|
AllPerEventOutputRateLimiter(String id,
Integer value) |
Modifier and Type | Method and Description |
---|---|
protected StateFactory<io.siddhi.core.query.output.ratelimit.event.AllPerEventOutputRateLimiter.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.AllPerEventOutputRateLimiter.RateLimiterState> init()
init
in class OutputRateLimiter<io.siddhi.core.query.output.ratelimit.event.AllPerEventOutputRateLimiter.RateLimiterState>
public void process(ComplexEventChunk complexEventChunk)
process
in class OutputRateLimiter<io.siddhi.core.query.output.ratelimit.event.AllPerEventOutputRateLimiter.RateLimiterState>
public void partitionCreated()
PartitionCreationListener
Copyright © 2021. All rights reserved.