Interface | Description |
---|---|
Executor |
This is the parent interface representing Event executor for incremental execution in Siddhi.
|
Class | Description |
---|---|
AggregationExpressionBuilder |
Builder to the Aggregation on condition.
|
AggregationExpressionVisitor |
Visitor class to reduce on condition Expression
|
AggregationRuntime |
Aggregation runtime managing aggregation operations for aggregation definition.
|
BaseIncrementalValueStore |
Store for maintaining the base values related to incremental aggregation.
|
IncrementalAggregationProcessor |
Incremental Aggregation Processor to consume events to Incremental Aggregators.
|
IncrementalDataAggregator |
This class implements the logic to aggregate data that is in-memory or in tables, in incremental data processing.
|
IncrementalDataPurger |
This class implements the logic which is needed to purge data which are related to incremental
|
IncrementalExecutor |
Incremental executor class which is responsible for performing incremental aggregation.
|
IncrementalExecutorsInitialiser |
This class is used to recreate in-memory data from the tables (Such as RDBMS) in incremental aggregation.
|
OutOfOrderEventsDataAggregator |
This class implements logic to process aggregates(after retrieval from tables) that were aggregated
using external timestamp.
|
Copyright © 2021. All rights reserved.