public class PerSnapshotOutputRateLimiter extends SnapshotOutputRateLimiter<io.siddhi.core.query.output.ratelimit.snapshot.PerSnapshotOutputRateLimiter.RateLimiterState>
lockWrapper, siddhiQueryContext, stateEventCloner, stateHolder, streamEventCloner
Constructor and Description |
---|
PerSnapshotOutputRateLimiter(Long value,
WrappedSnapshotOutputRateLimiter wrappedSnapshotOutputRateLimiter,
boolean groupBy,
SiddhiQueryContext siddhiQueryContext) |
Modifier and Type | Method and Description |
---|---|
protected StateFactory<io.siddhi.core.query.output.ratelimit.snapshot.PerSnapshotOutputRateLimiter.RateLimiterState> |
init() |
void |
partitionCreated() |
void |
process(ComplexEventChunk complexEventChunk) |
cloneComplexEvent, sendToCallBacks, setQueryLock, setStateEventCloner, setStreamEventCloner
public PerSnapshotOutputRateLimiter(Long value, WrappedSnapshotOutputRateLimiter wrappedSnapshotOutputRateLimiter, boolean groupBy, SiddhiQueryContext siddhiQueryContext)
protected StateFactory<io.siddhi.core.query.output.ratelimit.snapshot.PerSnapshotOutputRateLimiter.RateLimiterState> init()
init
in class SnapshotOutputRateLimiter<io.siddhi.core.query.output.ratelimit.snapshot.PerSnapshotOutputRateLimiter.RateLimiterState>
public void process(ComplexEventChunk complexEventChunk)
process
in interface Schedulable
process
in class SnapshotOutputRateLimiter<io.siddhi.core.query.output.ratelimit.snapshot.PerSnapshotOutputRateLimiter.RateLimiterState>
public void partitionCreated()
partitionCreated
in class SnapshotOutputRateLimiter<io.siddhi.core.query.output.ratelimit.snapshot.PerSnapshotOutputRateLimiter.RateLimiterState>
Copyright © 2019. All rights reserved.