Modifier and Type | Method and Description |
---|---|
OutputRateLimiter |
QueryRuntime.getOutputRateManager() |
Constructor and Description |
---|
QueryRuntime(io.siddhi.query.api.execution.query.Query query,
StreamRuntime streamRuntime,
QuerySelector selector,
OutputRateLimiter outputRateLimiter,
OutputCallback outputCallback,
MetaComplexEvent metaComplexEvent,
SiddhiQueryContext siddhiQueryContext) |
Modifier and Type | Field and Description |
---|---|
protected OutputRateLimiter |
MultiProcessStreamReceiver.outputRateLimiter |
Modifier and Type | Method and Description |
---|---|
void |
MultiProcessStreamReceiver.setOutputRateLimiter(OutputRateLimiter outputRateLimiter) |
Modifier and Type | Class and Description |
---|---|
class |
PassThroughOutputRateLimiter
Implementation of
OutputRateLimiter which will pass through events without doing any rate limiting. |
Modifier and Type | Class and Description |
---|---|
class |
AllPerEventOutputRateLimiter
Implementation of
OutputRateLimiter which will collect pre-defined number of events and the emit all
collected events as a batch. |
class |
FirstGroupByPerEventOutputRateLimiter
Implementation of
OutputRateLimiter which will collect pre-defined number of events and the emit only the
first event. |
class |
FirstPerEventOutputRateLimiter
Implementation of
OutputRateLimiter which will collect pre-defined number of events and the emit only the
first event. |
class |
LastGroupByPerEventOutputRateLimiter
Implementation of
OutputRateLimiter which will collect pre-defined number of events and the emit only the
last event. |
class |
LastPerEventOutputRateLimiter
Implementation of
OutputRateLimiter which will collect pre-defined number of events and the emit only the
last event. |
Modifier and Type | Class and Description |
---|---|
class |
WrappedSnapshotOutputRateLimiter<S extends State>
Implementation of
OutputRateLimiter to be used by Snapshot Output Rate Limiting implementations. |
Modifier and Type | Class and Description |
---|---|
class |
AllPerTimeOutputRateLimiter
Implementation of
OutputRateLimiter which will collect pre-defined time period and the emit all
collected events as a batch. |
class |
FirstGroupByPerTimeOutputRateLimiter
Implementation of
OutputRateLimiter which will collect pre-defined time period and the emit only first
event. |
class |
FirstPerTimeOutputRateLimiter
Implementation of
OutputRateLimiter which will collect pre-defined time period and the emit only first
event. |
class |
LastGroupByPerTimeOutputRateLimiter
Implementation of
OutputRateLimiter which will collect pre-defined time period and the emit only last
event. |
class |
LastPerTimeOutputRateLimiter
Implementation of
OutputRateLimiter which will collect pre-defined time period and the emit only last
event. |
Modifier and Type | Method and Description |
---|---|
void |
QuerySelector.setNextProcessor(OutputRateLimiter outputRateLimiter) |
Modifier and Type | Method and Description |
---|---|
static OutputRateLimiter |
OutputParser.constructOutputRateLimiter(String id,
io.siddhi.query.api.execution.query.output.ratelimit.OutputRate outputRate,
boolean isGroupBy,
boolean isWindow,
SiddhiQueryContext siddhiQueryContext) |
Copyright © 2019. All rights reserved.