S
- current state of the RateLimiterpublic abstract class OutputRateLimiter<S extends State> extends Object implements PartitionCreationListener
Modifier and Type | Field and Description |
---|---|
protected LatencyTracker |
latencyTracker |
protected LockWrapper |
lockWrapper |
protected OutputCallback |
outputCallback |
protected List<QueryCallback> |
queryCallbacks |
protected SiddhiQueryContext |
siddhiQueryContext |
protected StateHolder<S> |
stateHolder |
Constructor and Description |
---|
OutputRateLimiter() |
Modifier and Type | Method and Description |
---|---|
void |
addQueryCallback(QueryCallback callback) |
OutputCallback |
getOutputCallback() |
boolean |
hasCallBack() |
protected abstract StateFactory<S> |
init() |
void |
init(LockWrapper lockWrapper,
boolean groupBy,
SiddhiQueryContext siddhiQueryContext) |
abstract void |
process(ComplexEventChunk complexEventChunk) |
void |
process(List<ComplexEventChunk> complexEventChunks) |
void |
removeQueryCallback(QueryCallback callback) |
void |
sendToCallBacks(ComplexEventChunk complexEventChunk) |
void |
setOutputCallback(OutputCallback outputCallback) |
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
partitionCreated
protected List<QueryCallback> queryCallbacks
protected OutputCallback outputCallback
protected LatencyTracker latencyTracker
protected SiddhiQueryContext siddhiQueryContext
protected LockWrapper lockWrapper
protected StateHolder<S extends State> stateHolder
public void init(LockWrapper lockWrapper, boolean groupBy, SiddhiQueryContext siddhiQueryContext)
protected abstract StateFactory<S> init()
public void sendToCallBacks(ComplexEventChunk complexEventChunk)
public void addQueryCallback(QueryCallback callback)
public void removeQueryCallback(QueryCallback callback)
public abstract void process(ComplexEventChunk complexEventChunk)
public void process(List<ComplexEventChunk> complexEventChunks)
public OutputCallback getOutputCallback()
public void setOutputCallback(OutputCallback outputCallback)
public boolean hasCallBack()
Copyright © 2021. All rights reserved.