public class AggregationGroupByWindowedPerSnapshotOutputRateLimiter extends AggregationWindowedPerSnapshotOutputRateLimiter
PerSnapshotOutputRateLimiter
for queries with GroupBy, Aggregators and Windows.aggregateAttributePositionList, comparator, scheduler, value
lockWrapper, siddhiQueryContext, stateEventCloner, stateHolder, streamEventCloner
Modifier | Constructor and Description |
---|---|
protected |
AggregationGroupByWindowedPerSnapshotOutputRateLimiter(Long value,
List<Integer> aggregateAttributePositionList,
WrappedSnapshotOutputRateLimiter wrappedSnapshotOutputRateLimiter,
boolean groupBy,
SiddhiQueryContext siddhiQueryContext) |
Modifier and Type | Method and Description |
---|---|
protected StateFactory<io.siddhi.core.query.output.ratelimit.snapshot.AggregationWindowedPerSnapshotOutputRateLimiter.AggregationRateLimiterState> |
init() |
void |
process(ComplexEventChunk complexEventChunk) |
partitionCreated
cloneComplexEvent, sendToCallBacks, setQueryLock, setStateEventCloner, setStreamEventCloner
protected AggregationGroupByWindowedPerSnapshotOutputRateLimiter(Long value, List<Integer> aggregateAttributePositionList, WrappedSnapshotOutputRateLimiter wrappedSnapshotOutputRateLimiter, boolean groupBy, SiddhiQueryContext siddhiQueryContext)
protected StateFactory<io.siddhi.core.query.output.ratelimit.snapshot.AggregationWindowedPerSnapshotOutputRateLimiter.AggregationRateLimiterState> init()
init
in class AggregationWindowedPerSnapshotOutputRateLimiter
public void process(ComplexEventChunk complexEventChunk)
process
in interface Schedulable
process
in class AggregationWindowedPerSnapshotOutputRateLimiter
Copyright © 2021. All rights reserved.