[to rel/1.0] add doublelive (apache#360)

RYH61 · Mar 8, 2023 · 200ef54 · 200ef54
1 parent dbb1049
commit 200ef54
Show file tree

Hide file tree

Showing 60 changed files with 3,670 additions and 33 deletions.
diff --git a/docs/UserGuide/Administration-Management/Multi-Tenancy.md b/docs/UserGuide/Administration-Management/Multi-Tenancy.md
@@ -23,7 +23,7 @@
 
 # Multi-Tenancy
 
-IoTDB provides multi tenant operations, mainly to limit the resources of the database or the database when users are using it.
+Times provides multi tenant operations, mainly to limit the resources of the database or the database when users are using it.
 
 ## Space Quota
 
@@ -72,9 +72,9 @@ set space quota timeseries=unlimited on root.sg1;
 -  Show the space quota information of all databases 
 
 ```SQL
-IoTDB> set space quota devices=5,timeseries=10,disk=100g on root.sg1, root.sg2;
+Times> set space quota devices=5,timeseries=10,disk=100g on root.sg1, root.sg2;
 Msg: The statement is executed successfully.
-IoTDB> show space quota;
+Times> show space quota;
 +--------+-------------+-------+----+
 |database|    quotaType|  limit|used|
 +--------+-------------+-------+----+
@@ -92,7 +92,7 @@ It costs 0.067s
 - Show the space quota information of the specified database
 
 ```SQL
-IoTDB> show space quota root.sg1;
+Times> show space quota root.sg1;
 +--------+-------------+-------+----+
 |database|    quotaType|  limit|used|
 +--------+-------------+-------+----+
@@ -162,7 +162,7 @@ We support viewing quota information. The main syntax is as follows:
 - View the throttle quota information of all users
 
 ```SQL
-IoTDB> show throttle quota
+Times> show throttle quota
 +-----+---------+---------+----------+
 | User|QuotaType|    Limit|Read/Write|
 +-----+---------+---------+----------+
@@ -178,7 +178,7 @@ It costs 0.007s
 - View the throttle quota information of the specified user
 
 ```SQL
-IoTDB> show throttle quota user1;
+Times> show throttle quota user1;
 +-----+---------+---------+----------+
 | User|QuotaType|    Limit|Read/Write|
 +-----+---------+---------+----------+

diff --git a/docs/zh/UserGuide/Administration-Management/Multi-Tenancy.md b/docs/zh/UserGuide/Administration-Management/Multi-Tenancy.md
@@ -21,7 +21,7 @@
 
 # 多租户
 
-IoTDB 提供了多租户操作，主要是对数据库，或者用户在使用的过程中，对数据库进行一定的资源限制。
+Times 提供了多租户操作，主要是对数据库，或者用户在使用的过程中，对数据库进行一定的资源限制。
 
 ## 空间限额
 
@@ -70,9 +70,9 @@ set space quota timeseries=unlimited on root.sg1;
 - 查看全部数据库的空间限额信息
 
 ```SQL
-IoTDB> set space quota devices=5,timeseries=10,disk=100g on root.sg1, root.sg2;
+Times> set space quota devices=5,timeseries=10,disk=100g on root.sg1, root.sg2;
 Msg: The statement is executed successfully.
-IoTDB> show space quota;
+Times> show space quota;
 +--------+-------------+-------+----+
 |database|    quotaType|  limit|used|
 +--------+-------------+-------+----+
@@ -90,7 +90,7 @@ It costs 0.067s
 - 查看指定数据库的空间限额信息
 
 ```SQL
-IoTDB> show space quota root.sg1;
+Times> show space quota root.sg1;
 +--------+-------------+-------+----+
 |database|    quotaType|  limit|used|
 +--------+-------------+-------+----+
@@ -162,7 +162,7 @@ set throttle quota cpu=2, mem=2G on user1;
 - 查看全部用户的throttle quota信息
 
 ```SQL
-IoTDB> show throttle quota
+Times> show throttle quota
 +-----+---------+---------+----------+
 | User|QuotaType|    Limit|Read/Write|
 +-----+---------+---------+----------+
@@ -178,7 +178,7 @@ It costs 0.007s
 - 查看指定用户的throttle quota信息
 
 ```SQL
-IoTDB> show throttle quota user1;
+Times> show throttle quota user1;
 +-----+---------+---------+----------+
 | User|QuotaType|    Limit|Read/Write|
 +-----+---------+---------+----------+

diff --git a/isession/src/main/java/org/apache/iotdb/isession/ISession.java b/isession/src/main/java/org/apache/iotdb/isession/ISession.java
@@ -20,7 +20,6 @@
 
 import org.apache.iotdb.common.rpc.thrift.TEndPoint;
 import org.apache.iotdb.isession.template.Template;
-import org.apache.iotdb.isession.util.SystemStatus;
 import org.apache.iotdb.isession.util.Version;
 import org.apache.iotdb.rpc.IoTDBConnectionException;
 import org.apache.iotdb.rpc.StatementExecutionException;
@@ -473,10 +472,7 @@ TSBackupConfigurationResp getBackupConfiguration()
 
   long getQueryTimeout();
 
-  @Deprecated
-  default SystemStatus getSystemStatus() {
-    return SystemStatus.NORMAL;
-  }
+  String getSystemStatus() throws IoTDBConnectionException;
 
   @Deprecated
   default void createTimeseriesOfTemplateOnPath(String path)
@@ -486,7 +482,6 @@ default void createTimeseriesOfTemplateOnPath(String path)
   default void deactivateTemplateOn(String templateName, String prefixPath)
       throws IoTDBConnectionException, StatementExecutionException {}
 
-  @Deprecated
   default void operationSyncTransmit(ByteBuffer buffer)
       throws IoTDBConnectionException, StatementExecutionException {}
 

diff --git a/isession/src/main/java/org/apache/iotdb/isession/pool/ISessionPool.java b/isession/src/main/java/org/apache/iotdb/isession/pool/ISessionPool.java
@@ -19,7 +19,6 @@
 package org.apache.iotdb.isession.pool;
 
 import org.apache.iotdb.isession.template.Template;
-import org.apache.iotdb.isession.util.SystemStatus;
 import org.apache.iotdb.isession.util.Version;
 import org.apache.iotdb.rpc.IoTDBConnectionException;
 import org.apache.iotdb.rpc.StatementExecutionException;
@@ -462,6 +461,8 @@ TSBackupConfigurationResp getBackupConfiguration()
 
   long getQueryTimeout();
 
+  String getSystemStatus() throws IoTDBConnectionException;
+
   @Deprecated
   default void createTimeseriesOfTemplateOnPath(String path)
       throws IoTDBConnectionException, StatementExecutionException {}
@@ -477,17 +478,11 @@ default ISessionDataSetWrapper executeRawDataQuery(
     return null;
   }
 
-  @Deprecated
   default boolean operationSyncTransmit(ByteBuffer buffer)
       throws IoTDBConnectionException, StatementExecutionException {
     return false;
   }
 
-  @Deprecated
-  default SystemStatus getSystemStatus() throws IoTDBConnectionException {
-    return SystemStatus.NORMAL;
-  }
-
   @Deprecated
   default boolean isEnableCacheLeader() {
     return false;

diff --git a/node-commons/src/main/java/org/apache/iotdb/commons/conf/IoTDBConstant.java b/node-commons/src/main/java/org/apache/iotdb/commons/conf/IoTDBConstant.java
@@ -292,6 +292,9 @@ private IoTDBConstant() {}
   public static final String AVAILABLE = "Available";
   public static final String USED = "Times-Used";
 
+  // Operation Sync folder name
+  public static final String OPERATION_SYNC_FOLDER_NAME = "operationsync";
+
   // client version number
   public enum ClientVersion {
     V_0_12,

diff --git a/node-commons/src/main/java/org/apache/iotdb/commons/utils/PropertiesUtils.java b/node-commons/src/main/java/org/apache/iotdb/commons/utils/PropertiesUtils.java
@@ -766,6 +766,7 @@ public static void getXml(List<String> fileNames, String xmlFilePath) {
                 || line.contains("dn_tracing_dir=datanode\\\\tracing")
                 || line.contains("trigger_lib_dir=ext\\\\trigger")
                 || line.contains("udf_lib_dir=ext\\\\udf")
+                || line.contains("dn_sync_dir=data\\\\operationsync")
                 || split[0].contains("<")) {
               currentNum++;
               continue;
@@ -915,6 +916,7 @@ public static void getXml(List<String> fileNames, String xmlFilePath) {
                 || " schema_region_ratis_log_max_size".equals(split[0])
                 || " data_region_ratis_log_max_size".equals(split[0])
                 || " iot_consensus_throttle_threshold_in_byte".equals(split[0])
+                || " operation_sync_max_log_size".equals(split[0])
                 || " ratis_first_election_timeout_max_ms".equals(split[0])) {
               text[6] = "long";
             } else {