Modifier and Type | Class and Description |
---|---|
class |
EntryValveExecutor
Entry point to incremental executors.
|
class |
EntryValveProcessor
Entry Valve Siddhi processor chain.
|
Modifier and Type | Class and Description |
---|---|
class |
AggregationGroupByWindowedPerSnapshotOutputRateLimiter
Implementation of
PerSnapshotOutputRateLimiter for queries with GroupBy, Aggregators and Windows. |
class |
AggregationWindowedPerSnapshotOutputRateLimiter
Implementation of
PerSnapshotOutputRateLimiter for queries with Windows and Aggregators. |
class |
AllAggregationGroupByWindowedPerSnapshotOutputRateLimiter
Implementation of
PerSnapshotOutputRateLimiter for queries with GroupBy, Aggregators and Windows which
will output all events. |
class |
AllAggregationPerSnapshotOutputRateLimiter
Implementation of
PerSnapshotOutputRateLimiter for queries with Aggregators which will output all events. |
class |
GroupByPerSnapshotOutputRateLimiter
Implementation of
PerSnapshotOutputRateLimiter for queries with GroupBy. |
class |
PerSnapshotOutputRateLimiter
Parent implementation for per event periodic snapshot rate limiting.
|
class |
SnapshotOutputRateLimiter<S extends State>
Parent implementation to run the
Scheduler to handle periodic snapshot rate
limiting. |
class |
WindowedPerSnapshotOutputRateLimiter
Implementation of
PerSnapshotOutputRateLimiter for queries with Windows. |
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. |
Constructor and Description |
---|
Scheduler(Schedulable singleThreadEntryValve,
SiddhiQueryContext siddhiQueryContext) |
Modifier and Type | Method and Description |
---|---|
static Scheduler |
SchedulerParser.parse(Schedulable singleThreadEntryValve,
SiddhiQueryContext siddhiQueryContext)
Create Scheduler object.
|
Copyright © 2021. All rights reserved.