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