Merge pull request #1824 from BLasan/add-getters

Add getters to the variables
siddhi-io · Dec 6, 2023 · 8141f9f · 8141f9f
2 parents d99c494 + ae34cee
commit 8141f9f
Show file tree

Hide file tree

Showing 2 changed files with 8 additions and 0 deletions.
diff --git a/modules/siddhi-core/src/main/java/io/siddhi/core/SiddhiAppRuntimeImpl.java b/modules/siddhi-core/src/main/java/io/siddhi/core/SiddhiAppRuntimeImpl.java
@@ -222,6 +222,10 @@ public Map<String, TableDefinition> getTableDefinitionMap() {
                         e -> (TableDefinition) e.getValue()));
     }
 
+    public ConcurrentMap<String, AggregationRuntime> getAggregationMap() {
+        return aggregationMap;
+    }
+
     /**
      * Get the window definition map.
      *

diff --git a/modules/siddhi-core/src/main/java/io/siddhi/core/aggregation/AggregationRuntime.java b/modules/siddhi-core/src/main/java/io/siddhi/core/aggregation/AggregationRuntime.java
@@ -733,4 +733,8 @@ public void setAggregationDurationExecutorMap(Map<String,
             Map<TimePeriod.Duration, Executor>> aggregationDurationExecutorMap) {
         this.aggregationDurationExecutorMap = aggregationDurationExecutorMap;
     }
+
+    public IncrementalExecutorsInitialiser getIncrementalExecutorsInitialiser() {
+        return incrementalExecutorsInitialiser;
+    }
 }