From ae34cee7c582db32a76beadc3a623409eff7e066 Mon Sep 17 00:00:00 2001 From: BLasan Date: Tue, 5 Dec 2023 16:55:18 +0530 Subject: [PATCH] fixes: https://github.com/wso2/api-manager/issues/2305 --- .../src/main/java/io/siddhi/core/SiddhiAppRuntimeImpl.java | 4 ++++ .../java/io/siddhi/core/aggregation/AggregationRuntime.java | 4 ++++ 2 files changed, 8 insertions(+) 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 getTableDefinitionMap() { e -> (TableDefinition) e.getValue())); } + public ConcurrentMap 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> aggregationDurationExecutorMap) { this.aggregationDurationExecutorMap = aggregationDurationExecutorMap; } + + public IncrementalExecutorsInitialiser getIncrementalExecutorsInitialiser() { + return incrementalExecutorsInitialiser; + } }