public class AggregationWindowedPerSnapshotOutputRateLimiter extends SnapshotOutputRateLimiter<io.siddhi.core.query.output.ratelimit.snapshot.AggregationWindowedPerSnapshotOutputRateLimiter.AggregationRateLimiterState>
PerSnapshotOutputRateLimiter
for queries with Windows and Aggregators.Modifier and Type | Field and Description |
---|---|
protected List<Integer> |
aggregateAttributePositionList |
protected Comparator<ComplexEvent> |
comparator |
protected Scheduler |
scheduler |
protected Long |
value |
lockWrapper, siddhiQueryContext, stateEventCloner, stateHolder, streamEventCloner
Modifier | Constructor and Description |
---|---|
protected |
AggregationWindowedPerSnapshotOutputRateLimiter(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 |
partitionCreated() |
void |
process(ComplexEventChunk complexEventChunk) |
cloneComplexEvent, sendToCallBacks, setQueryLock, setStateEventCloner, setStreamEventCloner
protected final Long value
protected Comparator<ComplexEvent> comparator
protected Scheduler scheduler
protected AggregationWindowedPerSnapshotOutputRateLimiter(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 SnapshotOutputRateLimiter<io.siddhi.core.query.output.ratelimit.snapshot.AggregationWindowedPerSnapshotOutputRateLimiter.AggregationRateLimiterState>
public void process(ComplexEventChunk complexEventChunk)
process
in interface Schedulable
process
in class SnapshotOutputRateLimiter<io.siddhi.core.query.output.ratelimit.snapshot.AggregationWindowedPerSnapshotOutputRateLimiter.AggregationRateLimiterState>
public void partitionCreated()
partitionCreated
in class SnapshotOutputRateLimiter<io.siddhi.core.query.output.ratelimit.snapshot.AggregationWindowedPerSnapshotOutputRateLimiter.AggregationRateLimiterState>
Copyright © 2019. All rights reserved.