S
- current state of the RateLimiterpublic class WrappedSnapshotOutputRateLimiter<S extends State> extends OutputRateLimiter<S>
OutputRateLimiter
to be used by Snapshot Output Rate Limiting implementations.latencyTracker, lockWrapper, outputCallback, queryCallbacks, stateHolder
Constructor and Description |
---|
WrappedSnapshotOutputRateLimiter(Long value,
boolean groupBy,
boolean isWindowed,
SiddhiQueryContext siddhiQueryContext) |
Modifier and Type | Method and Description |
---|---|
protected StateFactory<S> |
init() |
void |
init(int outPutAttributeSize,
List<AttributeProcessor> attributeProcessorList,
MetaComplexEvent metaComplexEvent) |
void |
init(SiddhiQueryContext siddhiQueryContext,
LockWrapper lockWrapper) |
void |
partitionCreated()
Get called when partition is created
|
void |
passToCallBacks(ComplexEventChunk complexEventChunk) |
void |
process(ComplexEventChunk complexEventChunk) |
addQueryCallback, getOutputCallback, hasCallBack, init, sendToCallBacks, setOutputCallback
public WrappedSnapshotOutputRateLimiter(Long value, boolean groupBy, boolean isWindowed, SiddhiQueryContext siddhiQueryContext)
public void init(SiddhiQueryContext siddhiQueryContext, LockWrapper lockWrapper)
public void init(int outPutAttributeSize, List<AttributeProcessor> attributeProcessorList, MetaComplexEvent metaComplexEvent)
public void partitionCreated()
PartitionCreationListener
protected StateFactory<S> init()
init
in class OutputRateLimiter<S extends State>
public void process(ComplexEventChunk complexEventChunk)
process
in class OutputRateLimiter<S extends State>
public void passToCallBacks(ComplexEventChunk complexEventChunk)
Copyright © 2019. All rights reserved.