Exposing tableDefinitionMap and available query names
@@ -49,6 +49,7 @@ import java.util.Collection;
import java.util.HashMap;
import java.util.List;
import java.util.Map;
+import java.util.Set;
import java.util.concurrent.ConcurrentHashMap;
import java.util.concurrent.ConcurrentMap;
import java.util.concurrent.Future;
@@ -129,6 +130,14 @@ public class ExecutionPlanRuntime {
return streamDefinitionMap;
}
+ public Map<String, AbstractDefinition> getTableDefinitionMap() {
+ return tableDefinitionMap;
+ }
+
+ public Set<String> getQueryNames() {
+ return queryProcessorMap.keySet();
+ }
+
public Map<String, Map<String, AbstractDefinition>> getPartitionedInnerStreamDefinitionMap() {
Map<String, Map<String, AbstractDefinition>> innerStreams = new HashMap<>();
for (PartitionRuntime partition : partitionMap.values()) {
