You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@iotdb.apache.org by ro...@apache.org on 2022/05/23 17:38:27 UTC
[iotdb] 13/18: ConfigManager
This is an automated email from the ASF dual-hosted git repository.
rong pushed a commit to branch iotdb-3227
in repository https://gitbox.apache.org/repos/asf/iotdb.git
commit 00e6a633784dc96760b2e5627a5eeec0f1cc762d
Author: Steve Yurong Su <ro...@apache.org>
AuthorDate: Fri May 20 21:48:59 2022 +0800
ConfigManager
---
.../java/org/apache/iotdb/confignode/manager/ConfigManager.java | 5 +++++
.../src/main/java/org/apache/iotdb/confignode/manager/Manager.java | 7 +++++++
.../confignode/persistence/executor/ConfigRequestExecutor.java | 6 ++++--
3 files changed, 16 insertions(+), 2 deletions(-)
diff --git a/confignode/src/main/java/org/apache/iotdb/confignode/manager/ConfigManager.java b/confignode/src/main/java/org/apache/iotdb/confignode/manager/ConfigManager.java
index b6e06544ab..dadd79976f 100644
--- a/confignode/src/main/java/org/apache/iotdb/confignode/manager/ConfigManager.java
+++ b/confignode/src/main/java/org/apache/iotdb/confignode/manager/ConfigManager.java
@@ -598,6 +598,11 @@ public class ConfigManager implements Manager {
: status;
}
+ @Override
+ public UDFManager getUDFManager() {
+ return udfManager;
+ }
+
public ProcedureManager getProcedureManager() {
return procedureManager;
}
diff --git a/confignode/src/main/java/org/apache/iotdb/confignode/manager/Manager.java b/confignode/src/main/java/org/apache/iotdb/confignode/manager/Manager.java
index 2d5d8bb460..019458a285 100644
--- a/confignode/src/main/java/org/apache/iotdb/confignode/manager/Manager.java
+++ b/confignode/src/main/java/org/apache/iotdb/confignode/manager/Manager.java
@@ -89,6 +89,13 @@ public interface Manager {
*/
LoadManager getLoadManager();
+ /**
+ * Get UDFManager
+ *
+ * @return UDFManager instance
+ */
+ UDFManager getUDFManager();
+
/**
* Register DataNode
*
diff --git a/confignode/src/main/java/org/apache/iotdb/confignode/persistence/executor/ConfigRequestExecutor.java b/confignode/src/main/java/org/apache/iotdb/confignode/persistence/executor/ConfigRequestExecutor.java
index 4cd9127994..c522bc7226 100644
--- a/confignode/src/main/java/org/apache/iotdb/confignode/persistence/executor/ConfigRequestExecutor.java
+++ b/confignode/src/main/java/org/apache/iotdb/confignode/persistence/executor/ConfigRequestExecutor.java
@@ -215,7 +215,8 @@ public class ConfigRequestExecutor {
}
AtomicBoolean result = new AtomicBoolean(true);
- getAllAttributes().parallelStream()
+ getAllAttributes()
+ .parallelStream()
.forEach(
x -> {
boolean takeSnapshotResult = true;
@@ -244,7 +245,8 @@ public class ConfigRequestExecutor {
return;
}
- getAllAttributes().parallelStream()
+ getAllAttributes()
+ .parallelStream()
.forEach(
x -> {
try {