public class AllPerTimeOutputRateLimiter extends OutputRateLimiter<io.siddhi.core.query.output.ratelimit.time.AllPerTimeOutputRateLimiter.RateLimiterState> implements Schedulable
OutputRateLimiter
which will collect pre-defined time period and the emit all
collected events as a batch.latencyTracker, lockWrapper, outputCallback, queryCallbacks, siddhiQueryContext, stateHolder
Constructor and Description |
---|
AllPerTimeOutputRateLimiter(String id,
Long value) |
Modifier and Type | Method and Description |
---|---|
protected StateFactory<io.siddhi.core.query.output.ratelimit.time.AllPerTimeOutputRateLimiter.RateLimiterState> |
init() |
void |
partitionCreated()
Get called when partition is created
|
void |
process(ComplexEventChunk complexEventChunk) |
addQueryCallback, getOutputCallback, hasCallBack, init, sendToCallBacks, setLatencyTracker, setOutputCallback
protected StateFactory<io.siddhi.core.query.output.ratelimit.time.AllPerTimeOutputRateLimiter.RateLimiterState> init()
init
in class OutputRateLimiter<io.siddhi.core.query.output.ratelimit.time.AllPerTimeOutputRateLimiter.RateLimiterState>
public void process(ComplexEventChunk complexEventChunk)
process
in interface Schedulable
process
in class OutputRateLimiter<io.siddhi.core.query.output.ratelimit.time.AllPerTimeOutputRateLimiter.RateLimiterState>
public void partitionCreated()
PartitionCreationListener
partitionCreated
in interface PartitionCreationListener
Copyright © 2019. All rights reserved.