public class PassThroughOutputRateLimiter extends OutputRateLimiter
OutputRateLimiter
which will pass through events without doing any rate limiting. This
is the default rate limiting strategy used by Siddhi.latencyTracker, lockWrapper, outputCallback, queryCallbacks, siddhiQueryContext, stateHolder
Constructor and Description |
---|
PassThroughOutputRateLimiter(String id) |
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, sendToCallBacks, setOutputCallback
public PassThroughOutputRateLimiter(String id)
protected StateFactory init()
init
in class OutputRateLimiter
public void process(ComplexEventChunk complexEventChunk)
process
in class OutputRateLimiter
public void partitionCreated()
PartitionCreationListener
Copyright © 2019. All rights reserved.