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
index 94cebdd140..3cfd7855aa 100644
--- 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
index cdfe146260..5a66414f65 100644
--- 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;
+    }
 }