Modifier and Type | Interface and Description |
---|---|
interface |
AbsentPreStateProcessor
PreStateProcessor of events not received by Siddhi.
|
Modifier and Type | Class and Description |
---|---|
class |
AbsentLogicalPreStateProcessor
Logical not processor.
|
class |
AbsentStreamPreStateProcessor
Pre processor of not operator.
|
Modifier and Type | Class and Description |
---|---|
class |
OutputRateLimiter<S extends State>
Abstract parent implementation of Output Rate Limiting.
|
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. |
Copyright © 2019. All rights reserved.