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