You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@iotdb.apache.org by yo...@apache.org on 2023/02/09 03:38:39 UTC
[iotdb] branch Rename-TStorageGroupSchema-to-TDatabaseSchema updated: Finish
This is an automated email from the ASF dual-hosted git repository.
yongzao pushed a commit to branch Rename-TStorageGroupSchema-to-TDatabaseSchema
in repository https://gitbox.apache.org/repos/asf/iotdb.git
The following commit(s) were added to refs/heads/Rename-TStorageGroupSchema-to-TDatabaseSchema by this push:
new c2f09ff8bc Finish
c2f09ff8bc is described below
commit c2f09ff8bca6e42340c8b5f11abc9b450397d673
Author: YongzaoDan <53...@qq.com>
AuthorDate: Thu Feb 9 11:38:28 2023 +0800
Finish
---
RELEASE_NOTES.md | 2 +-
.../consensus/request/ConfigPhysicalPlan.java | 16 ++--
.../CountDatabasePlan.java} | 14 ++--
.../GetDatabasePlan.java} | 8 +-
.../request/read/region/GetRegionInfoListPlan.java | 6 +-
...orageGroupPlan.java => DeleteDatabasePlan.java} | 8 +-
...geGroupPlan.java => PreDeleteDatabasePlan.java} | 6 +-
.../response/{ => auth}/PermissionInfoResp.java | 2 +-
.../consensus/response/{ => cq}/ShowCQResp.java | 2 +-
.../CountDatabaseResp.java} | 10 +--
.../DatabaseSchemaResp.java} | 10 +--
.../response/{ => datanode}/ConfigurationResp.java | 2 +-
.../{ => datanode}/DataNodeConfigurationResp.java | 2 +-
.../{ => datanode}/DataNodeRegisterResp.java | 2 +-
.../{ => datanode}/DataNodeToStatusResp.java | 2 +-
.../response/{ => function}/FunctionTableResp.java | 2 +-
.../{ => partition}/DataPartitionResp.java | 2 +-
.../response/{ => partition}/GetRegionIdResp.java | 2 +-
.../{ => partition}/GetSeriesSlotListResp.java | 2 +-
.../{ => partition}/GetTimeSlotListResp.java | 2 +-
.../response/{ => partition}/PathInfoResp.java | 2 +-
.../{ => partition}/RegionInfoListResp.java | 2 +-
.../{ => partition}/SchemaNodeManagementResp.java | 2 +-
.../{ => partition}/SchemaPartitionResp.java | 2 +-
.../consensus/response/{ => pipe}/PipeResp.java | 2 +-
.../response/{ => pipe}/PipeSinkResp.java | 2 +-
.../{ => template}/AllTemplateSetInfoResp.java | 2 +-
.../response/{ => template}/TemplateInfoResp.java | 2 +-
.../{ => template}/TemplateSetInfoResp.java | 2 +-
.../{ => trigger}/TransferringTriggersResp.java | 2 +-
.../{ => trigger}/TriggerLocationResp.java | 2 +-
.../response/{ => trigger}/TriggerTableResp.java | 2 +-
.../consensus/response/{ => udf}/JarResp.java | 2 +-
.../confignode/manager/ClusterSchemaManager.java | 52 ++++++------
.../iotdb/confignode/manager/ConfigManager.java | 40 ++++-----
.../apache/iotdb/confignode/manager/IManager.java | 10 +--
.../confignode/manager/PermissionManager.java | 2 +-
.../iotdb/confignode/manager/SyncManager.java | 4 +-
.../iotdb/confignode/manager/TriggerManager.java | 8 +-
.../iotdb/confignode/manager/UDFManager.java | 4 +-
.../iotdb/confignode/manager/cq/CQManager.java | 2 +-
.../iotdb/confignode/manager/node/NodeManager.java | 8 +-
.../manager/partition/PartitionManager.java | 26 +++---
.../iotdb/confignode/persistence/AuthorInfo.java | 2 +-
.../iotdb/confignode/persistence/TriggerInfo.java | 8 +-
.../iotdb/confignode/persistence/UDFInfo.java | 4 +-
.../iotdb/confignode/persistence/cq/CQInfo.java | 2 +-
.../persistence/executor/ConfigPlanExecutor.java | 26 +++---
.../persistence/metric/PartitionInfoMetrics.java | 41 +++++----
.../confignode/persistence/node/NodeInfo.java | 2 +-
...itionTable.java => DatabasePartitionTable.java} | 34 ++++----
.../persistence/partition/PartitionInfo.java | 96 ++++++++++------------
.../persistence/schema/ClusterSchemaInfo.java | 28 +++----
.../persistence/sync/ClusterSyncInfo.java | 4 +-
.../procedure/env/ConfigNodeProcedureEnv.java | 11 ++-
.../procedure/env/DataNodeRemoveHandler.java | 2 +-
.../impl/schema/DeleteStorageGroupProcedure.java | 6 +-
.../thrift/ConfigNodeRPCServiceProcessor.java | 76 +++++++++--------
.../request/ConfigPhysicalPlanSerDeTest.java | 26 +++---
.../confignode/persistence/AuthorInfoTest.java | 2 +-
.../persistence/ClusterSchemaInfoTest.java | 8 +-
.../confignode/persistence/PartitionInfoTest.java | 6 +-
.../it/database/IoTDBDatabaseSetAndDeleteIT.java | 26 +++---
.../partition/IoTDBAutoRegionGroupExtensionIT.java | 8 +-
.../it/partition/IoTDBPartitionGetterIT.java | 6 +-
.../apache/iotdb/db/client/ConfigNodeClient.java | 27 +++---
.../db/mpp/plan/analyze/cache/PartitionCache.java | 6 +-
.../config/executor/ClusterConfigTaskExecutor.java | 29 +++----
.../execution/config/metadata/ShowRegionTask.java | 2 +-
.../src/main/thrift/confignode.thrift | 78 +++++++++---------
70 files changed, 414 insertions(+), 436 deletions(-)
diff --git a/RELEASE_NOTES.md b/RELEASE_NOTES.md
index c2df9ea18e..78e450e740 100644
--- a/RELEASE_NOTES.md
+++ b/RELEASE_NOTES.md
@@ -887,7 +887,7 @@ Import-CSV supports specify data type and no need quotation for text value
* IOTDB-947 Fix error when counting node with wildcard
* IOTDB-949 Align by device doesn't support 'T*' in path.
* IOTDB-956 Filter will be missed in group by time align by device
-* IOTDB-963 Redo deleteStorageGroupPlan failed when recovering
+* IOTDB-963 Redo deleteDatabasePlan failed when recovering
* IOTDB-967 Fix xxx does not have the child node xxx Bug in count timeseries
* IOTDB-970 Restrict log file number and size
* IOTDB-971 More precise error messages of slimit and soffset
diff --git a/confignode/src/main/java/org/apache/iotdb/confignode/consensus/request/ConfigPhysicalPlan.java b/confignode/src/main/java/org/apache/iotdb/confignode/consensus/request/ConfigPhysicalPlan.java
index 18c1692a7e..f51999cfdf 100644
--- a/confignode/src/main/java/org/apache/iotdb/confignode/consensus/request/ConfigPhysicalPlan.java
+++ b/confignode/src/main/java/org/apache/iotdb/confignode/consensus/request/ConfigPhysicalPlan.java
@@ -20,6 +20,8 @@ package org.apache.iotdb.confignode.consensus.request;
import org.apache.iotdb.commons.exception.runtime.SerializationRunTimeException;
import org.apache.iotdb.confignode.consensus.request.auth.AuthorPlan;
+import org.apache.iotdb.confignode.consensus.request.read.database.CountDatabasePlan;
+import org.apache.iotdb.confignode.consensus.request.read.database.GetDatabasePlan;
import org.apache.iotdb.confignode.consensus.request.read.datanode.GetDataNodeConfigurationPlan;
import org.apache.iotdb.confignode.consensus.request.read.function.GetFunctionTablePlan;
import org.apache.iotdb.confignode.consensus.request.read.partition.GetDataPartitionPlan;
@@ -31,8 +33,6 @@ import org.apache.iotdb.confignode.consensus.request.read.partition.GetSeriesSlo
import org.apache.iotdb.confignode.consensus.request.read.partition.GetTimeSlotListPlan;
import org.apache.iotdb.confignode.consensus.request.read.region.GetRegionIdPlan;
import org.apache.iotdb.confignode.consensus.request.read.region.GetRegionInfoListPlan;
-import org.apache.iotdb.confignode.consensus.request.read.storagegroup.CountStorageGroupPlan;
-import org.apache.iotdb.confignode.consensus.request.read.storagegroup.GetStorageGroupPlan;
import org.apache.iotdb.confignode.consensus.request.read.template.CheckTemplateSettablePlan;
import org.apache.iotdb.confignode.consensus.request.read.template.GetAllSchemaTemplatePlan;
import org.apache.iotdb.confignode.consensus.request.read.template.GetAllTemplateSetInfoPlan;
@@ -66,8 +66,8 @@ import org.apache.iotdb.confignode.consensus.request.write.region.OfferRegionMai
import org.apache.iotdb.confignode.consensus.request.write.region.PollRegionMaintainTaskPlan;
import org.apache.iotdb.confignode.consensus.request.write.storagegroup.AdjustMaxRegionGroupNumPlan;
import org.apache.iotdb.confignode.consensus.request.write.storagegroup.DatabaseSchemaPlan;
-import org.apache.iotdb.confignode.consensus.request.write.storagegroup.DeleteStorageGroupPlan;
-import org.apache.iotdb.confignode.consensus.request.write.storagegroup.PreDeleteStorageGroupPlan;
+import org.apache.iotdb.confignode.consensus.request.write.storagegroup.DeleteDatabasePlan;
+import org.apache.iotdb.confignode.consensus.request.write.storagegroup.PreDeleteDatabasePlan;
import org.apache.iotdb.confignode.consensus.request.write.storagegroup.SetDataReplicationFactorPlan;
import org.apache.iotdb.confignode.consensus.request.write.storagegroup.SetSchemaReplicationFactorPlan;
import org.apache.iotdb.confignode.consensus.request.write.storagegroup.SetTTLPlan;
@@ -185,10 +185,10 @@ public abstract class ConfigPhysicalPlan implements IConsensusRequest {
plan = new AdjustMaxRegionGroupNumPlan();
break;
case CountDatabase:
- plan = new CountStorageGroupPlan();
+ plan = new CountDatabasePlan();
break;
case GetDatabase:
- plan = new GetStorageGroupPlan();
+ plan = new GetDatabasePlan();
break;
case CreateRegionGroups:
plan = new CreateRegionGroupsPlan();
@@ -224,10 +224,10 @@ public abstract class ConfigPhysicalPlan implements IConsensusRequest {
plan = new UpdateProcedurePlan();
break;
case PreDeleteDatabase:
- plan = new PreDeleteStorageGroupPlan();
+ plan = new PreDeleteDatabasePlan();
break;
case DeleteDatabase:
- plan = new DeleteStorageGroupPlan();
+ plan = new DeleteDatabasePlan();
break;
case ListUser:
case ListRole:
diff --git a/confignode/src/main/java/org/apache/iotdb/confignode/consensus/request/read/storagegroup/CountStorageGroupPlan.java b/confignode/src/main/java/org/apache/iotdb/confignode/consensus/request/read/database/CountDatabasePlan.java
similarity index 84%
rename from confignode/src/main/java/org/apache/iotdb/confignode/consensus/request/read/storagegroup/CountStorageGroupPlan.java
rename to confignode/src/main/java/org/apache/iotdb/confignode/consensus/request/read/database/CountDatabasePlan.java
index d6ef3889a6..411e404042 100644
--- a/confignode/src/main/java/org/apache/iotdb/confignode/consensus/request/read/storagegroup/CountStorageGroupPlan.java
+++ b/confignode/src/main/java/org/apache/iotdb/confignode/consensus/request/read/database/CountDatabasePlan.java
@@ -16,7 +16,7 @@
* specific language governing permissions and limitations
* under the License.
*/
-package org.apache.iotdb.confignode.consensus.request.read.storagegroup;
+package org.apache.iotdb.confignode.consensus.request.read.database;
import org.apache.iotdb.commons.utils.BasicStructureSerDeUtil;
import org.apache.iotdb.confignode.consensus.request.ConfigPhysicalPlan;
@@ -28,24 +28,24 @@ import java.nio.ByteBuffer;
import java.util.Arrays;
import java.util.List;
-public class CountStorageGroupPlan extends ConfigPhysicalPlan {
+public class CountDatabasePlan extends ConfigPhysicalPlan {
private String[] storageGroupPattern;
- public CountStorageGroupPlan() {
+ public CountDatabasePlan() {
super(ConfigPhysicalPlanType.CountDatabase);
}
- public CountStorageGroupPlan(ConfigPhysicalPlanType type) {
+ public CountDatabasePlan(ConfigPhysicalPlanType type) {
super(type);
}
- public CountStorageGroupPlan(List<String> storageGroupPattern) {
+ public CountDatabasePlan(List<String> storageGroupPattern) {
this();
this.storageGroupPattern = storageGroupPattern.toArray(new String[0]);
}
- public CountStorageGroupPlan(ConfigPhysicalPlanType type, List<String> storageGroupPattern) {
+ public CountDatabasePlan(ConfigPhysicalPlanType type, List<String> storageGroupPattern) {
super(type);
this.storageGroupPattern = storageGroupPattern.toArray(new String[0]);
}
@@ -77,7 +77,7 @@ public class CountStorageGroupPlan extends ConfigPhysicalPlan {
public boolean equals(Object o) {
if (this == o) return true;
if (o == null || getClass() != o.getClass()) return false;
- CountStorageGroupPlan that = (CountStorageGroupPlan) o;
+ CountDatabasePlan that = (CountDatabasePlan) o;
return Arrays.equals(storageGroupPattern, that.storageGroupPattern);
}
diff --git a/confignode/src/main/java/org/apache/iotdb/confignode/consensus/request/read/storagegroup/GetStorageGroupPlan.java b/confignode/src/main/java/org/apache/iotdb/confignode/consensus/request/read/database/GetDatabasePlan.java
similarity index 81%
rename from confignode/src/main/java/org/apache/iotdb/confignode/consensus/request/read/storagegroup/GetStorageGroupPlan.java
rename to confignode/src/main/java/org/apache/iotdb/confignode/consensus/request/read/database/GetDatabasePlan.java
index 2a9c139762..3734fa3568 100644
--- a/confignode/src/main/java/org/apache/iotdb/confignode/consensus/request/read/storagegroup/GetStorageGroupPlan.java
+++ b/confignode/src/main/java/org/apache/iotdb/confignode/consensus/request/read/database/GetDatabasePlan.java
@@ -16,19 +16,19 @@
* specific language governing permissions and limitations
* under the License.
*/
-package org.apache.iotdb.confignode.consensus.request.read.storagegroup;
+package org.apache.iotdb.confignode.consensus.request.read.database;
import org.apache.iotdb.confignode.consensus.request.ConfigPhysicalPlanType;
import java.util.List;
-public class GetStorageGroupPlan extends CountStorageGroupPlan {
+public class GetDatabasePlan extends CountDatabasePlan {
- public GetStorageGroupPlan() {
+ public GetDatabasePlan() {
super(ConfigPhysicalPlanType.GetDatabase);
}
- public GetStorageGroupPlan(List<String> storageGroupPathPattern) {
+ public GetDatabasePlan(List<String> storageGroupPathPattern) {
super(ConfigPhysicalPlanType.GetDatabase, storageGroupPathPattern);
}
}
diff --git a/confignode/src/main/java/org/apache/iotdb/confignode/consensus/request/read/region/GetRegionInfoListPlan.java b/confignode/src/main/java/org/apache/iotdb/confignode/consensus/request/read/region/GetRegionInfoListPlan.java
index ce450f552b..d40ddfecee 100644
--- a/confignode/src/main/java/org/apache/iotdb/confignode/consensus/request/read/region/GetRegionInfoListPlan.java
+++ b/confignode/src/main/java/org/apache/iotdb/confignode/consensus/request/read/region/GetRegionInfoListPlan.java
@@ -60,10 +60,10 @@ public class GetRegionInfoListPlan extends ConfigPhysicalPlan {
if (setConsensusGroupType) {
ReadWriteIOUtils.write(showRegionReq.getConsensusGroupType().ordinal(), stream);
}
- boolean setStorageGroups = showRegionReq.isSetStorageGroups();
+ boolean setStorageGroups = showRegionReq.isSetDatabases();
stream.writeBoolean(setStorageGroups);
if (setStorageGroups) {
- ReadWriteIOUtils.writeStringList(showRegionReq.getStorageGroups(), stream);
+ ReadWriteIOUtils.writeStringList(showRegionReq.getDatabases(), stream);
}
}
}
@@ -77,7 +77,7 @@ public class GetRegionInfoListPlan extends ConfigPhysicalPlan {
TConsensusGroupType.values()[ReadWriteIOUtils.readInt(buffer)]);
}
if (ReadWriteIOUtils.readBool(buffer)) {
- this.showRegionReq.setStorageGroups(ReadWriteIOUtils.readStringList(buffer));
+ this.showRegionReq.setDatabases(ReadWriteIOUtils.readStringList(buffer));
}
}
}
diff --git a/confignode/src/main/java/org/apache/iotdb/confignode/consensus/request/write/storagegroup/DeleteStorageGroupPlan.java b/confignode/src/main/java/org/apache/iotdb/confignode/consensus/request/write/storagegroup/DeleteDatabasePlan.java
similarity index 90%
rename from confignode/src/main/java/org/apache/iotdb/confignode/consensus/request/write/storagegroup/DeleteStorageGroupPlan.java
rename to confignode/src/main/java/org/apache/iotdb/confignode/consensus/request/write/storagegroup/DeleteDatabasePlan.java
index ca76c1131e..84f7b41449 100644
--- a/confignode/src/main/java/org/apache/iotdb/confignode/consensus/request/write/storagegroup/DeleteStorageGroupPlan.java
+++ b/confignode/src/main/java/org/apache/iotdb/confignode/consensus/request/write/storagegroup/DeleteDatabasePlan.java
@@ -27,15 +27,15 @@ import java.io.IOException;
import java.nio.ByteBuffer;
import java.util.Objects;
-public class DeleteStorageGroupPlan extends ConfigPhysicalPlan {
+public class DeleteDatabasePlan extends ConfigPhysicalPlan {
private String name;
- public DeleteStorageGroupPlan() {
+ public DeleteDatabasePlan() {
super(ConfigPhysicalPlanType.DeleteDatabase);
}
- public DeleteStorageGroupPlan(String name) {
+ public DeleteDatabasePlan(String name) {
this();
this.name = name;
}
@@ -59,7 +59,7 @@ public class DeleteStorageGroupPlan extends ConfigPhysicalPlan {
public boolean equals(Object o) {
if (this == o) return true;
if (o == null || getClass() != o.getClass()) return false;
- DeleteStorageGroupPlan that = (DeleteStorageGroupPlan) o;
+ DeleteDatabasePlan that = (DeleteDatabasePlan) o;
return name.equals(that.name);
}
diff --git a/confignode/src/main/java/org/apache/iotdb/confignode/consensus/request/write/storagegroup/PreDeleteStorageGroupPlan.java b/confignode/src/main/java/org/apache/iotdb/confignode/consensus/request/write/storagegroup/PreDeleteDatabasePlan.java
similarity index 92%
rename from confignode/src/main/java/org/apache/iotdb/confignode/consensus/request/write/storagegroup/PreDeleteStorageGroupPlan.java
rename to confignode/src/main/java/org/apache/iotdb/confignode/consensus/request/write/storagegroup/PreDeleteDatabasePlan.java
index e93e598add..ffa6c73634 100644
--- a/confignode/src/main/java/org/apache/iotdb/confignode/consensus/request/write/storagegroup/PreDeleteStorageGroupPlan.java
+++ b/confignode/src/main/java/org/apache/iotdb/confignode/consensus/request/write/storagegroup/PreDeleteDatabasePlan.java
@@ -27,15 +27,15 @@ import java.io.DataOutputStream;
import java.io.IOException;
import java.nio.ByteBuffer;
-public class PreDeleteStorageGroupPlan extends ConfigPhysicalPlan {
+public class PreDeleteDatabasePlan extends ConfigPhysicalPlan {
private String storageGroup;
private PreDeleteType preDeleteType;
- public PreDeleteStorageGroupPlan() {
+ public PreDeleteDatabasePlan() {
super(ConfigPhysicalPlanType.PreDeleteDatabase);
}
- public PreDeleteStorageGroupPlan(String storageGroup, PreDeleteType preDeleteType) {
+ public PreDeleteDatabasePlan(String storageGroup, PreDeleteType preDeleteType) {
this();
this.storageGroup = storageGroup;
this.preDeleteType = preDeleteType;
diff --git a/confignode/src/main/java/org/apache/iotdb/confignode/consensus/response/PermissionInfoResp.java b/confignode/src/main/java/org/apache/iotdb/confignode/consensus/response/auth/PermissionInfoResp.java
similarity index 96%
rename from confignode/src/main/java/org/apache/iotdb/confignode/consensus/response/PermissionInfoResp.java
rename to confignode/src/main/java/org/apache/iotdb/confignode/consensus/response/auth/PermissionInfoResp.java
index 50fde2a033..35aad7a15c 100644
--- a/confignode/src/main/java/org/apache/iotdb/confignode/consensus/response/PermissionInfoResp.java
+++ b/confignode/src/main/java/org/apache/iotdb/confignode/consensus/response/auth/PermissionInfoResp.java
@@ -17,7 +17,7 @@
* under the License.
*/
-package org.apache.iotdb.confignode.consensus.response;
+package org.apache.iotdb.confignode.consensus.response.auth;
import org.apache.iotdb.common.rpc.thrift.TSStatus;
import org.apache.iotdb.consensus.common.DataSet;
diff --git a/confignode/src/main/java/org/apache/iotdb/confignode/consensus/response/ShowCQResp.java b/confignode/src/main/java/org/apache/iotdb/confignode/consensus/response/cq/ShowCQResp.java
similarity index 96%
rename from confignode/src/main/java/org/apache/iotdb/confignode/consensus/response/ShowCQResp.java
rename to confignode/src/main/java/org/apache/iotdb/confignode/consensus/response/cq/ShowCQResp.java
index e59cc9eb04..be971a8687 100644
--- a/confignode/src/main/java/org/apache/iotdb/confignode/consensus/response/ShowCQResp.java
+++ b/confignode/src/main/java/org/apache/iotdb/confignode/consensus/response/cq/ShowCQResp.java
@@ -16,7 +16,7 @@
* specific language governing permissions and limitations
* under the License.
*/
-package org.apache.iotdb.confignode.consensus.response;
+package org.apache.iotdb.confignode.consensus.response.cq;
import org.apache.iotdb.common.rpc.thrift.TSStatus;
import org.apache.iotdb.confignode.persistence.cq.CQInfo;
diff --git a/confignode/src/main/java/org/apache/iotdb/confignode/consensus/response/CountStorageGroupResp.java b/confignode/src/main/java/org/apache/iotdb/confignode/consensus/response/database/CountDatabaseResp.java
similarity index 82%
rename from confignode/src/main/java/org/apache/iotdb/confignode/consensus/response/CountStorageGroupResp.java
rename to confignode/src/main/java/org/apache/iotdb/confignode/consensus/response/database/CountDatabaseResp.java
index 259acb2094..38a768f890 100644
--- a/confignode/src/main/java/org/apache/iotdb/confignode/consensus/response/CountStorageGroupResp.java
+++ b/confignode/src/main/java/org/apache/iotdb/confignode/consensus/response/database/CountDatabaseResp.java
@@ -16,20 +16,20 @@
* specific language governing permissions and limitations
* under the License.
*/
-package org.apache.iotdb.confignode.consensus.response;
+package org.apache.iotdb.confignode.consensus.response.database;
import org.apache.iotdb.common.rpc.thrift.TSStatus;
-import org.apache.iotdb.confignode.rpc.thrift.TCountStorageGroupResp;
+import org.apache.iotdb.confignode.rpc.thrift.TCountDatabaseResp;
import org.apache.iotdb.consensus.common.DataSet;
import org.apache.iotdb.rpc.TSStatusCode;
-public class CountStorageGroupResp implements DataSet {
+public class CountDatabaseResp implements DataSet {
private TSStatus status;
private int count;
- public CountStorageGroupResp() {
+ public CountDatabaseResp() {
// Empty constructor
}
@@ -45,7 +45,7 @@ public class CountStorageGroupResp implements DataSet {
this.count = count;
}
- public void convertToRPCCountStorageGroupResp(TCountStorageGroupResp resp) {
+ public void convertToRPCCountStorageGroupResp(TCountDatabaseResp resp) {
resp.setStatus(status);
if (status.getCode() == TSStatusCode.SUCCESS_STATUS.getStatusCode()) {
resp.setCount(count);
diff --git a/confignode/src/main/java/org/apache/iotdb/confignode/consensus/response/StorageGroupSchemaResp.java b/confignode/src/main/java/org/apache/iotdb/confignode/consensus/response/database/DatabaseSchemaResp.java
similarity index 87%
rename from confignode/src/main/java/org/apache/iotdb/confignode/consensus/response/StorageGroupSchemaResp.java
rename to confignode/src/main/java/org/apache/iotdb/confignode/consensus/response/database/DatabaseSchemaResp.java
index f32d33dbf4..e6d9d24c74 100644
--- a/confignode/src/main/java/org/apache/iotdb/confignode/consensus/response/StorageGroupSchemaResp.java
+++ b/confignode/src/main/java/org/apache/iotdb/confignode/consensus/response/database/DatabaseSchemaResp.java
@@ -16,7 +16,7 @@
* specific language governing permissions and limitations
* under the License.
*/
-package org.apache.iotdb.confignode.consensus.response;
+package org.apache.iotdb.confignode.consensus.response.database;
import org.apache.iotdb.common.rpc.thrift.TSStatus;
import org.apache.iotdb.confignode.rpc.thrift.TDatabaseSchema;
@@ -26,14 +26,14 @@ import org.apache.iotdb.rpc.TSStatusCode;
import java.util.Map;
-public class StorageGroupSchemaResp implements DataSet {
+public class DatabaseSchemaResp implements DataSet {
private TSStatus status;
- // Map<StorageGroupName, TStorageGroupSchema>
+ // Map<DatabaseName, TDatabaseSchema>
private Map<String, TDatabaseSchema> schemaMap;
- public StorageGroupSchemaResp() {
+ public DatabaseSchemaResp() {
// empty constructor
}
@@ -53,7 +53,7 @@ public class StorageGroupSchemaResp implements DataSet {
TDatabaseSchemaResp resp = new TDatabaseSchemaResp();
resp.setStatus(status);
if (status.getCode() == TSStatusCode.SUCCESS_STATUS.getStatusCode()) {
- resp.setStorageGroupSchemaMap(schemaMap);
+ resp.setDatabaseSchemaMap(schemaMap);
}
return resp;
}
diff --git a/confignode/src/main/java/org/apache/iotdb/confignode/consensus/response/ConfigurationResp.java b/confignode/src/main/java/org/apache/iotdb/confignode/consensus/response/datanode/ConfigurationResp.java
similarity index 97%
rename from confignode/src/main/java/org/apache/iotdb/confignode/consensus/response/ConfigurationResp.java
rename to confignode/src/main/java/org/apache/iotdb/confignode/consensus/response/datanode/ConfigurationResp.java
index 3353411fe4..a7fd48f3a3 100644
--- a/confignode/src/main/java/org/apache/iotdb/confignode/consensus/response/ConfigurationResp.java
+++ b/confignode/src/main/java/org/apache/iotdb/confignode/consensus/response/datanode/ConfigurationResp.java
@@ -16,7 +16,7 @@
* specific language governing permissions and limitations
* under the License.
*/
-package org.apache.iotdb.confignode.consensus.response;
+package org.apache.iotdb.confignode.consensus.response.datanode;
import org.apache.iotdb.common.rpc.thrift.TSStatus;
import org.apache.iotdb.confignode.rpc.thrift.TCQConfig;
diff --git a/confignode/src/main/java/org/apache/iotdb/confignode/consensus/response/DataNodeConfigurationResp.java b/confignode/src/main/java/org/apache/iotdb/confignode/consensus/response/datanode/DataNodeConfigurationResp.java
similarity index 96%
rename from confignode/src/main/java/org/apache/iotdb/confignode/consensus/response/DataNodeConfigurationResp.java
rename to confignode/src/main/java/org/apache/iotdb/confignode/consensus/response/datanode/DataNodeConfigurationResp.java
index 696d3f163c..4d5244d1d0 100644
--- a/confignode/src/main/java/org/apache/iotdb/confignode/consensus/response/DataNodeConfigurationResp.java
+++ b/confignode/src/main/java/org/apache/iotdb/confignode/consensus/response/datanode/DataNodeConfigurationResp.java
@@ -16,7 +16,7 @@
* specific language governing permissions and limitations
* under the License.
*/
-package org.apache.iotdb.confignode.consensus.response;
+package org.apache.iotdb.confignode.consensus.response.datanode;
import org.apache.iotdb.common.rpc.thrift.TDataNodeConfiguration;
import org.apache.iotdb.common.rpc.thrift.TSStatus;
diff --git a/confignode/src/main/java/org/apache/iotdb/confignode/consensus/response/DataNodeRegisterResp.java b/confignode/src/main/java/org/apache/iotdb/confignode/consensus/response/datanode/DataNodeRegisterResp.java
similarity index 97%
rename from confignode/src/main/java/org/apache/iotdb/confignode/consensus/response/DataNodeRegisterResp.java
rename to confignode/src/main/java/org/apache/iotdb/confignode/consensus/response/datanode/DataNodeRegisterResp.java
index a6e8d9d713..c7bc7695b8 100644
--- a/confignode/src/main/java/org/apache/iotdb/confignode/consensus/response/DataNodeRegisterResp.java
+++ b/confignode/src/main/java/org/apache/iotdb/confignode/consensus/response/datanode/DataNodeRegisterResp.java
@@ -16,7 +16,7 @@
* specific language governing permissions and limitations
* under the License.
*/
-package org.apache.iotdb.confignode.consensus.response;
+package org.apache.iotdb.confignode.consensus.response.datanode;
import org.apache.iotdb.common.rpc.thrift.TConfigNodeLocation;
import org.apache.iotdb.common.rpc.thrift.TSStatus;
diff --git a/confignode/src/main/java/org/apache/iotdb/confignode/consensus/response/DataNodeToStatusResp.java b/confignode/src/main/java/org/apache/iotdb/confignode/consensus/response/datanode/DataNodeToStatusResp.java
similarity index 96%
rename from confignode/src/main/java/org/apache/iotdb/confignode/consensus/response/DataNodeToStatusResp.java
rename to confignode/src/main/java/org/apache/iotdb/confignode/consensus/response/datanode/DataNodeToStatusResp.java
index 17e265b376..99da9c7271 100644
--- a/confignode/src/main/java/org/apache/iotdb/confignode/consensus/response/DataNodeToStatusResp.java
+++ b/confignode/src/main/java/org/apache/iotdb/confignode/consensus/response/datanode/DataNodeToStatusResp.java
@@ -16,7 +16,7 @@
* specific language governing permissions and limitations
* under the License.
*/
-package org.apache.iotdb.confignode.consensus.response;
+package org.apache.iotdb.confignode.consensus.response.datanode;
import org.apache.iotdb.common.rpc.thrift.TDataNodeLocation;
import org.apache.iotdb.common.rpc.thrift.TSStatus;
diff --git a/confignode/src/main/java/org/apache/iotdb/confignode/consensus/response/FunctionTableResp.java b/confignode/src/main/java/org/apache/iotdb/confignode/consensus/response/function/FunctionTableResp.java
similarity index 97%
rename from confignode/src/main/java/org/apache/iotdb/confignode/consensus/response/FunctionTableResp.java
rename to confignode/src/main/java/org/apache/iotdb/confignode/consensus/response/function/FunctionTableResp.java
index 3a59cf8f9f..79a04ecc70 100644
--- a/confignode/src/main/java/org/apache/iotdb/confignode/consensus/response/FunctionTableResp.java
+++ b/confignode/src/main/java/org/apache/iotdb/confignode/consensus/response/function/FunctionTableResp.java
@@ -17,7 +17,7 @@
* under the License.
*/
-package org.apache.iotdb.confignode.consensus.response;
+package org.apache.iotdb.confignode.consensus.response.function;
import org.apache.iotdb.common.rpc.thrift.TSStatus;
import org.apache.iotdb.commons.udf.UDFInformation;
diff --git a/confignode/src/main/java/org/apache/iotdb/confignode/consensus/response/DataPartitionResp.java b/confignode/src/main/java/org/apache/iotdb/confignode/consensus/response/partition/DataPartitionResp.java
similarity index 97%
rename from confignode/src/main/java/org/apache/iotdb/confignode/consensus/response/DataPartitionResp.java
rename to confignode/src/main/java/org/apache/iotdb/confignode/consensus/response/partition/DataPartitionResp.java
index b370601527..a2f902f41f 100644
--- a/confignode/src/main/java/org/apache/iotdb/confignode/consensus/response/DataPartitionResp.java
+++ b/confignode/src/main/java/org/apache/iotdb/confignode/consensus/response/partition/DataPartitionResp.java
@@ -17,7 +17,7 @@
* under the License.
*/
-package org.apache.iotdb.confignode.consensus.response;
+package org.apache.iotdb.confignode.consensus.response.partition;
import org.apache.iotdb.common.rpc.thrift.TConsensusGroupId;
import org.apache.iotdb.common.rpc.thrift.TSStatus;
diff --git a/confignode/src/main/java/org/apache/iotdb/confignode/consensus/response/GetRegionIdResp.java b/confignode/src/main/java/org/apache/iotdb/confignode/consensus/response/partition/GetRegionIdResp.java
similarity index 96%
rename from confignode/src/main/java/org/apache/iotdb/confignode/consensus/response/GetRegionIdResp.java
rename to confignode/src/main/java/org/apache/iotdb/confignode/consensus/response/partition/GetRegionIdResp.java
index 7118482306..617591225a 100644
--- a/confignode/src/main/java/org/apache/iotdb/confignode/consensus/response/GetRegionIdResp.java
+++ b/confignode/src/main/java/org/apache/iotdb/confignode/consensus/response/partition/GetRegionIdResp.java
@@ -17,7 +17,7 @@
* under the License.
*/
-package org.apache.iotdb.confignode.consensus.response;
+package org.apache.iotdb.confignode.consensus.response.partition;
import org.apache.iotdb.common.rpc.thrift.TConsensusGroupId;
import org.apache.iotdb.common.rpc.thrift.TSStatus;
diff --git a/confignode/src/main/java/org/apache/iotdb/confignode/consensus/response/GetSeriesSlotListResp.java b/confignode/src/main/java/org/apache/iotdb/confignode/consensus/response/partition/GetSeriesSlotListResp.java
similarity index 96%
rename from confignode/src/main/java/org/apache/iotdb/confignode/consensus/response/GetSeriesSlotListResp.java
rename to confignode/src/main/java/org/apache/iotdb/confignode/consensus/response/partition/GetSeriesSlotListResp.java
index e094732319..77aa4c990b 100644
--- a/confignode/src/main/java/org/apache/iotdb/confignode/consensus/response/GetSeriesSlotListResp.java
+++ b/confignode/src/main/java/org/apache/iotdb/confignode/consensus/response/partition/GetSeriesSlotListResp.java
@@ -17,7 +17,7 @@
* under the License.
*/
-package org.apache.iotdb.confignode.consensus.response;
+package org.apache.iotdb.confignode.consensus.response.partition;
import org.apache.iotdb.common.rpc.thrift.TSStatus;
import org.apache.iotdb.common.rpc.thrift.TSeriesPartitionSlot;
diff --git a/confignode/src/main/java/org/apache/iotdb/confignode/consensus/response/GetTimeSlotListResp.java b/confignode/src/main/java/org/apache/iotdb/confignode/consensus/response/partition/GetTimeSlotListResp.java
similarity index 96%
rename from confignode/src/main/java/org/apache/iotdb/confignode/consensus/response/GetTimeSlotListResp.java
rename to confignode/src/main/java/org/apache/iotdb/confignode/consensus/response/partition/GetTimeSlotListResp.java
index e6230ca602..e4ef4c7d14 100644
--- a/confignode/src/main/java/org/apache/iotdb/confignode/consensus/response/GetTimeSlotListResp.java
+++ b/confignode/src/main/java/org/apache/iotdb/confignode/consensus/response/partition/GetTimeSlotListResp.java
@@ -17,7 +17,7 @@
* under the License.
*/
-package org.apache.iotdb.confignode.consensus.response;
+package org.apache.iotdb.confignode.consensus.response.partition;
import org.apache.iotdb.common.rpc.thrift.TSStatus;
import org.apache.iotdb.common.rpc.thrift.TTimePartitionSlot;
diff --git a/confignode/src/main/java/org/apache/iotdb/confignode/consensus/response/PathInfoResp.java b/confignode/src/main/java/org/apache/iotdb/confignode/consensus/response/partition/PathInfoResp.java
similarity index 95%
rename from confignode/src/main/java/org/apache/iotdb/confignode/consensus/response/PathInfoResp.java
rename to confignode/src/main/java/org/apache/iotdb/confignode/consensus/response/partition/PathInfoResp.java
index db0d0c3e7b..23b6d48616 100644
--- a/confignode/src/main/java/org/apache/iotdb/confignode/consensus/response/PathInfoResp.java
+++ b/confignode/src/main/java/org/apache/iotdb/confignode/consensus/response/partition/PathInfoResp.java
@@ -17,7 +17,7 @@
* under the License.
*/
-package org.apache.iotdb.confignode.consensus.response;
+package org.apache.iotdb.confignode.consensus.response.partition;
import org.apache.iotdb.common.rpc.thrift.TSStatus;
import org.apache.iotdb.consensus.common.DataSet;
diff --git a/confignode/src/main/java/org/apache/iotdb/confignode/consensus/response/RegionInfoListResp.java b/confignode/src/main/java/org/apache/iotdb/confignode/consensus/response/partition/RegionInfoListResp.java
similarity index 95%
rename from confignode/src/main/java/org/apache/iotdb/confignode/consensus/response/RegionInfoListResp.java
rename to confignode/src/main/java/org/apache/iotdb/confignode/consensus/response/partition/RegionInfoListResp.java
index a38d429745..a39ea18d61 100644
--- a/confignode/src/main/java/org/apache/iotdb/confignode/consensus/response/RegionInfoListResp.java
+++ b/confignode/src/main/java/org/apache/iotdb/confignode/consensus/response/partition/RegionInfoListResp.java
@@ -17,7 +17,7 @@
* under the License.
*/
-package org.apache.iotdb.confignode.consensus.response;
+package org.apache.iotdb.confignode.consensus.response.partition;
import org.apache.iotdb.common.rpc.thrift.TSStatus;
import org.apache.iotdb.confignode.rpc.thrift.TRegionInfo;
diff --git a/confignode/src/main/java/org/apache/iotdb/confignode/consensus/response/SchemaNodeManagementResp.java b/confignode/src/main/java/org/apache/iotdb/confignode/consensus/response/partition/SchemaNodeManagementResp.java
similarity index 98%
rename from confignode/src/main/java/org/apache/iotdb/confignode/consensus/response/SchemaNodeManagementResp.java
rename to confignode/src/main/java/org/apache/iotdb/confignode/consensus/response/partition/SchemaNodeManagementResp.java
index 8fc684554b..5a765237f3 100644
--- a/confignode/src/main/java/org/apache/iotdb/confignode/consensus/response/SchemaNodeManagementResp.java
+++ b/confignode/src/main/java/org/apache/iotdb/confignode/consensus/response/partition/SchemaNodeManagementResp.java
@@ -17,7 +17,7 @@
* under the License.
*/
-package org.apache.iotdb.confignode.consensus.response;
+package org.apache.iotdb.confignode.consensus.response.partition;
import org.apache.iotdb.common.rpc.thrift.TConsensusGroupId;
import org.apache.iotdb.common.rpc.thrift.TRegionReplicaSet;
diff --git a/confignode/src/main/java/org/apache/iotdb/confignode/consensus/response/SchemaPartitionResp.java b/confignode/src/main/java/org/apache/iotdb/confignode/consensus/response/partition/SchemaPartitionResp.java
similarity index 97%
rename from confignode/src/main/java/org/apache/iotdb/confignode/consensus/response/SchemaPartitionResp.java
rename to confignode/src/main/java/org/apache/iotdb/confignode/consensus/response/partition/SchemaPartitionResp.java
index d08855a3fc..fa20b4d380 100644
--- a/confignode/src/main/java/org/apache/iotdb/confignode/consensus/response/SchemaPartitionResp.java
+++ b/confignode/src/main/java/org/apache/iotdb/confignode/consensus/response/partition/SchemaPartitionResp.java
@@ -17,7 +17,7 @@
* under the License.
*/
-package org.apache.iotdb.confignode.consensus.response;
+package org.apache.iotdb.confignode.consensus.response.partition;
import org.apache.iotdb.common.rpc.thrift.TConsensusGroupId;
import org.apache.iotdb.common.rpc.thrift.TSStatus;
diff --git a/confignode/src/main/java/org/apache/iotdb/confignode/consensus/response/PipeResp.java b/confignode/src/main/java/org/apache/iotdb/confignode/consensus/response/pipe/PipeResp.java
similarity index 95%
rename from confignode/src/main/java/org/apache/iotdb/confignode/consensus/response/PipeResp.java
rename to confignode/src/main/java/org/apache/iotdb/confignode/consensus/response/pipe/PipeResp.java
index 11a5c618d0..c0c134d282 100644
--- a/confignode/src/main/java/org/apache/iotdb/confignode/consensus/response/PipeResp.java
+++ b/confignode/src/main/java/org/apache/iotdb/confignode/consensus/response/pipe/PipeResp.java
@@ -16,7 +16,7 @@
* specific language governing permissions and limitations
* under the License.
*/
-package org.apache.iotdb.confignode.consensus.response;
+package org.apache.iotdb.confignode.consensus.response.pipe;
import org.apache.iotdb.common.rpc.thrift.TSStatus;
import org.apache.iotdb.commons.sync.pipe.PipeInfo;
diff --git a/confignode/src/main/java/org/apache/iotdb/confignode/consensus/response/PipeSinkResp.java b/confignode/src/main/java/org/apache/iotdb/confignode/consensus/response/pipe/PipeSinkResp.java
similarity index 95%
rename from confignode/src/main/java/org/apache/iotdb/confignode/consensus/response/PipeSinkResp.java
rename to confignode/src/main/java/org/apache/iotdb/confignode/consensus/response/pipe/PipeSinkResp.java
index ff6c7112d6..f06dbe50eb 100644
--- a/confignode/src/main/java/org/apache/iotdb/confignode/consensus/response/PipeSinkResp.java
+++ b/confignode/src/main/java/org/apache/iotdb/confignode/consensus/response/pipe/PipeSinkResp.java
@@ -16,7 +16,7 @@
* specific language governing permissions and limitations
* under the License.
*/
-package org.apache.iotdb.confignode.consensus.response;
+package org.apache.iotdb.confignode.consensus.response.pipe;
import org.apache.iotdb.common.rpc.thrift.TSStatus;
import org.apache.iotdb.commons.sync.pipesink.PipeSink;
diff --git a/confignode/src/main/java/org/apache/iotdb/confignode/consensus/response/AllTemplateSetInfoResp.java b/confignode/src/main/java/org/apache/iotdb/confignode/consensus/response/template/AllTemplateSetInfoResp.java
similarity index 94%
rename from confignode/src/main/java/org/apache/iotdb/confignode/consensus/response/AllTemplateSetInfoResp.java
rename to confignode/src/main/java/org/apache/iotdb/confignode/consensus/response/template/AllTemplateSetInfoResp.java
index 8b1365e0f0..f07f84bcd9 100644
--- a/confignode/src/main/java/org/apache/iotdb/confignode/consensus/response/AllTemplateSetInfoResp.java
+++ b/confignode/src/main/java/org/apache/iotdb/confignode/consensus/response/template/AllTemplateSetInfoResp.java
@@ -17,7 +17,7 @@
* under the License.
*/
-package org.apache.iotdb.confignode.consensus.response;
+package org.apache.iotdb.confignode.consensus.response.template;
import org.apache.iotdb.consensus.common.DataSet;
diff --git a/confignode/src/main/java/org/apache/iotdb/confignode/consensus/response/TemplateInfoResp.java b/confignode/src/main/java/org/apache/iotdb/confignode/consensus/response/template/TemplateInfoResp.java
similarity index 95%
rename from confignode/src/main/java/org/apache/iotdb/confignode/consensus/response/TemplateInfoResp.java
rename to confignode/src/main/java/org/apache/iotdb/confignode/consensus/response/template/TemplateInfoResp.java
index c427867b48..fe2fae6517 100644
--- a/confignode/src/main/java/org/apache/iotdb/confignode/consensus/response/TemplateInfoResp.java
+++ b/confignode/src/main/java/org/apache/iotdb/confignode/consensus/response/template/TemplateInfoResp.java
@@ -17,7 +17,7 @@
* under the License.
*/
-package org.apache.iotdb.confignode.consensus.response;
+package org.apache.iotdb.confignode.consensus.response.template;
import org.apache.iotdb.common.rpc.thrift.TSStatus;
import org.apache.iotdb.consensus.common.DataSet;
diff --git a/confignode/src/main/java/org/apache/iotdb/confignode/consensus/response/TemplateSetInfoResp.java b/confignode/src/main/java/org/apache/iotdb/confignode/consensus/response/template/TemplateSetInfoResp.java
similarity index 96%
rename from confignode/src/main/java/org/apache/iotdb/confignode/consensus/response/TemplateSetInfoResp.java
rename to confignode/src/main/java/org/apache/iotdb/confignode/consensus/response/template/TemplateSetInfoResp.java
index f7573499fa..7294eb5e46 100644
--- a/confignode/src/main/java/org/apache/iotdb/confignode/consensus/response/TemplateSetInfoResp.java
+++ b/confignode/src/main/java/org/apache/iotdb/confignode/consensus/response/template/TemplateSetInfoResp.java
@@ -17,7 +17,7 @@
* under the License.
*/
-package org.apache.iotdb.confignode.consensus.response;
+package org.apache.iotdb.confignode.consensus.response.template;
import org.apache.iotdb.common.rpc.thrift.TSStatus;
import org.apache.iotdb.commons.path.PartialPath;
diff --git a/confignode/src/main/java/org/apache/iotdb/confignode/consensus/response/TransferringTriggersResp.java b/confignode/src/main/java/org/apache/iotdb/confignode/consensus/response/trigger/TransferringTriggersResp.java
similarity index 95%
rename from confignode/src/main/java/org/apache/iotdb/confignode/consensus/response/TransferringTriggersResp.java
rename to confignode/src/main/java/org/apache/iotdb/confignode/consensus/response/trigger/TransferringTriggersResp.java
index 11d6671e44..a8545b6f70 100644
--- a/confignode/src/main/java/org/apache/iotdb/confignode/consensus/response/TransferringTriggersResp.java
+++ b/confignode/src/main/java/org/apache/iotdb/confignode/consensus/response/trigger/TransferringTriggersResp.java
@@ -17,7 +17,7 @@
* under the License.
*/
-package org.apache.iotdb.confignode.consensus.response;
+package org.apache.iotdb.confignode.consensus.response.trigger;
import org.apache.iotdb.consensus.common.DataSet;
diff --git a/confignode/src/main/java/org/apache/iotdb/confignode/consensus/response/TriggerLocationResp.java b/confignode/src/main/java/org/apache/iotdb/confignode/consensus/response/trigger/TriggerLocationResp.java
similarity index 96%
rename from confignode/src/main/java/org/apache/iotdb/confignode/consensus/response/TriggerLocationResp.java
rename to confignode/src/main/java/org/apache/iotdb/confignode/consensus/response/trigger/TriggerLocationResp.java
index 12a8165945..362142762a 100644
--- a/confignode/src/main/java/org/apache/iotdb/confignode/consensus/response/TriggerLocationResp.java
+++ b/confignode/src/main/java/org/apache/iotdb/confignode/consensus/response/trigger/TriggerLocationResp.java
@@ -17,7 +17,7 @@
* under the License.
*/
-package org.apache.iotdb.confignode.consensus.response;
+package org.apache.iotdb.confignode.consensus.response.trigger;
import org.apache.iotdb.common.rpc.thrift.TDataNodeLocation;
import org.apache.iotdb.common.rpc.thrift.TSStatus;
diff --git a/confignode/src/main/java/org/apache/iotdb/confignode/consensus/response/TriggerTableResp.java b/confignode/src/main/java/org/apache/iotdb/confignode/consensus/response/trigger/TriggerTableResp.java
similarity index 97%
rename from confignode/src/main/java/org/apache/iotdb/confignode/consensus/response/TriggerTableResp.java
rename to confignode/src/main/java/org/apache/iotdb/confignode/consensus/response/trigger/TriggerTableResp.java
index 77305ac07f..ed4d85b2f6 100644
--- a/confignode/src/main/java/org/apache/iotdb/confignode/consensus/response/TriggerTableResp.java
+++ b/confignode/src/main/java/org/apache/iotdb/confignode/consensus/response/trigger/TriggerTableResp.java
@@ -17,7 +17,7 @@
* under the License.
*/
-package org.apache.iotdb.confignode.consensus.response;
+package org.apache.iotdb.confignode.consensus.response.trigger;
import org.apache.iotdb.common.rpc.thrift.TSStatus;
import org.apache.iotdb.commons.trigger.TriggerInformation;
diff --git a/confignode/src/main/java/org/apache/iotdb/confignode/consensus/response/JarResp.java b/confignode/src/main/java/org/apache/iotdb/confignode/consensus/response/udf/JarResp.java
similarity index 96%
rename from confignode/src/main/java/org/apache/iotdb/confignode/consensus/response/JarResp.java
rename to confignode/src/main/java/org/apache/iotdb/confignode/consensus/response/udf/JarResp.java
index 59a8a56382..6ec80fe504 100644
--- a/confignode/src/main/java/org/apache/iotdb/confignode/consensus/response/JarResp.java
+++ b/confignode/src/main/java/org/apache/iotdb/confignode/consensus/response/udf/JarResp.java
@@ -17,7 +17,7 @@
* under the License.
*/
-package org.apache.iotdb.confignode.consensus.response;
+package org.apache.iotdb.confignode.consensus.response.udf;
import org.apache.iotdb.common.rpc.thrift.TSStatus;
import org.apache.iotdb.confignode.rpc.thrift.TGetJarInListResp;
diff --git a/confignode/src/main/java/org/apache/iotdb/confignode/manager/ClusterSchemaManager.java b/confignode/src/main/java/org/apache/iotdb/confignode/manager/ClusterSchemaManager.java
index 83d398c49e..b2b45472a1 100644
--- a/confignode/src/main/java/org/apache/iotdb/confignode/manager/ClusterSchemaManager.java
+++ b/confignode/src/main/java/org/apache/iotdb/confignode/manager/ClusterSchemaManager.java
@@ -33,8 +33,8 @@ import org.apache.iotdb.confignode.client.async.handlers.AsyncClientHandler;
import org.apache.iotdb.confignode.client.sync.SyncDataNodeClientPool;
import org.apache.iotdb.confignode.conf.ConfigNodeConfig;
import org.apache.iotdb.confignode.conf.ConfigNodeDescriptor;
-import org.apache.iotdb.confignode.consensus.request.read.storagegroup.CountStorageGroupPlan;
-import org.apache.iotdb.confignode.consensus.request.read.storagegroup.GetStorageGroupPlan;
+import org.apache.iotdb.confignode.consensus.request.read.database.CountDatabasePlan;
+import org.apache.iotdb.confignode.consensus.request.read.database.GetDatabasePlan;
import org.apache.iotdb.confignode.consensus.request.read.template.CheckTemplateSettablePlan;
import org.apache.iotdb.confignode.consensus.request.read.template.GetAllSchemaTemplatePlan;
import org.apache.iotdb.confignode.consensus.request.read.template.GetAllTemplateSetInfoPlan;
@@ -43,7 +43,7 @@ import org.apache.iotdb.confignode.consensus.request.read.template.GetSchemaTemp
import org.apache.iotdb.confignode.consensus.request.read.template.GetTemplateSetInfoPlan;
import org.apache.iotdb.confignode.consensus.request.write.storagegroup.AdjustMaxRegionGroupNumPlan;
import org.apache.iotdb.confignode.consensus.request.write.storagegroup.DatabaseSchemaPlan;
-import org.apache.iotdb.confignode.consensus.request.write.storagegroup.DeleteStorageGroupPlan;
+import org.apache.iotdb.confignode.consensus.request.write.storagegroup.DeleteDatabasePlan;
import org.apache.iotdb.confignode.consensus.request.write.storagegroup.SetDataReplicationFactorPlan;
import org.apache.iotdb.confignode.consensus.request.write.storagegroup.SetSchemaReplicationFactorPlan;
import org.apache.iotdb.confignode.consensus.request.write.storagegroup.SetTTLPlan;
@@ -54,11 +54,11 @@ import org.apache.iotdb.confignode.consensus.request.write.template.PreUnsetSche
import org.apache.iotdb.confignode.consensus.request.write.template.RollbackPreUnsetSchemaTemplatePlan;
import org.apache.iotdb.confignode.consensus.request.write.template.SetSchemaTemplatePlan;
import org.apache.iotdb.confignode.consensus.request.write.template.UnsetSchemaTemplatePlan;
-import org.apache.iotdb.confignode.consensus.response.AllTemplateSetInfoResp;
-import org.apache.iotdb.confignode.consensus.response.PathInfoResp;
-import org.apache.iotdb.confignode.consensus.response.StorageGroupSchemaResp;
-import org.apache.iotdb.confignode.consensus.response.TemplateInfoResp;
-import org.apache.iotdb.confignode.consensus.response.TemplateSetInfoResp;
+import org.apache.iotdb.confignode.consensus.response.database.DatabaseSchemaResp;
+import org.apache.iotdb.confignode.consensus.response.partition.PathInfoResp;
+import org.apache.iotdb.confignode.consensus.response.template.AllTemplateSetInfoResp;
+import org.apache.iotdb.confignode.consensus.response.template.TemplateInfoResp;
+import org.apache.iotdb.confignode.consensus.response.template.TemplateSetInfoResp;
import org.apache.iotdb.confignode.exception.DatabaseNotExistsException;
import org.apache.iotdb.confignode.manager.node.NodeManager;
import org.apache.iotdb.confignode.manager.observer.NodeStatisticsEvent;
@@ -207,8 +207,8 @@ public class ClusterSchemaManager {
}
/** Delete StorageGroup synchronized to protect the safety of adjustMaxRegionGroupNum */
- public synchronized TSStatus deleteStorageGroup(DeleteStorageGroupPlan deleteStorageGroupPlan) {
- TSStatus result = getConsensusManager().write(deleteStorageGroupPlan).getStatus();
+ public synchronized TSStatus deleteStorageGroup(DeleteDatabasePlan deleteDatabasePlan) {
+ TSStatus result = getConsensusManager().write(deleteDatabasePlan).getStatus();
// Adjust the maximum RegionGroup number of each StorageGroup after deleting the storage group
if (result.getCode() == TSStatusCode.SUCCESS_STATUS.getStatusCode()) {
adjustMaxRegionGroupNum();
@@ -221,8 +221,8 @@ public class ClusterSchemaManager {
*
* @return CountStorageGroupResp
*/
- public DataSet countMatchedStorageGroups(CountStorageGroupPlan countStorageGroupPlan) {
- return getConsensusManager().read(countStorageGroupPlan).getDataset();
+ public DataSet countMatchedStorageGroups(CountDatabasePlan countDatabasePlan) {
+ return getConsensusManager().read(countDatabasePlan).getDataset();
}
/**
@@ -230,22 +230,21 @@ public class ClusterSchemaManager {
*
* @return StorageGroupSchemaDataSet
*/
- public DataSet getMatchedStorageGroupSchema(GetStorageGroupPlan getStorageGroupPlan) {
+ public DataSet getMatchedStorageGroupSchema(GetDatabasePlan getStorageGroupPlan) {
return getConsensusManager().read(getStorageGroupPlan).getDataset();
}
/** Only used in cluster tool show StorageGroup */
- public TShowDatabaseResp showStorageGroup(GetStorageGroupPlan getStorageGroupPlan) {
- StorageGroupSchemaResp storageGroupSchemaResp =
- (StorageGroupSchemaResp) getMatchedStorageGroupSchema(getStorageGroupPlan);
- if (storageGroupSchemaResp.getStatus().getCode()
- != TSStatusCode.SUCCESS_STATUS.getStatusCode()) {
+ public TShowDatabaseResp showStorageGroup(GetDatabasePlan getStorageGroupPlan) {
+ DatabaseSchemaResp databaseSchemaResp =
+ (DatabaseSchemaResp) getMatchedStorageGroupSchema(getStorageGroupPlan);
+ if (databaseSchemaResp.getStatus().getCode() != TSStatusCode.SUCCESS_STATUS.getStatusCode()) {
// Return immediately if some StorageGroups doesn't exist
- return new TShowDatabaseResp().setStatus(storageGroupSchemaResp.getStatus());
+ return new TShowDatabaseResp().setStatus(databaseSchemaResp.getStatus());
}
Map<String, TDatabaseInfo> infoMap = new ConcurrentHashMap<>();
- for (TDatabaseSchema storageGroupSchema : storageGroupSchemaResp.getSchemaMap().values()) {
+ for (TDatabaseSchema storageGroupSchema : databaseSchemaResp.getSchemaMap().values()) {
String database = storageGroupSchema.getName();
TDatabaseInfo storageGroupInfo = new TDatabaseInfo();
storageGroupInfo.setName(database);
@@ -278,20 +277,19 @@ public class ClusterSchemaManager {
infoMap.put(database, storageGroupInfo);
}
- return new TShowDatabaseResp().setStorageGroupInfoMap(infoMap).setStatus(StatusUtils.OK);
+ return new TShowDatabaseResp().setDatabaseInfoMap(infoMap).setStatus(StatusUtils.OK);
}
public Map<String, Long> getAllTTLInfo() {
- StorageGroupSchemaResp storageGroupSchemaResp =
- (StorageGroupSchemaResp)
- getMatchedStorageGroupSchema(new GetStorageGroupPlan(Arrays.asList("root", "**")));
+ DatabaseSchemaResp databaseSchemaResp =
+ (DatabaseSchemaResp)
+ getMatchedStorageGroupSchema(new GetDatabasePlan(Arrays.asList("root", "**")));
Map<String, Long> infoMap = new ConcurrentHashMap<>();
- if (storageGroupSchemaResp.getStatus().getCode()
- != TSStatusCode.SUCCESS_STATUS.getStatusCode()) {
+ if (databaseSchemaResp.getStatus().getCode() != TSStatusCode.SUCCESS_STATUS.getStatusCode()) {
// Return immediately if some StorageGroups doesn't exist
return infoMap;
}
- for (TDatabaseSchema storageGroupSchema : storageGroupSchemaResp.getSchemaMap().values()) {
+ for (TDatabaseSchema storageGroupSchema : databaseSchemaResp.getSchemaMap().values()) {
infoMap.put(storageGroupSchema.getName(), storageGroupSchema.getTTL());
}
return infoMap;
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 2bb0c087a4..327a8f5afc 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
@@ -44,6 +44,8 @@ import org.apache.iotdb.confignode.conf.ConfigNodeConfig;
import org.apache.iotdb.confignode.conf.ConfigNodeDescriptor;
import org.apache.iotdb.confignode.conf.SystemPropertiesUtils;
import org.apache.iotdb.confignode.consensus.request.auth.AuthorPlan;
+import org.apache.iotdb.confignode.consensus.request.read.database.CountDatabasePlan;
+import org.apache.iotdb.confignode.consensus.request.read.database.GetDatabasePlan;
import org.apache.iotdb.confignode.consensus.request.read.datanode.GetDataNodeConfigurationPlan;
import org.apache.iotdb.confignode.consensus.request.read.partition.GetDataPartitionPlan;
import org.apache.iotdb.confignode.consensus.request.read.partition.GetNodePathsPartitionPlan;
@@ -53,8 +55,6 @@ import org.apache.iotdb.confignode.consensus.request.read.partition.GetSchemaPar
import org.apache.iotdb.confignode.consensus.request.read.partition.GetSeriesSlotListPlan;
import org.apache.iotdb.confignode.consensus.request.read.partition.GetTimeSlotListPlan;
import org.apache.iotdb.confignode.consensus.request.read.region.GetRegionInfoListPlan;
-import org.apache.iotdb.confignode.consensus.request.read.storagegroup.CountStorageGroupPlan;
-import org.apache.iotdb.confignode.consensus.request.read.storagegroup.GetStorageGroupPlan;
import org.apache.iotdb.confignode.consensus.request.write.confignode.RemoveConfigNodePlan;
import org.apache.iotdb.confignode.consensus.request.write.datanode.RegisterDataNodePlan;
import org.apache.iotdb.confignode.consensus.request.write.datanode.RemoveDataNodePlan;
@@ -67,18 +67,18 @@ import org.apache.iotdb.confignode.consensus.request.write.storagegroup.SetTimeP
import org.apache.iotdb.confignode.consensus.request.write.sync.CreatePipeSinkPlan;
import org.apache.iotdb.confignode.consensus.request.write.sync.DropPipeSinkPlan;
import org.apache.iotdb.confignode.consensus.request.write.template.CreateSchemaTemplatePlan;
-import org.apache.iotdb.confignode.consensus.response.ConfigurationResp;
-import org.apache.iotdb.confignode.consensus.response.CountStorageGroupResp;
-import org.apache.iotdb.confignode.consensus.response.DataNodeConfigurationResp;
-import org.apache.iotdb.confignode.consensus.response.DataNodeRegisterResp;
-import org.apache.iotdb.confignode.consensus.response.DataNodeToStatusResp;
-import org.apache.iotdb.confignode.consensus.response.DataPartitionResp;
-import org.apache.iotdb.confignode.consensus.response.PermissionInfoResp;
-import org.apache.iotdb.confignode.consensus.response.RegionInfoListResp;
-import org.apache.iotdb.confignode.consensus.response.SchemaNodeManagementResp;
-import org.apache.iotdb.confignode.consensus.response.SchemaPartitionResp;
-import org.apache.iotdb.confignode.consensus.response.StorageGroupSchemaResp;
-import org.apache.iotdb.confignode.consensus.response.TemplateSetInfoResp;
+import org.apache.iotdb.confignode.consensus.response.auth.PermissionInfoResp;
+import org.apache.iotdb.confignode.consensus.response.database.CountDatabaseResp;
+import org.apache.iotdb.confignode.consensus.response.database.DatabaseSchemaResp;
+import org.apache.iotdb.confignode.consensus.response.datanode.ConfigurationResp;
+import org.apache.iotdb.confignode.consensus.response.datanode.DataNodeConfigurationResp;
+import org.apache.iotdb.confignode.consensus.response.datanode.DataNodeRegisterResp;
+import org.apache.iotdb.confignode.consensus.response.datanode.DataNodeToStatusResp;
+import org.apache.iotdb.confignode.consensus.response.partition.DataPartitionResp;
+import org.apache.iotdb.confignode.consensus.response.partition.RegionInfoListResp;
+import org.apache.iotdb.confignode.consensus.response.partition.SchemaNodeManagementResp;
+import org.apache.iotdb.confignode.consensus.response.partition.SchemaPartitionResp;
+import org.apache.iotdb.confignode.consensus.response.template.TemplateSetInfoResp;
import org.apache.iotdb.confignode.consensus.statemachine.ConfigNodeRegionStateMachine;
import org.apache.iotdb.confignode.manager.cq.CQManager;
import org.apache.iotdb.confignode.manager.load.LoadManager;
@@ -486,11 +486,11 @@ public class ConfigManager implements IManager {
}
@Override
- public DataSet countMatchedStorageGroups(CountStorageGroupPlan countStorageGroupPlan) {
+ public DataSet countMatchedStorageGroups(CountDatabasePlan countDatabasePlan) {
TSStatus status = confirmLeader();
- CountStorageGroupResp result = new CountStorageGroupResp();
+ CountDatabaseResp result = new CountDatabaseResp();
if (status.getCode() == TSStatusCode.SUCCESS_STATUS.getStatusCode()) {
- return clusterSchemaManager.countMatchedStorageGroups(countStorageGroupPlan);
+ return clusterSchemaManager.countMatchedStorageGroups(countDatabasePlan);
} else {
result.setStatus(status);
}
@@ -498,12 +498,12 @@ public class ConfigManager implements IManager {
}
@Override
- public DataSet getMatchedStorageGroupSchemas(GetStorageGroupPlan getStorageGroupReq) {
+ public DataSet getMatchedStorageGroupSchemas(GetDatabasePlan getStorageGroupReq) {
TSStatus status = confirmLeader();
if (status.getCode() == TSStatusCode.SUCCESS_STATUS.getStatusCode()) {
return clusterSchemaManager.getMatchedStorageGroupSchema(getStorageGroupReq);
} else {
- StorageGroupSchemaResp dataSet = new StorageGroupSchemaResp();
+ DatabaseSchemaResp dataSet = new DatabaseSchemaResp();
dataSet.setStatus(status);
return dataSet;
}
@@ -1304,7 +1304,7 @@ public class ConfigManager implements IManager {
}
@Override
- public TShowDatabaseResp showStorageGroup(GetStorageGroupPlan getStorageGroupPlan) {
+ public TShowDatabaseResp showStorageGroup(GetDatabasePlan getStorageGroupPlan) {
TSStatus status = confirmLeader();
if (status.getCode() == TSStatusCode.SUCCESS_STATUS.getStatusCode()) {
return getClusterSchemaManager().showStorageGroup(getStorageGroupPlan);
diff --git a/confignode/src/main/java/org/apache/iotdb/confignode/manager/IManager.java b/confignode/src/main/java/org/apache/iotdb/confignode/manager/IManager.java
index 743af47af3..d59791c5ab 100644
--- a/confignode/src/main/java/org/apache/iotdb/confignode/manager/IManager.java
+++ b/confignode/src/main/java/org/apache/iotdb/confignode/manager/IManager.java
@@ -25,14 +25,14 @@ import org.apache.iotdb.common.rpc.thrift.TSStatus;
import org.apache.iotdb.commons.path.PartialPath;
import org.apache.iotdb.commons.path.PathPatternTree;
import org.apache.iotdb.confignode.consensus.request.auth.AuthorPlan;
+import org.apache.iotdb.confignode.consensus.request.read.database.CountDatabasePlan;
+import org.apache.iotdb.confignode.consensus.request.read.database.GetDatabasePlan;
import org.apache.iotdb.confignode.consensus.request.read.datanode.GetDataNodeConfigurationPlan;
import org.apache.iotdb.confignode.consensus.request.read.partition.GetDataPartitionPlan;
import org.apache.iotdb.confignode.consensus.request.read.partition.GetOrCreateDataPartitionPlan;
import org.apache.iotdb.confignode.consensus.request.read.partition.GetSeriesSlotListPlan;
import org.apache.iotdb.confignode.consensus.request.read.partition.GetTimeSlotListPlan;
import org.apache.iotdb.confignode.consensus.request.read.region.GetRegionInfoListPlan;
-import org.apache.iotdb.confignode.consensus.request.read.storagegroup.CountStorageGroupPlan;
-import org.apache.iotdb.confignode.consensus.request.read.storagegroup.GetStorageGroupPlan;
import org.apache.iotdb.confignode.consensus.request.write.confignode.RemoveConfigNodePlan;
import org.apache.iotdb.confignode.consensus.request.write.datanode.RemoveDataNodePlan;
import org.apache.iotdb.confignode.consensus.request.write.datanode.UpdateDataNodePlan;
@@ -264,14 +264,14 @@ public interface IManager {
*
* @return The number of matched StorageGroups
*/
- DataSet countMatchedStorageGroups(CountStorageGroupPlan countStorageGroupPlan);
+ DataSet countMatchedStorageGroups(CountDatabasePlan countDatabasePlan);
/**
* Get StorageGroupSchemas
*
* @return StorageGroupSchemaDataSet
*/
- DataSet getMatchedStorageGroupSchemas(GetStorageGroupPlan getOrCountStorageGroupPlan);
+ DataSet getMatchedStorageGroupSchemas(GetDatabasePlan getOrCountStorageGroupPlan);
/**
* Set Database
@@ -446,7 +446,7 @@ public interface IManager {
* @param getStorageGroupPlan GetStorageGroupPlan, including path patterns about StorageGroups
* @return TShowStorageGroupResp
*/
- TShowDatabaseResp showStorageGroup(GetStorageGroupPlan getStorageGroupPlan);
+ TShowDatabaseResp showStorageGroup(GetDatabasePlan getStorageGroupPlan);
/**
* create schema template
diff --git a/confignode/src/main/java/org/apache/iotdb/confignode/manager/PermissionManager.java b/confignode/src/main/java/org/apache/iotdb/confignode/manager/PermissionManager.java
index 150d7175c3..3aee9c071d 100644
--- a/confignode/src/main/java/org/apache/iotdb/confignode/manager/PermissionManager.java
+++ b/confignode/src/main/java/org/apache/iotdb/confignode/manager/PermissionManager.java
@@ -25,7 +25,7 @@ import org.apache.iotdb.confignode.client.DataNodeRequestType;
import org.apache.iotdb.confignode.client.sync.SyncDataNodeClientPool;
import org.apache.iotdb.confignode.consensus.request.ConfigPhysicalPlanType;
import org.apache.iotdb.confignode.consensus.request.auth.AuthorPlan;
-import org.apache.iotdb.confignode.consensus.response.PermissionInfoResp;
+import org.apache.iotdb.confignode.consensus.response.auth.PermissionInfoResp;
import org.apache.iotdb.confignode.persistence.AuthorInfo;
import org.apache.iotdb.confignode.rpc.thrift.TPermissionInfoResp;
import org.apache.iotdb.mpp.rpc.thrift.TInvalidatePermissionCacheReq;
diff --git a/confignode/src/main/java/org/apache/iotdb/confignode/manager/SyncManager.java b/confignode/src/main/java/org/apache/iotdb/confignode/manager/SyncManager.java
index 92b6fe2b7f..9e5645af7b 100644
--- a/confignode/src/main/java/org/apache/iotdb/confignode/manager/SyncManager.java
+++ b/confignode/src/main/java/org/apache/iotdb/confignode/manager/SyncManager.java
@@ -41,8 +41,8 @@ import org.apache.iotdb.confignode.consensus.request.write.sync.PreCreatePipePla
import org.apache.iotdb.confignode.consensus.request.write.sync.RecordPipeMessagePlan;
import org.apache.iotdb.confignode.consensus.request.write.sync.SetPipeStatusPlan;
import org.apache.iotdb.confignode.consensus.request.write.sync.ShowPipePlan;
-import org.apache.iotdb.confignode.consensus.response.PipeResp;
-import org.apache.iotdb.confignode.consensus.response.PipeSinkResp;
+import org.apache.iotdb.confignode.consensus.response.pipe.PipeResp;
+import org.apache.iotdb.confignode.consensus.response.pipe.PipeSinkResp;
import org.apache.iotdb.confignode.manager.node.NodeManager;
import org.apache.iotdb.confignode.manager.observer.NodeStatisticsEvent;
import org.apache.iotdb.confignode.persistence.sync.ClusterSyncInfo;
diff --git a/confignode/src/main/java/org/apache/iotdb/confignode/manager/TriggerManager.java b/confignode/src/main/java/org/apache/iotdb/confignode/manager/TriggerManager.java
index 6f6813952c..ae094acc3e 100644
--- a/confignode/src/main/java/org/apache/iotdb/confignode/manager/TriggerManager.java
+++ b/confignode/src/main/java/org/apache/iotdb/confignode/manager/TriggerManager.java
@@ -33,10 +33,10 @@ import org.apache.iotdb.confignode.consensus.request.read.trigger.GetTriggerLoca
import org.apache.iotdb.confignode.consensus.request.read.trigger.GetTriggerTablePlan;
import org.apache.iotdb.confignode.consensus.request.write.trigger.UpdateTriggerLocationPlan;
import org.apache.iotdb.confignode.consensus.request.write.trigger.UpdateTriggersOnTransferNodesPlan;
-import org.apache.iotdb.confignode.consensus.response.JarResp;
-import org.apache.iotdb.confignode.consensus.response.TransferringTriggersResp;
-import org.apache.iotdb.confignode.consensus.response.TriggerLocationResp;
-import org.apache.iotdb.confignode.consensus.response.TriggerTableResp;
+import org.apache.iotdb.confignode.consensus.response.trigger.TransferringTriggersResp;
+import org.apache.iotdb.confignode.consensus.response.trigger.TriggerLocationResp;
+import org.apache.iotdb.confignode.consensus.response.trigger.TriggerTableResp;
+import org.apache.iotdb.confignode.consensus.response.udf.JarResp;
import org.apache.iotdb.confignode.manager.node.NodeManager;
import org.apache.iotdb.confignode.persistence.TriggerInfo;
import org.apache.iotdb.confignode.rpc.thrift.TCreateTriggerReq;
diff --git a/confignode/src/main/java/org/apache/iotdb/confignode/manager/UDFManager.java b/confignode/src/main/java/org/apache/iotdb/confignode/manager/UDFManager.java
index 38d177911c..96485bffc2 100644
--- a/confignode/src/main/java/org/apache/iotdb/confignode/manager/UDFManager.java
+++ b/confignode/src/main/java/org/apache/iotdb/confignode/manager/UDFManager.java
@@ -31,8 +31,8 @@ import org.apache.iotdb.confignode.consensus.request.read.function.GetFunctionTa
import org.apache.iotdb.confignode.consensus.request.read.udf.GetUDFJarPlan;
import org.apache.iotdb.confignode.consensus.request.write.function.CreateFunctionPlan;
import org.apache.iotdb.confignode.consensus.request.write.function.DropFunctionPlan;
-import org.apache.iotdb.confignode.consensus.response.FunctionTableResp;
-import org.apache.iotdb.confignode.consensus.response.JarResp;
+import org.apache.iotdb.confignode.consensus.response.function.FunctionTableResp;
+import org.apache.iotdb.confignode.consensus.response.udf.JarResp;
import org.apache.iotdb.confignode.persistence.UDFInfo;
import org.apache.iotdb.confignode.rpc.thrift.TCreateFunctionReq;
import org.apache.iotdb.confignode.rpc.thrift.TGetJarInListReq;
diff --git a/confignode/src/main/java/org/apache/iotdb/confignode/manager/cq/CQManager.java b/confignode/src/main/java/org/apache/iotdb/confignode/manager/cq/CQManager.java
index ead3f1b63f..25a1763ffc 100644
--- a/confignode/src/main/java/org/apache/iotdb/confignode/manager/cq/CQManager.java
+++ b/confignode/src/main/java/org/apache/iotdb/confignode/manager/cq/CQManager.java
@@ -25,7 +25,7 @@ import org.apache.iotdb.confignode.conf.ConfigNodeConfig;
import org.apache.iotdb.confignode.conf.ConfigNodeDescriptor;
import org.apache.iotdb.confignode.consensus.request.write.cq.DropCQPlan;
import org.apache.iotdb.confignode.consensus.request.write.cq.ShowCQPlan;
-import org.apache.iotdb.confignode.consensus.response.ShowCQResp;
+import org.apache.iotdb.confignode.consensus.response.cq.ShowCQResp;
import org.apache.iotdb.confignode.manager.ConfigManager;
import org.apache.iotdb.confignode.persistence.cq.CQInfo;
import org.apache.iotdb.confignode.rpc.thrift.TCreateCQReq;
diff --git a/confignode/src/main/java/org/apache/iotdb/confignode/manager/node/NodeManager.java b/confignode/src/main/java/org/apache/iotdb/confignode/manager/node/NodeManager.java
index 6b8a42bb5a..a7040004c0 100644
--- a/confignode/src/main/java/org/apache/iotdb/confignode/manager/node/NodeManager.java
+++ b/confignode/src/main/java/org/apache/iotdb/confignode/manager/node/NodeManager.java
@@ -47,10 +47,10 @@ import org.apache.iotdb.confignode.consensus.request.write.confignode.RemoveConf
import org.apache.iotdb.confignode.consensus.request.write.datanode.RegisterDataNodePlan;
import org.apache.iotdb.confignode.consensus.request.write.datanode.RemoveDataNodePlan;
import org.apache.iotdb.confignode.consensus.request.write.datanode.UpdateDataNodePlan;
-import org.apache.iotdb.confignode.consensus.response.ConfigurationResp;
-import org.apache.iotdb.confignode.consensus.response.DataNodeConfigurationResp;
-import org.apache.iotdb.confignode.consensus.response.DataNodeRegisterResp;
-import org.apache.iotdb.confignode.consensus.response.DataNodeToStatusResp;
+import org.apache.iotdb.confignode.consensus.response.datanode.ConfigurationResp;
+import org.apache.iotdb.confignode.consensus.response.datanode.DataNodeConfigurationResp;
+import org.apache.iotdb.confignode.consensus.response.datanode.DataNodeRegisterResp;
+import org.apache.iotdb.confignode.consensus.response.datanode.DataNodeToStatusResp;
import org.apache.iotdb.confignode.manager.ClusterSchemaManager;
import org.apache.iotdb.confignode.manager.ConfigManager;
import org.apache.iotdb.confignode.manager.ConsensusManager;
diff --git a/confignode/src/main/java/org/apache/iotdb/confignode/manager/partition/PartitionManager.java b/confignode/src/main/java/org/apache/iotdb/confignode/manager/partition/PartitionManager.java
index 8c3e063711..b8fa5732e1 100644
--- a/confignode/src/main/java/org/apache/iotdb/confignode/manager/partition/PartitionManager.java
+++ b/confignode/src/main/java/org/apache/iotdb/confignode/manager/partition/PartitionManager.java
@@ -51,14 +51,14 @@ import org.apache.iotdb.confignode.consensus.request.write.partition.CreateSchem
import org.apache.iotdb.confignode.consensus.request.write.partition.UpdateRegionLocationPlan;
import org.apache.iotdb.confignode.consensus.request.write.region.CreateRegionGroupsPlan;
import org.apache.iotdb.confignode.consensus.request.write.region.PollRegionMaintainTaskPlan;
-import org.apache.iotdb.confignode.consensus.request.write.storagegroup.PreDeleteStorageGroupPlan;
-import org.apache.iotdb.confignode.consensus.response.DataPartitionResp;
-import org.apache.iotdb.confignode.consensus.response.GetRegionIdResp;
-import org.apache.iotdb.confignode.consensus.response.GetSeriesSlotListResp;
-import org.apache.iotdb.confignode.consensus.response.GetTimeSlotListResp;
-import org.apache.iotdb.confignode.consensus.response.RegionInfoListResp;
-import org.apache.iotdb.confignode.consensus.response.SchemaNodeManagementResp;
-import org.apache.iotdb.confignode.consensus.response.SchemaPartitionResp;
+import org.apache.iotdb.confignode.consensus.request.write.storagegroup.PreDeleteDatabasePlan;
+import org.apache.iotdb.confignode.consensus.response.partition.DataPartitionResp;
+import org.apache.iotdb.confignode.consensus.response.partition.GetRegionIdResp;
+import org.apache.iotdb.confignode.consensus.response.partition.GetSeriesSlotListResp;
+import org.apache.iotdb.confignode.consensus.response.partition.GetTimeSlotListResp;
+import org.apache.iotdb.confignode.consensus.response.partition.RegionInfoListResp;
+import org.apache.iotdb.confignode.consensus.response.partition.SchemaNodeManagementResp;
+import org.apache.iotdb.confignode.consensus.response.partition.SchemaPartitionResp;
import org.apache.iotdb.confignode.exception.DatabaseNotExistsException;
import org.apache.iotdb.confignode.exception.NoAvailableRegionGroupException;
import org.apache.iotdb.confignode.exception.NotEnoughDataNodeException;
@@ -643,10 +643,10 @@ public class PartitionManager {
}
public void preDeleteStorageGroup(
- String storageGroup, PreDeleteStorageGroupPlan.PreDeleteType preDeleteType) {
- final PreDeleteStorageGroupPlan preDeleteStorageGroupPlan =
- new PreDeleteStorageGroupPlan(storageGroup, preDeleteType);
- getConsensusManager().write(preDeleteStorageGroupPlan);
+ String storageGroup, PreDeleteDatabasePlan.PreDeleteType preDeleteType) {
+ final PreDeleteDatabasePlan preDeleteDatabasePlan =
+ new PreDeleteDatabasePlan(storageGroup, preDeleteType);
+ getConsensusManager().write(preDeleteDatabasePlan);
}
public void addMetrics() {
@@ -709,7 +709,7 @@ public class PartitionManager {
public GetRegionIdResp getRegionId(TGetRegionIdReq req) {
GetRegionIdPlan plan =
new GetRegionIdPlan(
- req.getStorageGroup(),
+ req.getDatabase(),
req.getType(),
req.isSetSeriesSlotId()
? req.getSeriesSlotId()
diff --git a/confignode/src/main/java/org/apache/iotdb/confignode/persistence/AuthorInfo.java b/confignode/src/main/java/org/apache/iotdb/confignode/persistence/AuthorInfo.java
index 3f7a473bc5..0d72f5a59a 100644
--- a/confignode/src/main/java/org/apache/iotdb/confignode/persistence/AuthorInfo.java
+++ b/confignode/src/main/java/org/apache/iotdb/confignode/persistence/AuthorInfo.java
@@ -36,7 +36,7 @@ import org.apache.iotdb.commons.utils.FileUtils;
import org.apache.iotdb.commons.utils.TestOnly;
import org.apache.iotdb.confignode.consensus.request.ConfigPhysicalPlanType;
import org.apache.iotdb.confignode.consensus.request.auth.AuthorPlan;
-import org.apache.iotdb.confignode.consensus.response.PermissionInfoResp;
+import org.apache.iotdb.confignode.consensus.response.auth.PermissionInfoResp;
import org.apache.iotdb.confignode.rpc.thrift.TPermissionInfoResp;
import org.apache.iotdb.confignode.rpc.thrift.TRoleResp;
import org.apache.iotdb.confignode.rpc.thrift.TUserResp;
diff --git a/confignode/src/main/java/org/apache/iotdb/confignode/persistence/TriggerInfo.java b/confignode/src/main/java/org/apache/iotdb/confignode/persistence/TriggerInfo.java
index 54fa77e2da..99816ad17a 100644
--- a/confignode/src/main/java/org/apache/iotdb/confignode/persistence/TriggerInfo.java
+++ b/confignode/src/main/java/org/apache/iotdb/confignode/persistence/TriggerInfo.java
@@ -38,10 +38,10 @@ import org.apache.iotdb.confignode.consensus.request.write.trigger.DeleteTrigger
import org.apache.iotdb.confignode.consensus.request.write.trigger.UpdateTriggerLocationPlan;
import org.apache.iotdb.confignode.consensus.request.write.trigger.UpdateTriggerStateInTablePlan;
import org.apache.iotdb.confignode.consensus.request.write.trigger.UpdateTriggersOnTransferNodesPlan;
-import org.apache.iotdb.confignode.consensus.response.JarResp;
-import org.apache.iotdb.confignode.consensus.response.TransferringTriggersResp;
-import org.apache.iotdb.confignode.consensus.response.TriggerLocationResp;
-import org.apache.iotdb.confignode.consensus.response.TriggerTableResp;
+import org.apache.iotdb.confignode.consensus.response.trigger.TransferringTriggersResp;
+import org.apache.iotdb.confignode.consensus.response.trigger.TriggerLocationResp;
+import org.apache.iotdb.confignode.consensus.response.trigger.TriggerTableResp;
+import org.apache.iotdb.confignode.consensus.response.udf.JarResp;
import org.apache.iotdb.confignode.rpc.thrift.TTriggerState;
import org.apache.iotdb.consensus.common.DataSet;
import org.apache.iotdb.rpc.TSStatusCode;
diff --git a/confignode/src/main/java/org/apache/iotdb/confignode/persistence/UDFInfo.java b/confignode/src/main/java/org/apache/iotdb/confignode/persistence/UDFInfo.java
index dc9e695d4f..bbc0198b29 100644
--- a/confignode/src/main/java/org/apache/iotdb/confignode/persistence/UDFInfo.java
+++ b/confignode/src/main/java/org/apache/iotdb/confignode/persistence/UDFInfo.java
@@ -31,8 +31,8 @@ import org.apache.iotdb.confignode.conf.ConfigNodeDescriptor;
import org.apache.iotdb.confignode.consensus.request.read.udf.GetUDFJarPlan;
import org.apache.iotdb.confignode.consensus.request.write.function.CreateFunctionPlan;
import org.apache.iotdb.confignode.consensus.request.write.function.DropFunctionPlan;
-import org.apache.iotdb.confignode.consensus.response.FunctionTableResp;
-import org.apache.iotdb.confignode.consensus.response.JarResp;
+import org.apache.iotdb.confignode.consensus.response.function.FunctionTableResp;
+import org.apache.iotdb.confignode.consensus.response.udf.JarResp;
import org.apache.iotdb.consensus.common.DataSet;
import org.apache.iotdb.rpc.TSStatusCode;
import org.apache.iotdb.tsfile.utils.ReadWriteIOUtils;
diff --git a/confignode/src/main/java/org/apache/iotdb/confignode/persistence/cq/CQInfo.java b/confignode/src/main/java/org/apache/iotdb/confignode/persistence/cq/CQInfo.java
index 3c296765d1..328eef6d25 100644
--- a/confignode/src/main/java/org/apache/iotdb/confignode/persistence/cq/CQInfo.java
+++ b/confignode/src/main/java/org/apache/iotdb/confignode/persistence/cq/CQInfo.java
@@ -27,7 +27,7 @@ import org.apache.iotdb.confignode.consensus.request.write.cq.AddCQPlan;
import org.apache.iotdb.confignode.consensus.request.write.cq.DropCQPlan;
import org.apache.iotdb.confignode.consensus.request.write.cq.ShowCQPlan;
import org.apache.iotdb.confignode.consensus.request.write.cq.UpdateCQLastExecTimePlan;
-import org.apache.iotdb.confignode.consensus.response.ShowCQResp;
+import org.apache.iotdb.confignode.consensus.response.cq.ShowCQResp;
import org.apache.iotdb.confignode.rpc.thrift.TCreateCQReq;
import org.apache.iotdb.rpc.TSStatusCode;
import org.apache.iotdb.tsfile.utils.ReadWriteIOUtils;
diff --git a/confignode/src/main/java/org/apache/iotdb/confignode/persistence/executor/ConfigPlanExecutor.java b/confignode/src/main/java/org/apache/iotdb/confignode/persistence/executor/ConfigPlanExecutor.java
index f7b41b2a80..8ac4878631 100644
--- a/confignode/src/main/java/org/apache/iotdb/confignode/persistence/executor/ConfigPlanExecutor.java
+++ b/confignode/src/main/java/org/apache/iotdb/confignode/persistence/executor/ConfigPlanExecutor.java
@@ -25,6 +25,8 @@ import org.apache.iotdb.commons.path.PartialPath;
import org.apache.iotdb.commons.snapshot.SnapshotProcessor;
import org.apache.iotdb.confignode.consensus.request.ConfigPhysicalPlan;
import org.apache.iotdb.confignode.consensus.request.auth.AuthorPlan;
+import org.apache.iotdb.confignode.consensus.request.read.database.CountDatabasePlan;
+import org.apache.iotdb.confignode.consensus.request.read.database.GetDatabasePlan;
import org.apache.iotdb.confignode.consensus.request.read.datanode.GetDataNodeConfigurationPlan;
import org.apache.iotdb.confignode.consensus.request.read.partition.GetDataPartitionPlan;
import org.apache.iotdb.confignode.consensus.request.read.partition.GetNodePathsPartitionPlan;
@@ -33,8 +35,6 @@ import org.apache.iotdb.confignode.consensus.request.read.partition.GetSeriesSlo
import org.apache.iotdb.confignode.consensus.request.read.partition.GetTimeSlotListPlan;
import org.apache.iotdb.confignode.consensus.request.read.region.GetRegionIdPlan;
import org.apache.iotdb.confignode.consensus.request.read.region.GetRegionInfoListPlan;
-import org.apache.iotdb.confignode.consensus.request.read.storagegroup.CountStorageGroupPlan;
-import org.apache.iotdb.confignode.consensus.request.read.storagegroup.GetStorageGroupPlan;
import org.apache.iotdb.confignode.consensus.request.read.template.CheckTemplateSettablePlan;
import org.apache.iotdb.confignode.consensus.request.read.template.GetPathsSetTemplatePlan;
import org.apache.iotdb.confignode.consensus.request.read.template.GetSchemaTemplatePlan;
@@ -64,8 +64,8 @@ import org.apache.iotdb.confignode.consensus.request.write.region.CreateRegionGr
import org.apache.iotdb.confignode.consensus.request.write.region.OfferRegionMaintainTasksPlan;
import org.apache.iotdb.confignode.consensus.request.write.storagegroup.AdjustMaxRegionGroupNumPlan;
import org.apache.iotdb.confignode.consensus.request.write.storagegroup.DatabaseSchemaPlan;
-import org.apache.iotdb.confignode.consensus.request.write.storagegroup.DeleteStorageGroupPlan;
-import org.apache.iotdb.confignode.consensus.request.write.storagegroup.PreDeleteStorageGroupPlan;
+import org.apache.iotdb.confignode.consensus.request.write.storagegroup.DeleteDatabasePlan;
+import org.apache.iotdb.confignode.consensus.request.write.storagegroup.PreDeleteDatabasePlan;
import org.apache.iotdb.confignode.consensus.request.write.storagegroup.SetDataReplicationFactorPlan;
import org.apache.iotdb.confignode.consensus.request.write.storagegroup.SetSchemaReplicationFactorPlan;
import org.apache.iotdb.confignode.consensus.request.write.storagegroup.SetTTLPlan;
@@ -89,7 +89,7 @@ import org.apache.iotdb.confignode.consensus.request.write.trigger.DeleteTrigger
import org.apache.iotdb.confignode.consensus.request.write.trigger.UpdateTriggerLocationPlan;
import org.apache.iotdb.confignode.consensus.request.write.trigger.UpdateTriggerStateInTablePlan;
import org.apache.iotdb.confignode.consensus.request.write.trigger.UpdateTriggersOnTransferNodesPlan;
-import org.apache.iotdb.confignode.consensus.response.SchemaNodeManagementResp;
+import org.apache.iotdb.confignode.consensus.response.partition.SchemaNodeManagementResp;
import org.apache.iotdb.confignode.exception.physical.UnknownPhysicalPlanTypeException;
import org.apache.iotdb.confignode.persistence.AuthorInfo;
import org.apache.iotdb.confignode.persistence.ProcedureInfo;
@@ -192,9 +192,9 @@ public class ConfigPlanExecutor {
case GetDataNodeConfiguration:
return nodeInfo.getDataNodeConfiguration((GetDataNodeConfigurationPlan) req);
case CountDatabase:
- return clusterSchemaInfo.countMatchedStorageGroups((CountStorageGroupPlan) req);
+ return clusterSchemaInfo.countMatchedDatabases((CountDatabasePlan) req);
case GetDatabase:
- return clusterSchemaInfo.getMatchedStorageGroupSchemas((GetStorageGroupPlan) req);
+ return clusterSchemaInfo.getMatchedDatabaseSchemas((GetDatabasePlan) req);
case GetDataPartition:
case GetOrCreateDataPartition:
return partitionInfo.getDataPartition((GetDataPartitionPlan) req);
@@ -275,10 +275,10 @@ public class ConfigPlanExecutor {
return clusterSchemaInfo.adjustMaxRegionGroupCount(
(AdjustMaxRegionGroupNumPlan) physicalPlan);
case DeleteDatabase:
- partitionInfo.deleteStorageGroup((DeleteStorageGroupPlan) physicalPlan);
- return clusterSchemaInfo.deleteStorageGroup((DeleteStorageGroupPlan) physicalPlan);
+ partitionInfo.deleteDatabase((DeleteDatabasePlan) physicalPlan);
+ return clusterSchemaInfo.deleteDatabase((DeleteDatabasePlan) physicalPlan);
case PreDeleteDatabase:
- return partitionInfo.preDeleteStorageGroup((PreDeleteStorageGroupPlan) physicalPlan);
+ return partitionInfo.preDeleteDatabase((PreDeleteDatabasePlan) physicalPlan);
case SetTTL:
return clusterSchemaInfo.setTTL((SetTTLPlan) physicalPlan);
case SetSchemaReplicationFactor:
@@ -487,14 +487,14 @@ public class ConfigPlanExecutor {
private DataSet getRegionInfoList(ConfigPhysicalPlan req) {
final GetRegionInfoListPlan getRegionInfoListPlan = (GetRegionInfoListPlan) req;
TShowRegionReq showRegionReq = getRegionInfoListPlan.getShowRegionReq();
- if (showRegionReq != null && showRegionReq.isSetStorageGroups()) {
- final List<String> storageGroups = showRegionReq.getStorageGroups();
+ if (showRegionReq != null && showRegionReq.isSetDatabases()) {
+ final List<String> storageGroups = showRegionReq.getDatabases();
final List<String> matchedStorageGroups =
clusterSchemaInfo.getMatchedDatabaseSchemasByName(storageGroups).values().stream()
.map(TDatabaseSchema::getName)
.collect(Collectors.toList());
if (!matchedStorageGroups.isEmpty()) {
- showRegionReq.setStorageGroups(matchedStorageGroups);
+ showRegionReq.setDatabases(matchedStorageGroups);
}
}
return partitionInfo.getRegionInfoList(getRegionInfoListPlan);
diff --git a/confignode/src/main/java/org/apache/iotdb/confignode/persistence/metric/PartitionInfoMetrics.java b/confignode/src/main/java/org/apache/iotdb/confignode/persistence/metric/PartitionInfoMetrics.java
index 59dc871c02..274f99e709 100644
--- a/confignode/src/main/java/org/apache/iotdb/confignode/persistence/metric/PartitionInfoMetrics.java
+++ b/confignode/src/main/java/org/apache/iotdb/confignode/persistence/metric/PartitionInfoMetrics.java
@@ -22,8 +22,8 @@ package org.apache.iotdb.confignode.persistence.metric;
import org.apache.iotdb.common.rpc.thrift.TConsensusGroupType;
import org.apache.iotdb.commons.service.metric.enums.Metric;
import org.apache.iotdb.commons.service.metric.enums.Tag;
+import org.apache.iotdb.confignode.persistence.partition.DatabasePartitionTable;
import org.apache.iotdb.confignode.persistence.partition.PartitionInfo;
-import org.apache.iotdb.confignode.persistence.partition.StorageGroupPartitionTable;
import org.apache.iotdb.metrics.AbstractMetricService;
import org.apache.iotdb.metrics.metricsets.IMetricSet;
import org.apache.iotdb.metrics.utils.MetricLevel;
@@ -101,11 +101,10 @@ public class PartitionInfoMetrics implements IMetricSet {
}
public static class StorageGroupPartitionTableMetrics implements IMetricSet {
- private StorageGroupPartitionTable storageGroupPartitionTable;
+ private DatabasePartitionTable databasePartitionTable;
- public StorageGroupPartitionTableMetrics(
- StorageGroupPartitionTable storageGroupPartitionTable) {
- this.storageGroupPartitionTable = storageGroupPartitionTable;
+ public StorageGroupPartitionTableMetrics(DatabasePartitionTable databasePartitionTable) {
+ this.databasePartitionTable = databasePartitionTable;
}
@Override
@@ -113,38 +112,38 @@ public class PartitionInfoMetrics implements IMetricSet {
metricService.createAutoGauge(
Metric.REGION.toString(),
MetricLevel.NORMAL,
- storageGroupPartitionTable,
+ databasePartitionTable,
o -> o.getRegionGroupCount(TConsensusGroupType.SchemaRegion),
Tag.NAME.toString(),
- storageGroupPartitionTable.getStorageGroupName(),
+ databasePartitionTable.getDatabaseName(),
Tag.TYPE.toString(),
TConsensusGroupType.SchemaRegion.toString());
metricService.createAutoGauge(
Metric.REGION.toString(),
MetricLevel.NORMAL,
- storageGroupPartitionTable,
+ databasePartitionTable,
o -> o.getRegionGroupCount(TConsensusGroupType.DataRegion),
Tag.NAME.toString(),
- storageGroupPartitionTable.getStorageGroupName(),
+ databasePartitionTable.getDatabaseName(),
Tag.TYPE.toString(),
TConsensusGroupType.DataRegion.toString());
// TODO slot will be updated in the future
metricService.createAutoGauge(
Metric.SLOT.toString(),
MetricLevel.NORMAL,
- storageGroupPartitionTable,
- StorageGroupPartitionTable::getSchemaPartitionMapSize,
+ databasePartitionTable,
+ DatabasePartitionTable::getSchemaPartitionMapSize,
Tag.NAME.toString(),
- storageGroupPartitionTable.getStorageGroupName(),
+ databasePartitionTable.getDatabaseName(),
Tag.TYPE.toString(),
"schemaSlotNumber");
metricService.createAutoGauge(
Metric.SLOT.toString(),
MetricLevel.NORMAL,
- storageGroupPartitionTable,
- StorageGroupPartitionTable::getDataPartitionMapSize,
+ databasePartitionTable,
+ DatabasePartitionTable::getDataPartitionMapSize,
Tag.NAME.toString(),
- storageGroupPartitionTable.getStorageGroupName(),
+ databasePartitionTable.getDatabaseName(),
Tag.TYPE.toString(),
"dataSlotNumber");
}
@@ -155,14 +154,14 @@ public class PartitionInfoMetrics implements IMetricSet {
MetricType.AUTO_GAUGE,
Metric.REGION.toString(),
Tag.NAME.toString(),
- storageGroupPartitionTable.getStorageGroupName(),
+ databasePartitionTable.getDatabaseName(),
Tag.TYPE.toString(),
TConsensusGroupType.SchemaRegion.toString());
metricService.remove(
MetricType.AUTO_GAUGE,
Metric.REGION.toString(),
Tag.NAME.toString(),
- storageGroupPartitionTable.getStorageGroupName(),
+ databasePartitionTable.getDatabaseName(),
Tag.TYPE.toString(),
TConsensusGroupType.DataRegion.toString());
// TODO slot will be updated in the future
@@ -170,14 +169,14 @@ public class PartitionInfoMetrics implements IMetricSet {
MetricType.AUTO_GAUGE,
Metric.SLOT.toString(),
Tag.NAME.toString(),
- storageGroupPartitionTable.getStorageGroupName(),
+ databasePartitionTable.getDatabaseName(),
Tag.TYPE.toString(),
"schemaSlotNumber");
metricService.remove(
MetricType.AUTO_GAUGE,
Metric.SLOT.toString(),
Tag.NAME.toString(),
- storageGroupPartitionTable.getStorageGroupName(),
+ databasePartitionTable.getDatabaseName(),
Tag.TYPE.toString(),
"dataSlotNumber");
}
@@ -187,12 +186,12 @@ public class PartitionInfoMetrics implements IMetricSet {
if (this == o) return true;
if (o == null || getClass() != o.getClass()) return false;
StorageGroupPartitionTableMetrics that = (StorageGroupPartitionTableMetrics) o;
- return Objects.equals(storageGroupPartitionTable, that.storageGroupPartitionTable);
+ return Objects.equals(databasePartitionTable, that.databasePartitionTable);
}
@Override
public int hashCode() {
- return Objects.hash(storageGroupPartitionTable);
+ return Objects.hash(databasePartitionTable);
}
}
}
diff --git a/confignode/src/main/java/org/apache/iotdb/confignode/persistence/node/NodeInfo.java b/confignode/src/main/java/org/apache/iotdb/confignode/persistence/node/NodeInfo.java
index 67790476ff..9183869042 100644
--- a/confignode/src/main/java/org/apache/iotdb/confignode/persistence/node/NodeInfo.java
+++ b/confignode/src/main/java/org/apache/iotdb/confignode/persistence/node/NodeInfo.java
@@ -30,7 +30,7 @@ import org.apache.iotdb.confignode.consensus.request.write.confignode.RemoveConf
import org.apache.iotdb.confignode.consensus.request.write.datanode.RegisterDataNodePlan;
import org.apache.iotdb.confignode.consensus.request.write.datanode.RemoveDataNodePlan;
import org.apache.iotdb.confignode.consensus.request.write.datanode.UpdateDataNodePlan;
-import org.apache.iotdb.confignode.consensus.response.DataNodeConfigurationResp;
+import org.apache.iotdb.confignode.consensus.response.datanode.DataNodeConfigurationResp;
import org.apache.iotdb.rpc.TSStatusCode;
import org.apache.iotdb.tsfile.utils.ReadWriteIOUtils;
diff --git a/confignode/src/main/java/org/apache/iotdb/confignode/persistence/partition/StorageGroupPartitionTable.java b/confignode/src/main/java/org/apache/iotdb/confignode/persistence/partition/DatabasePartitionTable.java
similarity index 95%
rename from confignode/src/main/java/org/apache/iotdb/confignode/persistence/partition/StorageGroupPartitionTable.java
rename to confignode/src/main/java/org/apache/iotdb/confignode/persistence/partition/DatabasePartitionTable.java
index 1f341b0005..18cccef2b7 100644
--- a/confignode/src/main/java/org/apache/iotdb/confignode/persistence/partition/StorageGroupPartitionTable.java
+++ b/confignode/src/main/java/org/apache/iotdb/confignode/persistence/partition/DatabasePartitionTable.java
@@ -55,12 +55,12 @@ import java.util.concurrent.atomic.AtomicLong;
import java.util.stream.Collectors;
import java.util.stream.Stream;
-public class StorageGroupPartitionTable {
- private static final Logger LOGGER = LoggerFactory.getLogger(StorageGroupPartitionTable.class);
+public class DatabasePartitionTable {
+ private static final Logger LOGGER = LoggerFactory.getLogger(DatabasePartitionTable.class);
private volatile boolean isPredeleted = false;
// The name of database
- private String storageGroupName;
+ private String databaseName;
// RegionGroup
private final Map<TConsensusGroupId, RegionGroup> regionGroupMap;
@@ -69,8 +69,8 @@ public class StorageGroupPartitionTable {
// DataPartition
private final DataPartitionTable dataPartitionTable;
- public StorageGroupPartitionTable(String storageGroupName) {
- this.storageGroupName = storageGroupName;
+ public DatabasePartitionTable(String databaseName) {
+ this.databaseName = databaseName;
this.regionGroupMap = new ConcurrentHashMap<>();
@@ -341,7 +341,7 @@ public class StorageGroupPartitionTable {
(dataNodeLocation) -> {
TRegionInfo regionInfo = new TRegionInfo();
regionInfo.setConsensusGroupId(regionId);
- regionInfo.setStorageGroup(storageGroupName);
+ regionInfo.setDatabase(databaseName);
regionInfo.setSeriesSlots(regionGroup.getSeriesSlotCount());
regionInfo.setTimeSlots(regionGroup.getTimeSlotCount());
regionInfo.setDataNodeId(dataNodeLocation.getDataNodeId());
@@ -356,7 +356,7 @@ public class StorageGroupPartitionTable {
public void serialize(OutputStream outputStream, TProtocol protocol)
throws IOException, TException {
ReadWriteIOUtils.write(isPredeleted, outputStream);
- ReadWriteIOUtils.write(storageGroupName, outputStream);
+ ReadWriteIOUtils.write(databaseName, outputStream);
ReadWriteIOUtils.write(regionGroupMap.size(), outputStream);
for (Map.Entry<TConsensusGroupId, RegionGroup> regionInfoEntry : regionGroupMap.entrySet()) {
@@ -371,7 +371,7 @@ public class StorageGroupPartitionTable {
public void deserialize(InputStream inputStream, TProtocol protocol)
throws IOException, TException {
isPredeleted = ReadWriteIOUtils.readBool(inputStream);
- storageGroupName = ReadWriteIOUtils.readString(inputStream);
+ databaseName = ReadWriteIOUtils.readString(inputStream);
int length = ReadWriteIOUtils.readInt(inputStream);
for (int i = 0; i < length; i++) {
@@ -437,13 +437,13 @@ public class StorageGroupPartitionTable {
LOGGER.warn(
"Cannot find RegionGroup for region {} when addRegionNewLocation in {}",
regionId,
- storageGroupName);
+ databaseName);
return;
}
if (regionGroup.getReplicaSet().getDataNodeLocations().contains(node)) {
LOGGER.info(
"Node is already in region locations when addRegionNewLocation in {}, node: {}, region: {}",
- storageGroupName,
+ databaseName,
node,
regionId);
return;
@@ -457,13 +457,13 @@ public class StorageGroupPartitionTable {
LOGGER.warn(
"Cannot find RegionGroup for region {} when removeRegionOldLocation in {}",
regionId,
- storageGroupName);
+ databaseName);
return;
}
if (!regionGroup.getReplicaSet().getDataNodeLocations().contains(node)) {
LOGGER.info(
"Node is not in region locations when removeRegionOldLocation in {}, no need to remove it, node: {}, region: {}",
- storageGroupName,
+ databaseName,
node,
regionId);
return;
@@ -481,8 +481,8 @@ public class StorageGroupPartitionTable {
return regionGroupMap.containsKey(regionId);
}
- public String getStorageGroupName() {
- return storageGroupName;
+ public String getDatabaseName() {
+ return databaseName;
}
public int getDataPartitionMapSize() {
@@ -497,8 +497,8 @@ public class StorageGroupPartitionTable {
public boolean equals(Object o) {
if (this == o) return true;
if (o == null || getClass() != o.getClass()) return false;
- StorageGroupPartitionTable that = (StorageGroupPartitionTable) o;
- return storageGroupName.equals(that.storageGroupName)
+ DatabasePartitionTable that = (DatabasePartitionTable) o;
+ return databaseName.equals(that.databaseName)
&& regionGroupMap.equals(that.regionGroupMap)
&& schemaPartitionTable.equals(that.schemaPartitionTable)
&& dataPartitionTable.equals(that.dataPartitionTable);
@@ -506,6 +506,6 @@ public class StorageGroupPartitionTable {
@Override
public int hashCode() {
- return Objects.hash(storageGroupName, regionGroupMap, schemaPartitionTable, dataPartitionTable);
+ return Objects.hash(databaseName, regionGroupMap, schemaPartitionTable, dataPartitionTable);
}
}
diff --git a/confignode/src/main/java/org/apache/iotdb/confignode/persistence/partition/PartitionInfo.java b/confignode/src/main/java/org/apache/iotdb/confignode/persistence/partition/PartitionInfo.java
index 2043b6c087..38849fc6af 100644
--- a/confignode/src/main/java/org/apache/iotdb/confignode/persistence/partition/PartitionInfo.java
+++ b/confignode/src/main/java/org/apache/iotdb/confignode/persistence/partition/PartitionInfo.java
@@ -44,15 +44,15 @@ import org.apache.iotdb.confignode.consensus.request.write.partition.UpdateRegio
import org.apache.iotdb.confignode.consensus.request.write.region.CreateRegionGroupsPlan;
import org.apache.iotdb.confignode.consensus.request.write.region.OfferRegionMaintainTasksPlan;
import org.apache.iotdb.confignode.consensus.request.write.storagegroup.DatabaseSchemaPlan;
-import org.apache.iotdb.confignode.consensus.request.write.storagegroup.DeleteStorageGroupPlan;
-import org.apache.iotdb.confignode.consensus.request.write.storagegroup.PreDeleteStorageGroupPlan;
-import org.apache.iotdb.confignode.consensus.response.DataPartitionResp;
-import org.apache.iotdb.confignode.consensus.response.GetRegionIdResp;
-import org.apache.iotdb.confignode.consensus.response.GetSeriesSlotListResp;
-import org.apache.iotdb.confignode.consensus.response.GetTimeSlotListResp;
-import org.apache.iotdb.confignode.consensus.response.RegionInfoListResp;
-import org.apache.iotdb.confignode.consensus.response.SchemaNodeManagementResp;
-import org.apache.iotdb.confignode.consensus.response.SchemaPartitionResp;
+import org.apache.iotdb.confignode.consensus.request.write.storagegroup.DeleteDatabasePlan;
+import org.apache.iotdb.confignode.consensus.request.write.storagegroup.PreDeleteDatabasePlan;
+import org.apache.iotdb.confignode.consensus.response.partition.DataPartitionResp;
+import org.apache.iotdb.confignode.consensus.response.partition.GetRegionIdResp;
+import org.apache.iotdb.confignode.consensus.response.partition.GetSeriesSlotListResp;
+import org.apache.iotdb.confignode.consensus.response.partition.GetTimeSlotListResp;
+import org.apache.iotdb.confignode.consensus.response.partition.RegionInfoListResp;
+import org.apache.iotdb.confignode.consensus.response.partition.SchemaNodeManagementResp;
+import org.apache.iotdb.confignode.consensus.response.partition.SchemaPartitionResp;
import org.apache.iotdb.confignode.exception.DatabaseNotExistsException;
import org.apache.iotdb.confignode.persistence.metric.PartitionInfoMetrics;
import org.apache.iotdb.confignode.persistence.partition.maintainer.RegionMaintainTask;
@@ -105,7 +105,7 @@ public class PartitionInfo implements SnapshotProcessor {
// For allocating Regions
private final AtomicInteger nextRegionGroupId;
// Map<StorageGroupName, StorageGroupPartitionInfo>
- private final Map<String, StorageGroupPartitionTable> storageGroupPartitionTables;
+ private final Map<String, DatabasePartitionTable> storageGroupPartitionTables;
/** For Region-Maintainer */
// For RegionReplicas' asynchronous management
@@ -136,12 +136,11 @@ public class PartitionInfo implements SnapshotProcessor {
*/
public TSStatus createDatabase(DatabaseSchemaPlan plan) {
String storageGroupName = plan.getSchema().getName();
- StorageGroupPartitionTable storageGroupPartitionTable =
- new StorageGroupPartitionTable(storageGroupName);
- storageGroupPartitionTables.put(storageGroupName, storageGroupPartitionTable);
+ DatabasePartitionTable databasePartitionTable = new DatabasePartitionTable(storageGroupName);
+ storageGroupPartitionTables.put(storageGroupName, databasePartitionTable);
MetricService.getInstance()
.addMetricSet(
- new PartitionInfoMetrics.StorageGroupPartitionTableMetrics(storageGroupPartitionTable));
+ new PartitionInfoMetrics.StorageGroupPartitionTableMetrics(databasePartitionTable));
return new TSStatus(TSStatusCode.SUCCESS_STATUS.getStatusCode());
}
@@ -218,24 +217,23 @@ public class PartitionInfo implements SnapshotProcessor {
/**
* Thread-safely pre-delete the specific StorageGroup
*
- * @param preDeleteStorageGroupPlan PreDeleteStorageGroupPlan
+ * @param preDeleteDatabasePlan PreDeleteStorageGroupPlan
* @return SUCCESS_STATUS
*/
- public TSStatus preDeleteStorageGroup(PreDeleteStorageGroupPlan preDeleteStorageGroupPlan) {
- final PreDeleteStorageGroupPlan.PreDeleteType preDeleteType =
- preDeleteStorageGroupPlan.getPreDeleteType();
- final String storageGroup = preDeleteStorageGroupPlan.getStorageGroup();
- StorageGroupPartitionTable storageGroupPartitionTable =
- storageGroupPartitionTables.get(storageGroup);
- if (storageGroupPartitionTable == null) {
+ public TSStatus preDeleteDatabase(PreDeleteDatabasePlan preDeleteDatabasePlan) {
+ final PreDeleteDatabasePlan.PreDeleteType preDeleteType =
+ preDeleteDatabasePlan.getPreDeleteType();
+ final String storageGroup = preDeleteDatabasePlan.getStorageGroup();
+ DatabasePartitionTable databasePartitionTable = storageGroupPartitionTables.get(storageGroup);
+ if (databasePartitionTable == null) {
return new TSStatus(TSStatusCode.SUCCESS_STATUS.getStatusCode());
}
switch (preDeleteType) {
case EXECUTE:
- storageGroupPartitionTable.setPredeleted(true);
+ databasePartitionTable.setPredeleted(true);
break;
case ROLLBACK:
- storageGroupPartitionTable.setPredeleted(false);
+ databasePartitionTable.setPredeleted(false);
break;
default:
break;
@@ -248,7 +246,7 @@ public class PartitionInfo implements SnapshotProcessor {
*
* @param plan DeleteStorageGroupPlan
*/
- public void deleteStorageGroup(DeleteStorageGroupPlan plan) {
+ public void deleteDatabase(DeleteDatabasePlan plan) {
// Clean the StorageGroupTable cache
storageGroupPartitionTables.remove(plan.getName());
}
@@ -267,11 +265,11 @@ public class PartitionInfo implements SnapshotProcessor {
if (plan.getPartitionSlotsMap().size() == 0) {
// Return all SchemaPartitions when the queried PartitionSlots are empty
storageGroupPartitionTables.forEach(
- (storageGroup, storageGroupPartitionTable) -> {
- if (!storageGroupPartitionTable.isPredeleted()) {
+ (storageGroup, databasePartitionTable) -> {
+ if (!databasePartitionTable.isPredeleted()) {
schemaPartition.put(storageGroup, new SchemaPartitionTable());
- storageGroupPartitionTable.getSchemaPartition(
+ databasePartitionTable.getSchemaPartition(
new ArrayList<>(), schemaPartition.get(storageGroup));
if (schemaPartition.get(storageGroup).getSchemaPartitionMap().isEmpty()) {
@@ -372,9 +370,9 @@ public class PartitionInfo implements SnapshotProcessor {
}
private boolean isStorageGroupExisted(String storageGroup) {
- final StorageGroupPartitionTable storageGroupPartitionTable =
+ final DatabasePartitionTable databasePartitionTable =
storageGroupPartitionTables.get(storageGroup);
- return storageGroupPartitionTable != null && !storageGroupPartitionTable.isPredeleted();
+ return databasePartitionTable != null && !databasePartitionTable.isPredeleted();
}
/**
@@ -453,14 +451,13 @@ public class PartitionInfo implements SnapshotProcessor {
return regionResp;
}
TShowRegionReq showRegionReq = regionsInfoPlan.getShowRegionReq();
- final List<String> storageGroups =
- showRegionReq != null ? showRegionReq.getStorageGroups() : null;
+ final List<String> storageGroups = showRegionReq != null ? showRegionReq.getDatabases() : null;
storageGroupPartitionTables.forEach(
- (storageGroup, storageGroupPartitionTable) -> {
+ (storageGroup, databasePartitionTable) -> {
if (storageGroups != null && !storageGroups.contains(storageGroup)) {
return;
}
- regionInfoList.addAll(storageGroupPartitionTable.getRegionInfoList(regionsInfoPlan));
+ regionInfoList.addAll(databasePartitionTable.getRegionInfoList(regionsInfoPlan));
});
regionInfoList.sort(
(o1, o2) ->
@@ -498,13 +495,11 @@ public class PartitionInfo implements SnapshotProcessor {
* @return database name
*/
public String getRegionStorageGroup(TConsensusGroupId regionId) {
- Optional<StorageGroupPartitionTable> sgPartitionTableOptional =
+ Optional<DatabasePartitionTable> sgPartitionTableOptional =
storageGroupPartitionTables.values().stream()
.filter(s -> s.containRegion(regionId))
.findFirst();
- return sgPartitionTableOptional
- .map(StorageGroupPartitionTable::getStorageGroupName)
- .orElse(null);
+ return sgPartitionTableOptional.map(DatabasePartitionTable::getDatabaseName).orElse(null);
}
// ======================================================
@@ -571,8 +566,7 @@ public class PartitionInfo implements SnapshotProcessor {
storageGroupPartitionTables
.values()
.forEach(
- storageGroupPartitionTable ->
- result.addAll(storageGroupPartitionTable.getAllReplicaSets()));
+ databasePartitionTable -> result.addAll(databasePartitionTable.getAllReplicaSets()));
return result;
}
@@ -587,8 +581,8 @@ public class PartitionInfo implements SnapshotProcessor {
storageGroupPartitionTables
.values()
.forEach(
- storageGroupPartitionTable ->
- result.addAll(storageGroupPartitionTable.getAllReplicaSets(type)));
+ databasePartitionTable ->
+ result.addAll(databasePartitionTable.getAllReplicaSets(type)));
return result;
}
@@ -662,8 +656,7 @@ public class PartitionInfo implements SnapshotProcessor {
*/
public int updateRegionGroupMetric(TConsensusGroupType type) {
Set<RegionGroup> regionGroups = new HashSet<>();
- for (Map.Entry<String, StorageGroupPartitionTable> entry :
- storageGroupPartitionTables.entrySet()) {
+ for (Map.Entry<String, DatabasePartitionTable> entry : storageGroupPartitionTables.entrySet()) {
regionGroups.addAll(entry.getValue().getRegionGroups(type));
}
int result = regionGroups.size();
@@ -725,7 +718,7 @@ public class PartitionInfo implements SnapshotProcessor {
// serialize StorageGroupPartitionTable
ReadWriteIOUtils.write(storageGroupPartitionTables.size(), fileOutputStream);
- for (Map.Entry<String, StorageGroupPartitionTable> storageGroupPartitionTableEntry :
+ for (Map.Entry<String, DatabasePartitionTable> storageGroupPartitionTableEntry :
storageGroupPartitionTables.entrySet()) {
ReadWriteIOUtils.write(storageGroupPartitionTableEntry.getKey(), fileOutputStream);
storageGroupPartitionTableEntry.getValue().serialize(fileOutputStream, protocol);
@@ -781,10 +774,9 @@ public class PartitionInfo implements SnapshotProcessor {
if (storageGroup == null) {
throw new IOException("Failed to load snapshot because get null StorageGroup name");
}
- StorageGroupPartitionTable storageGroupPartitionTable =
- new StorageGroupPartitionTable(storageGroup);
- storageGroupPartitionTable.deserialize(fileInputStream, protocol);
- storageGroupPartitionTables.put(storageGroup, storageGroupPartitionTable);
+ DatabasePartitionTable databasePartitionTable = new DatabasePartitionTable(storageGroup);
+ databasePartitionTable.deserialize(fileInputStream, protocol);
+ storageGroupPartitionTables.put(storageGroup, databasePartitionTable);
}
// restore deletedRegionSet
@@ -801,7 +793,7 @@ public class PartitionInfo implements SnapshotProcessor {
return new GetRegionIdResp(
new TSStatus(TSStatusCode.SUCCESS_STATUS.getStatusCode()), new ArrayList<>());
}
- StorageGroupPartitionTable sgPartitionTable =
+ DatabasePartitionTable sgPartitionTable =
storageGroupPartitionTables.get(plan.getStorageGroup());
return new GetRegionIdResp(
new TSStatus(TSStatusCode.SUCCESS_STATUS.getStatusCode()),
@@ -814,7 +806,7 @@ public class PartitionInfo implements SnapshotProcessor {
return new GetTimeSlotListResp(
new TSStatus(TSStatusCode.SUCCESS_STATUS.getStatusCode()), new ArrayList<>());
}
- StorageGroupPartitionTable sgPartitionTable =
+ DatabasePartitionTable sgPartitionTable =
storageGroupPartitionTables.get(plan.getStorageGroup());
return new GetTimeSlotListResp(
new TSStatus(TSStatusCode.SUCCESS_STATUS.getStatusCode()),
@@ -827,7 +819,7 @@ public class PartitionInfo implements SnapshotProcessor {
return new GetSeriesSlotListResp(
new TSStatus(TSStatusCode.SUCCESS_STATUS.getStatusCode()), new ArrayList<>());
}
- StorageGroupPartitionTable sgPartitionTable =
+ DatabasePartitionTable sgPartitionTable =
storageGroupPartitionTables.get(plan.getStorageGroup());
return new GetSeriesSlotListResp(
new TSStatus(TSStatusCode.SUCCESS_STATUS.getStatusCode()),
diff --git a/confignode/src/main/java/org/apache/iotdb/confignode/persistence/schema/ClusterSchemaInfo.java b/confignode/src/main/java/org/apache/iotdb/confignode/persistence/schema/ClusterSchemaInfo.java
index f6c800093e..ccd4b4f9f4 100644
--- a/confignode/src/main/java/org/apache/iotdb/confignode/persistence/schema/ClusterSchemaInfo.java
+++ b/confignode/src/main/java/org/apache/iotdb/confignode/persistence/schema/ClusterSchemaInfo.java
@@ -27,15 +27,15 @@ import org.apache.iotdb.commons.path.PartialPath;
import org.apache.iotdb.commons.snapshot.SnapshotProcessor;
import org.apache.iotdb.commons.utils.StatusUtils;
import org.apache.iotdb.commons.utils.TestOnly;
-import org.apache.iotdb.confignode.consensus.request.read.storagegroup.CountStorageGroupPlan;
-import org.apache.iotdb.confignode.consensus.request.read.storagegroup.GetStorageGroupPlan;
+import org.apache.iotdb.confignode.consensus.request.read.database.CountDatabasePlan;
+import org.apache.iotdb.confignode.consensus.request.read.database.GetDatabasePlan;
import org.apache.iotdb.confignode.consensus.request.read.template.CheckTemplateSettablePlan;
import org.apache.iotdb.confignode.consensus.request.read.template.GetPathsSetTemplatePlan;
import org.apache.iotdb.confignode.consensus.request.read.template.GetSchemaTemplatePlan;
import org.apache.iotdb.confignode.consensus.request.read.template.GetTemplateSetInfoPlan;
import org.apache.iotdb.confignode.consensus.request.write.storagegroup.AdjustMaxRegionGroupNumPlan;
import org.apache.iotdb.confignode.consensus.request.write.storagegroup.DatabaseSchemaPlan;
-import org.apache.iotdb.confignode.consensus.request.write.storagegroup.DeleteStorageGroupPlan;
+import org.apache.iotdb.confignode.consensus.request.write.storagegroup.DeleteDatabasePlan;
import org.apache.iotdb.confignode.consensus.request.write.storagegroup.SetDataReplicationFactorPlan;
import org.apache.iotdb.confignode.consensus.request.write.storagegroup.SetSchemaReplicationFactorPlan;
import org.apache.iotdb.confignode.consensus.request.write.storagegroup.SetTTLPlan;
@@ -46,12 +46,12 @@ import org.apache.iotdb.confignode.consensus.request.write.template.PreUnsetSche
import org.apache.iotdb.confignode.consensus.request.write.template.RollbackPreUnsetSchemaTemplatePlan;
import org.apache.iotdb.confignode.consensus.request.write.template.SetSchemaTemplatePlan;
import org.apache.iotdb.confignode.consensus.request.write.template.UnsetSchemaTemplatePlan;
-import org.apache.iotdb.confignode.consensus.response.AllTemplateSetInfoResp;
-import org.apache.iotdb.confignode.consensus.response.CountStorageGroupResp;
-import org.apache.iotdb.confignode.consensus.response.PathInfoResp;
-import org.apache.iotdb.confignode.consensus.response.StorageGroupSchemaResp;
-import org.apache.iotdb.confignode.consensus.response.TemplateInfoResp;
-import org.apache.iotdb.confignode.consensus.response.TemplateSetInfoResp;
+import org.apache.iotdb.confignode.consensus.response.database.CountDatabaseResp;
+import org.apache.iotdb.confignode.consensus.response.database.DatabaseSchemaResp;
+import org.apache.iotdb.confignode.consensus.response.partition.PathInfoResp;
+import org.apache.iotdb.confignode.consensus.response.template.AllTemplateSetInfoResp;
+import org.apache.iotdb.confignode.consensus.response.template.TemplateInfoResp;
+import org.apache.iotdb.confignode.consensus.response.template.TemplateSetInfoResp;
import org.apache.iotdb.confignode.exception.DatabaseNotExistsException;
import org.apache.iotdb.confignode.rpc.thrift.TDatabaseSchema;
import org.apache.iotdb.db.metadata.mtree.ConfigMTree;
@@ -213,7 +213,7 @@ public class ClusterSchemaInfo implements SnapshotProcessor {
* @param plan DeleteStorageGroupPlan
* @return SUCCESS_STATUS
*/
- public TSStatus deleteStorageGroup(DeleteStorageGroupPlan plan) {
+ public TSStatus deleteDatabase(DeleteDatabasePlan plan) {
TSStatus result = new TSStatus();
storageGroupReadWriteLock.writeLock().lock();
try {
@@ -235,8 +235,8 @@ public class ClusterSchemaInfo implements SnapshotProcessor {
}
/** @return The number of matched StorageGroups by the specific StorageGroup pattern */
- public CountStorageGroupResp countMatchedStorageGroups(CountStorageGroupPlan plan) {
- CountStorageGroupResp result = new CountStorageGroupResp();
+ public CountDatabaseResp countMatchedDatabases(CountDatabasePlan plan) {
+ CountDatabaseResp result = new CountDatabaseResp();
storageGroupReadWriteLock.readLock().lock();
try {
PartialPath patternPath = new PartialPath(plan.getStorageGroupPattern());
@@ -254,8 +254,8 @@ public class ClusterSchemaInfo implements SnapshotProcessor {
}
/** @return All StorageGroupSchemas that matches to the specific StorageGroup pattern */
- public StorageGroupSchemaResp getMatchedStorageGroupSchemas(GetStorageGroupPlan plan) {
- StorageGroupSchemaResp result = new StorageGroupSchemaResp();
+ public DatabaseSchemaResp getMatchedDatabaseSchemas(GetDatabasePlan plan) {
+ DatabaseSchemaResp result = new DatabaseSchemaResp();
storageGroupReadWriteLock.readLock().lock();
try {
Map<String, TDatabaseSchema> schemaMap = new HashMap<>();
diff --git a/confignode/src/main/java/org/apache/iotdb/confignode/persistence/sync/ClusterSyncInfo.java b/confignode/src/main/java/org/apache/iotdb/confignode/persistence/sync/ClusterSyncInfo.java
index beb0e0e18f..43ecde07c1 100644
--- a/confignode/src/main/java/org/apache/iotdb/confignode/persistence/sync/ClusterSyncInfo.java
+++ b/confignode/src/main/java/org/apache/iotdb/confignode/persistence/sync/ClusterSyncInfo.java
@@ -34,8 +34,8 @@ import org.apache.iotdb.confignode.consensus.request.write.sync.PreCreatePipePla
import org.apache.iotdb.confignode.consensus.request.write.sync.RecordPipeMessagePlan;
import org.apache.iotdb.confignode.consensus.request.write.sync.SetPipeStatusPlan;
import org.apache.iotdb.confignode.consensus.request.write.sync.ShowPipePlan;
-import org.apache.iotdb.confignode.consensus.response.PipeResp;
-import org.apache.iotdb.confignode.consensus.response.PipeSinkResp;
+import org.apache.iotdb.confignode.consensus.response.pipe.PipeResp;
+import org.apache.iotdb.confignode.consensus.response.pipe.PipeSinkResp;
import org.apache.iotdb.db.utils.sync.SyncPipeUtil;
import org.apache.iotdb.rpc.RpcUtils;
import org.apache.iotdb.rpc.TSStatusCode;
diff --git a/confignode/src/main/java/org/apache/iotdb/confignode/procedure/env/ConfigNodeProcedureEnv.java b/confignode/src/main/java/org/apache/iotdb/confignode/procedure/env/ConfigNodeProcedureEnv.java
index 642c4ac669..e01bb7ebf5 100644
--- a/confignode/src/main/java/org/apache/iotdb/confignode/procedure/env/ConfigNodeProcedureEnv.java
+++ b/confignode/src/main/java/org/apache/iotdb/confignode/procedure/env/ConfigNodeProcedureEnv.java
@@ -38,8 +38,8 @@ import org.apache.iotdb.confignode.client.sync.SyncDataNodeClientPool;
import org.apache.iotdb.confignode.conf.ConfigNodeDescriptor;
import org.apache.iotdb.confignode.consensus.request.write.confignode.RemoveConfigNodePlan;
import org.apache.iotdb.confignode.consensus.request.write.region.CreateRegionGroupsPlan;
-import org.apache.iotdb.confignode.consensus.request.write.storagegroup.DeleteStorageGroupPlan;
-import org.apache.iotdb.confignode.consensus.request.write.storagegroup.PreDeleteStorageGroupPlan;
+import org.apache.iotdb.confignode.consensus.request.write.storagegroup.DeleteDatabasePlan;
+import org.apache.iotdb.confignode.consensus.request.write.storagegroup.PreDeleteDatabasePlan;
import org.apache.iotdb.confignode.exception.AddConsensusGroupException;
import org.apache.iotdb.confignode.exception.AddPeerException;
import org.apache.iotdb.confignode.exception.DatabaseNotExistsException;
@@ -122,8 +122,8 @@ public class ConfigNodeProcedureEnv {
* @return tsStatus
*/
public TSStatus deleteConfig(String name) {
- DeleteStorageGroupPlan deleteStorageGroupPlan = new DeleteStorageGroupPlan(name);
- return getClusterSchemaManager().deleteStorageGroup(deleteStorageGroupPlan);
+ DeleteDatabasePlan deleteDatabasePlan = new DeleteDatabasePlan(name);
+ return getClusterSchemaManager().deleteStorageGroup(deleteDatabasePlan);
}
/**
@@ -132,8 +132,7 @@ public class ConfigNodeProcedureEnv {
* @param preDeleteType execute/rollback
* @param deleteSgName database name
*/
- public void preDelete(
- PreDeleteStorageGroupPlan.PreDeleteType preDeleteType, String deleteSgName) {
+ public void preDelete(PreDeleteDatabasePlan.PreDeleteType preDeleteType, String deleteSgName) {
getPartitionManager().preDeleteStorageGroup(deleteSgName, preDeleteType);
}
diff --git a/confignode/src/main/java/org/apache/iotdb/confignode/procedure/env/DataNodeRemoveHandler.java b/confignode/src/main/java/org/apache/iotdb/confignode/procedure/env/DataNodeRemoveHandler.java
index c33a261751..d424a1eff9 100644
--- a/confignode/src/main/java/org/apache/iotdb/confignode/procedure/env/DataNodeRemoveHandler.java
+++ b/confignode/src/main/java/org/apache/iotdb/confignode/procedure/env/DataNodeRemoveHandler.java
@@ -31,7 +31,7 @@ import org.apache.iotdb.confignode.conf.ConfigNodeConfig;
import org.apache.iotdb.confignode.conf.ConfigNodeDescriptor;
import org.apache.iotdb.confignode.consensus.request.write.datanode.RemoveDataNodePlan;
import org.apache.iotdb.confignode.consensus.request.write.partition.UpdateRegionLocationPlan;
-import org.apache.iotdb.confignode.consensus.response.DataNodeToStatusResp;
+import org.apache.iotdb.confignode.consensus.response.datanode.DataNodeToStatusResp;
import org.apache.iotdb.confignode.manager.ConfigManager;
import org.apache.iotdb.confignode.manager.node.heartbeat.BaseNodeCache;
import org.apache.iotdb.confignode.persistence.node.NodeInfo;
diff --git a/confignode/src/main/java/org/apache/iotdb/confignode/procedure/impl/schema/DeleteStorageGroupProcedure.java b/confignode/src/main/java/org/apache/iotdb/confignode/procedure/impl/schema/DeleteStorageGroupProcedure.java
index 0e3d95f657..89ecff9aa2 100644
--- a/confignode/src/main/java/org/apache/iotdb/confignode/procedure/impl/schema/DeleteStorageGroupProcedure.java
+++ b/confignode/src/main/java/org/apache/iotdb/confignode/procedure/impl/schema/DeleteStorageGroupProcedure.java
@@ -24,7 +24,7 @@ import org.apache.iotdb.common.rpc.thrift.TSStatus;
import org.apache.iotdb.commons.exception.runtime.ThriftSerDeException;
import org.apache.iotdb.commons.utils.ThriftConfigNodeSerDeUtils;
import org.apache.iotdb.confignode.consensus.request.write.region.OfferRegionMaintainTasksPlan;
-import org.apache.iotdb.confignode.consensus.request.write.storagegroup.PreDeleteStorageGroupPlan;
+import org.apache.iotdb.confignode.consensus.request.write.storagegroup.PreDeleteDatabasePlan;
import org.apache.iotdb.confignode.persistence.partition.maintainer.RegionDeleteTask;
import org.apache.iotdb.confignode.procedure.env.ConfigNodeProcedureEnv;
import org.apache.iotdb.confignode.procedure.exception.ProcedureException;
@@ -83,7 +83,7 @@ public class DeleteStorageGroupProcedure
break;
case DELETE_PRE:
LOG.info("Pre delete for database {}", deleteSgSchema.getName());
- env.preDelete(PreDeleteStorageGroupPlan.PreDeleteType.EXECUTE, deleteSgSchema.getName());
+ env.preDelete(PreDeleteDatabasePlan.PreDeleteType.EXECUTE, deleteSgSchema.getName());
setNextState(DeleteStorageGroupState.INVALIDATE_CACHE);
break;
case INVALIDATE_CACHE:
@@ -156,7 +156,7 @@ public class DeleteStorageGroupProcedure
case DELETE_PRE:
case INVALIDATE_CACHE:
LOG.info("Rollback preDeleted:{}", deleteSgSchema.getName());
- env.preDelete(PreDeleteStorageGroupPlan.PreDeleteType.ROLLBACK, deleteSgSchema.getName());
+ env.preDelete(PreDeleteDatabasePlan.PreDeleteType.ROLLBACK, deleteSgSchema.getName());
break;
default:
break;
diff --git a/confignode/src/main/java/org/apache/iotdb/confignode/service/thrift/ConfigNodeRPCServiceProcessor.java b/confignode/src/main/java/org/apache/iotdb/confignode/service/thrift/ConfigNodeRPCServiceProcessor.java
index 1852240af9..29798f63df 100644
--- a/confignode/src/main/java/org/apache/iotdb/confignode/service/thrift/ConfigNodeRPCServiceProcessor.java
+++ b/confignode/src/main/java/org/apache/iotdb/confignode/service/thrift/ConfigNodeRPCServiceProcessor.java
@@ -36,14 +36,14 @@ import org.apache.iotdb.confignode.conf.ConfigNodeDescriptor;
import org.apache.iotdb.confignode.conf.SystemPropertiesUtils;
import org.apache.iotdb.confignode.consensus.request.ConfigPhysicalPlanType;
import org.apache.iotdb.confignode.consensus.request.auth.AuthorPlan;
+import org.apache.iotdb.confignode.consensus.request.read.database.CountDatabasePlan;
+import org.apache.iotdb.confignode.consensus.request.read.database.GetDatabasePlan;
import org.apache.iotdb.confignode.consensus.request.read.datanode.GetDataNodeConfigurationPlan;
import org.apache.iotdb.confignode.consensus.request.read.partition.GetDataPartitionPlan;
import org.apache.iotdb.confignode.consensus.request.read.partition.GetOrCreateDataPartitionPlan;
import org.apache.iotdb.confignode.consensus.request.read.partition.GetSeriesSlotListPlan;
import org.apache.iotdb.confignode.consensus.request.read.partition.GetTimeSlotListPlan;
import org.apache.iotdb.confignode.consensus.request.read.region.GetRegionInfoListPlan;
-import org.apache.iotdb.confignode.consensus.request.read.storagegroup.CountStorageGroupPlan;
-import org.apache.iotdb.confignode.consensus.request.read.storagegroup.GetStorageGroupPlan;
import org.apache.iotdb.confignode.consensus.request.write.confignode.RemoveConfigNodePlan;
import org.apache.iotdb.confignode.consensus.request.write.datanode.RemoveDataNodePlan;
import org.apache.iotdb.confignode.consensus.request.write.datanode.UpdateDataNodePlan;
@@ -54,14 +54,14 @@ import org.apache.iotdb.confignode.consensus.request.write.storagegroup.SetTTLPl
import org.apache.iotdb.confignode.consensus.request.write.storagegroup.SetTimePartitionIntervalPlan;
import org.apache.iotdb.confignode.consensus.request.write.sync.CreatePipeSinkPlan;
import org.apache.iotdb.confignode.consensus.request.write.sync.DropPipeSinkPlan;
-import org.apache.iotdb.confignode.consensus.response.ConfigurationResp;
-import org.apache.iotdb.confignode.consensus.response.CountStorageGroupResp;
-import org.apache.iotdb.confignode.consensus.response.DataNodeConfigurationResp;
-import org.apache.iotdb.confignode.consensus.response.DataNodeRegisterResp;
-import org.apache.iotdb.confignode.consensus.response.DataNodeToStatusResp;
-import org.apache.iotdb.confignode.consensus.response.PermissionInfoResp;
-import org.apache.iotdb.confignode.consensus.response.RegionInfoListResp;
-import org.apache.iotdb.confignode.consensus.response.StorageGroupSchemaResp;
+import org.apache.iotdb.confignode.consensus.response.auth.PermissionInfoResp;
+import org.apache.iotdb.confignode.consensus.response.database.CountDatabaseResp;
+import org.apache.iotdb.confignode.consensus.response.database.DatabaseSchemaResp;
+import org.apache.iotdb.confignode.consensus.response.datanode.ConfigurationResp;
+import org.apache.iotdb.confignode.consensus.response.datanode.DataNodeConfigurationResp;
+import org.apache.iotdb.confignode.consensus.response.datanode.DataNodeRegisterResp;
+import org.apache.iotdb.confignode.consensus.response.datanode.DataNodeToStatusResp;
+import org.apache.iotdb.confignode.consensus.response.partition.RegionInfoListResp;
import org.apache.iotdb.confignode.manager.ConfigManager;
import org.apache.iotdb.confignode.manager.ConsensusManager;
import org.apache.iotdb.confignode.rpc.thrift.IConfigNodeRPCService;
@@ -72,7 +72,7 @@ import org.apache.iotdb.confignode.rpc.thrift.TCheckUserPrivilegesReq;
import org.apache.iotdb.confignode.rpc.thrift.TConfigNodeRegisterReq;
import org.apache.iotdb.confignode.rpc.thrift.TConfigNodeRegisterResp;
import org.apache.iotdb.confignode.rpc.thrift.TConfigNodeRestartReq;
-import org.apache.iotdb.confignode.rpc.thrift.TCountStorageGroupResp;
+import org.apache.iotdb.confignode.rpc.thrift.TCountDatabaseResp;
import org.apache.iotdb.confignode.rpc.thrift.TCreateCQReq;
import org.apache.iotdb.confignode.rpc.thrift.TCreateFunctionReq;
import org.apache.iotdb.confignode.rpc.thrift.TCreateModelReq;
@@ -92,8 +92,8 @@ import org.apache.iotdb.confignode.rpc.thrift.TDataPartitionTableResp;
import org.apache.iotdb.confignode.rpc.thrift.TDatabaseSchema;
import org.apache.iotdb.confignode.rpc.thrift.TDatabaseSchemaResp;
import org.apache.iotdb.confignode.rpc.thrift.TDeactivateSchemaTemplateReq;
-import org.apache.iotdb.confignode.rpc.thrift.TDeleteStorageGroupReq;
-import org.apache.iotdb.confignode.rpc.thrift.TDeleteStorageGroupsReq;
+import org.apache.iotdb.confignode.rpc.thrift.TDeleteDatabaseReq;
+import org.apache.iotdb.confignode.rpc.thrift.TDeleteDatabasesReq;
import org.apache.iotdb.confignode.rpc.thrift.TDeleteTimeSeriesReq;
import org.apache.iotdb.confignode.rpc.thrift.TDropCQReq;
import org.apache.iotdb.confignode.rpc.thrift.TDropFunctionReq;
@@ -345,7 +345,7 @@ public class ConfigNodeRPCServiceProcessor implements IConfigNodeRPCService.Ifac
new DatabaseSchemaPlan(ConfigPhysicalPlanType.CreateDatabase, databaseSchema);
TSStatus resp = configManager.setDatabase(setPlan);
- // Print log to record the ConfigNode that performs the set SetStorageGroupRequest
+ // Print log to record the ConfigNode that performs the set SetDatabaseRequest
LOGGER.info("Execute SetDatabase: {} with result: {}", databaseSchema, resp);
return resp;
@@ -389,20 +389,20 @@ public class ConfigNodeRPCServiceProcessor implements IConfigNodeRPCService.Ifac
new DatabaseSchemaPlan(ConfigPhysicalPlanType.AlterDatabase, databaseSchema);
TSStatus resp = configManager.alterDatabase(alterPlan);
- // Print log to record the ConfigNode that performs the set SetStorageGroupRequest
+ // Print log to record the ConfigNode that performs the set SetDatabaseRequest
LOGGER.info("Execute AlterDatabase: {} with result: {}", databaseSchema, resp);
return resp;
}
@Override
- public TSStatus deleteStorageGroup(TDeleteStorageGroupReq tDeleteReq) {
+ public TSStatus deleteDatabase(TDeleteDatabaseReq tDeleteReq) {
String prefixPath = tDeleteReq.getPrefixPath();
return configManager.deleteStorageGroups(Collections.singletonList(prefixPath));
}
@Override
- public TSStatus deleteStorageGroups(TDeleteStorageGroupsReq tDeleteReq) {
+ public TSStatus deleteDatabases(TDeleteDatabasesReq tDeleteReq) {
List<String> prefixList = tDeleteReq.getPrefixPathList();
return configManager.deleteStorageGroups(prefixList);
}
@@ -415,42 +415,40 @@ public class ConfigNodeRPCServiceProcessor implements IConfigNodeRPCService.Ifac
@Override
public TSStatus setSchemaReplicationFactor(TSetSchemaReplicationFactorReq req) throws TException {
return configManager.setSchemaReplicationFactor(
- new SetSchemaReplicationFactorPlan(
- req.getStorageGroup(), req.getSchemaReplicationFactor()));
+ new SetSchemaReplicationFactorPlan(req.getDatabase(), req.getSchemaReplicationFactor()));
}
@Override
public TSStatus setDataReplicationFactor(TSetDataReplicationFactorReq req) throws TException {
return configManager.setDataReplicationFactor(
- new SetDataReplicationFactorPlan(req.getStorageGroup(), req.getDataReplicationFactor()));
+ new SetDataReplicationFactorPlan(req.getDatabase(), req.getDataReplicationFactor()));
}
@Override
public TSStatus setTimePartitionInterval(TSetTimePartitionIntervalReq req) throws TException {
return configManager.setTimePartitionInterval(
- new SetTimePartitionIntervalPlan(req.getStorageGroup(), req.getTimePartitionInterval()));
+ new SetTimePartitionIntervalPlan(req.getDatabase(), req.getTimePartitionInterval()));
}
@Override
- public TCountStorageGroupResp countMatchedStorageGroups(List<String> storageGroupPathPattern) {
- CountStorageGroupResp countStorageGroupResp =
- (CountStorageGroupResp)
- configManager.countMatchedStorageGroups(
- new CountStorageGroupPlan(storageGroupPathPattern));
+ public TCountDatabaseResp countMatchedDatabases(List<String> storageGroupPathPattern) {
+ CountDatabaseResp countDatabaseResp =
+ (CountDatabaseResp)
+ configManager.countMatchedStorageGroups(new CountDatabasePlan(storageGroupPathPattern));
- TCountStorageGroupResp resp = new TCountStorageGroupResp();
- countStorageGroupResp.convertToRPCCountStorageGroupResp(resp);
+ TCountDatabaseResp resp = new TCountDatabaseResp();
+ countDatabaseResp.convertToRPCCountStorageGroupResp(resp);
return resp;
}
@Override
- public TDatabaseSchemaResp getMatchedStorageGroupSchemas(List<String> storageGroupPathPattern) {
- StorageGroupSchemaResp storageGroupSchemaResp =
- (StorageGroupSchemaResp)
+ public TDatabaseSchemaResp getMatchedDatabaseSchemas(List<String> storageGroupPathPattern) {
+ DatabaseSchemaResp databaseSchemaResp =
+ (DatabaseSchemaResp)
configManager.getMatchedStorageGroupSchemas(
- new GetStorageGroupPlan(storageGroupPathPattern));
+ new GetDatabasePlan(storageGroupPathPattern));
- return storageGroupSchemaResp.convertToRPCStorageGroupSchemaResp();
+ return databaseSchemaResp.convertToRPCStorageGroupSchemaResp();
}
@Override
@@ -774,8 +772,8 @@ public class ConfigNodeRPCServiceProcessor implements IConfigNodeRPCService.Ifac
}
@Override
- public TShowDatabaseResp showStorageGroup(List<String> storageGroupPathPattern) {
- return configManager.showStorageGroup(new GetStorageGroupPlan(storageGroupPathPattern));
+ public TShowDatabaseResp showDatabase(List<String> storageGroupPathPattern) {
+ return configManager.showStorageGroup(new GetDatabasePlan(storageGroupPathPattern));
}
@Override
@@ -809,12 +807,12 @@ public class ConfigNodeRPCServiceProcessor implements IConfigNodeRPCService.Ifac
}
@Override
- public TSStatus unsetSchemaTemplate(TUnsetSchemaTemplateReq req) throws TException {
+ public TSStatus unsetSchemaTemplate(TUnsetSchemaTemplateReq req) {
return configManager.unsetSchemaTemplate(req);
}
@Override
- public TSStatus dropSchemaTemplate(String req) throws TException {
+ public TSStatus dropSchemaTemplate(String req) {
return configManager.dropSchemaTemplate(req);
}
@@ -886,7 +884,7 @@ public class ConfigNodeRPCServiceProcessor implements IConfigNodeRPCService.Ifac
long startTime = req.isSetStartTime() ? req.getStartTime() : Long.MIN_VALUE;
long endTime = req.isSetEndTime() ? req.getEndTime() : Long.MAX_VALUE;
GetTimeSlotListPlan plan =
- new GetTimeSlotListPlan(req.getStorageGroup(), req.getSeriesSlotId(), startTime, endTime);
+ new GetTimeSlotListPlan(req.getDatabase(), req.getSeriesSlotId(), startTime, endTime);
return configManager.getTimeSlotList(plan);
}
@@ -894,7 +892,7 @@ public class ConfigNodeRPCServiceProcessor implements IConfigNodeRPCService.Ifac
public TGetSeriesSlotListResp getSeriesSlotList(TGetSeriesSlotListReq req) {
TConsensusGroupType type =
req.isSetType() ? req.getType() : TConsensusGroupType.ConfigNodeRegion;
- GetSeriesSlotListPlan plan = new GetSeriesSlotListPlan(req.getStorageGroup(), type);
+ GetSeriesSlotListPlan plan = new GetSeriesSlotListPlan(req.getDatabase(), type);
return configManager.getSeriesSlotList(plan);
}
diff --git a/confignode/src/test/java/org/apache/iotdb/confignode/consensus/request/ConfigPhysicalPlanSerDeTest.java b/confignode/src/test/java/org/apache/iotdb/confignode/consensus/request/ConfigPhysicalPlanSerDeTest.java
index 82b7a13d9d..7fd105a297 100644
--- a/confignode/src/test/java/org/apache/iotdb/confignode/consensus/request/ConfigPhysicalPlanSerDeTest.java
+++ b/confignode/src/test/java/org/apache/iotdb/confignode/consensus/request/ConfigPhysicalPlanSerDeTest.java
@@ -40,6 +40,8 @@ import org.apache.iotdb.commons.sync.pipe.PipeStatus;
import org.apache.iotdb.commons.sync.pipe.TsFilePipeInfo;
import org.apache.iotdb.commons.trigger.TriggerInformation;
import org.apache.iotdb.confignode.consensus.request.auth.AuthorPlan;
+import org.apache.iotdb.confignode.consensus.request.read.database.CountDatabasePlan;
+import org.apache.iotdb.confignode.consensus.request.read.database.GetDatabasePlan;
import org.apache.iotdb.confignode.consensus.request.read.datanode.GetDataNodeConfigurationPlan;
import org.apache.iotdb.confignode.consensus.request.read.function.GetFunctionTablePlan;
import org.apache.iotdb.confignode.consensus.request.read.partition.GetDataPartitionPlan;
@@ -51,8 +53,6 @@ import org.apache.iotdb.confignode.consensus.request.read.partition.GetSeriesSlo
import org.apache.iotdb.confignode.consensus.request.read.partition.GetTimeSlotListPlan;
import org.apache.iotdb.confignode.consensus.request.read.region.GetRegionIdPlan;
import org.apache.iotdb.confignode.consensus.request.read.region.GetRegionInfoListPlan;
-import org.apache.iotdb.confignode.consensus.request.read.storagegroup.CountStorageGroupPlan;
-import org.apache.iotdb.confignode.consensus.request.read.storagegroup.GetStorageGroupPlan;
import org.apache.iotdb.confignode.consensus.request.read.template.GetAllSchemaTemplatePlan;
import org.apache.iotdb.confignode.consensus.request.read.template.GetAllTemplateSetInfoPlan;
import org.apache.iotdb.confignode.consensus.request.read.template.GetPathsSetTemplatePlan;
@@ -81,7 +81,7 @@ import org.apache.iotdb.confignode.consensus.request.write.region.OfferRegionMai
import org.apache.iotdb.confignode.consensus.request.write.region.PollRegionMaintainTaskPlan;
import org.apache.iotdb.confignode.consensus.request.write.storagegroup.AdjustMaxRegionGroupNumPlan;
import org.apache.iotdb.confignode.consensus.request.write.storagegroup.DatabaseSchemaPlan;
-import org.apache.iotdb.confignode.consensus.request.write.storagegroup.DeleteStorageGroupPlan;
+import org.apache.iotdb.confignode.consensus.request.write.storagegroup.DeleteDatabasePlan;
import org.apache.iotdb.confignode.consensus.request.write.storagegroup.SetDataReplicationFactorPlan;
import org.apache.iotdb.confignode.consensus.request.write.storagegroup.SetSchemaReplicationFactorPlan;
import org.apache.iotdb.confignode.consensus.request.write.storagegroup.SetTTLPlan;
@@ -227,9 +227,9 @@ public class ConfigPhysicalPlanSerDeTest {
@Test
public void DeleteStorageGroupPlanTest() throws IOException {
// TODO: Add serialize and deserialize test
- DeleteStorageGroupPlan req0 = new DeleteStorageGroupPlan("root.sg");
- DeleteStorageGroupPlan req1 =
- (DeleteStorageGroupPlan) ConfigPhysicalPlan.Factory.create(req0.serializeToByteBuffer());
+ DeleteDatabasePlan req0 = new DeleteDatabasePlan("root.sg");
+ DeleteDatabasePlan req1 =
+ (DeleteDatabasePlan) ConfigPhysicalPlan.Factory.create(req0.serializeToByteBuffer());
Assert.assertEquals(req0, req1);
}
@@ -282,17 +282,17 @@ public class ConfigPhysicalPlanSerDeTest {
@Test
public void CountStorageGroupPlanTest() throws IOException {
- CountStorageGroupPlan req0 = new CountStorageGroupPlan(Arrays.asList("root", "sg"));
- CountStorageGroupPlan req1 =
- (CountStorageGroupPlan) ConfigPhysicalPlan.Factory.create(req0.serializeToByteBuffer());
+ CountDatabasePlan req0 = new CountDatabasePlan(Arrays.asList("root", "sg"));
+ CountDatabasePlan req1 =
+ (CountDatabasePlan) ConfigPhysicalPlan.Factory.create(req0.serializeToByteBuffer());
Assert.assertEquals(req0, req1);
}
@Test
public void GetStorageGroupPlanTest() throws IOException {
- GetStorageGroupPlan req0 = new GetStorageGroupPlan(Arrays.asList("root", "sg"));
- CountStorageGroupPlan req1 =
- (CountStorageGroupPlan) ConfigPhysicalPlan.Factory.create(req0.serializeToByteBuffer());
+ GetDatabasePlan req0 = new GetDatabasePlan(Arrays.asList("root", "sg"));
+ CountDatabasePlan req1 =
+ (CountDatabasePlan) ConfigPhysicalPlan.Factory.create(req0.serializeToByteBuffer());
Assert.assertEquals(req0, req1);
}
@@ -826,7 +826,7 @@ public class ConfigPhysicalPlanSerDeTest {
Assert.assertEquals(req0.getType(), req1.getType());
Assert.assertEquals(req0.getShowRegionReq(), req1.getShowRegionReq());
final List<String> sgList = Collections.singletonList("root.sg1, root.sg2, root.*");
- showRegionReq.setStorageGroups(new ArrayList<>(sgList));
+ showRegionReq.setDatabases(new ArrayList<>(sgList));
GetRegionInfoListPlan req2 =
(GetRegionInfoListPlan) ConfigPhysicalPlan.Factory.create(req0.serializeToByteBuffer());
Assert.assertEquals(req0.getType(), req1.getType());
diff --git a/confignode/src/test/java/org/apache/iotdb/confignode/persistence/AuthorInfoTest.java b/confignode/src/test/java/org/apache/iotdb/confignode/persistence/AuthorInfoTest.java
index 55346f6ed1..cc0e2888ca 100644
--- a/confignode/src/test/java/org/apache/iotdb/confignode/persistence/AuthorInfoTest.java
+++ b/confignode/src/test/java/org/apache/iotdb/confignode/persistence/AuthorInfoTest.java
@@ -25,7 +25,7 @@ import org.apache.iotdb.commons.auth.entity.PrivilegeType;
import org.apache.iotdb.commons.conf.IoTDBConstant;
import org.apache.iotdb.confignode.consensus.request.ConfigPhysicalPlanType;
import org.apache.iotdb.confignode.consensus.request.auth.AuthorPlan;
-import org.apache.iotdb.confignode.consensus.response.PermissionInfoResp;
+import org.apache.iotdb.confignode.consensus.response.auth.PermissionInfoResp;
import org.apache.iotdb.confignode.rpc.thrift.TCheckUserPrivilegesReq;
import org.apache.iotdb.rpc.TSStatusCode;
diff --git a/confignode/src/test/java/org/apache/iotdb/confignode/persistence/ClusterSchemaInfoTest.java b/confignode/src/test/java/org/apache/iotdb/confignode/persistence/ClusterSchemaInfoTest.java
index 8869d4646b..bbd1673399 100644
--- a/confignode/src/test/java/org/apache/iotdb/confignode/persistence/ClusterSchemaInfoTest.java
+++ b/confignode/src/test/java/org/apache/iotdb/confignode/persistence/ClusterSchemaInfoTest.java
@@ -22,7 +22,7 @@ package org.apache.iotdb.confignode.persistence;
import org.apache.iotdb.commons.exception.IllegalPathException;
import org.apache.iotdb.commons.utils.PathUtils;
import org.apache.iotdb.confignode.consensus.request.ConfigPhysicalPlanType;
-import org.apache.iotdb.confignode.consensus.request.read.storagegroup.GetStorageGroupPlan;
+import org.apache.iotdb.confignode.consensus.request.read.database.GetDatabasePlan;
import org.apache.iotdb.confignode.consensus.request.read.template.GetPathsSetTemplatePlan;
import org.apache.iotdb.confignode.consensus.request.write.storagegroup.DatabaseSchemaPlan;
import org.apache.iotdb.confignode.consensus.request.write.template.CreateSchemaTemplatePlan;
@@ -101,10 +101,10 @@ public class ClusterSchemaInfoTest {
Assert.assertEquals(storageGroupPathList.size(), clusterSchemaInfo.getDatabaseNames().size());
- GetStorageGroupPlan getStorageGroupReq =
- new GetStorageGroupPlan(Arrays.asList(PathUtils.splitPathToDetachedNodes("root.**")));
+ GetDatabasePlan getStorageGroupReq =
+ new GetDatabasePlan(Arrays.asList(PathUtils.splitPathToDetachedNodes("root.**")));
Map<String, TDatabaseSchema> reloadResult =
- clusterSchemaInfo.getMatchedStorageGroupSchemas(getStorageGroupReq).getSchemaMap();
+ clusterSchemaInfo.getMatchedDatabaseSchemas(getStorageGroupReq).getSchemaMap();
Assert.assertEquals(testMap, reloadResult);
}
diff --git a/confignode/src/test/java/org/apache/iotdb/confignode/persistence/PartitionInfoTest.java b/confignode/src/test/java/org/apache/iotdb/confignode/persistence/PartitionInfoTest.java
index 4acc8d8fc8..b0553b1b92 100644
--- a/confignode/src/test/java/org/apache/iotdb/confignode/persistence/PartitionInfoTest.java
+++ b/confignode/src/test/java/org/apache/iotdb/confignode/persistence/PartitionInfoTest.java
@@ -36,7 +36,7 @@ import org.apache.iotdb.confignode.consensus.request.write.partition.CreateSchem
import org.apache.iotdb.confignode.consensus.request.write.region.CreateRegionGroupsPlan;
import org.apache.iotdb.confignode.consensus.request.write.region.OfferRegionMaintainTasksPlan;
import org.apache.iotdb.confignode.consensus.request.write.storagegroup.DatabaseSchemaPlan;
-import org.apache.iotdb.confignode.consensus.response.RegionInfoListResp;
+import org.apache.iotdb.confignode.consensus.response.partition.RegionInfoListResp;
import org.apache.iotdb.confignode.persistence.partition.PartitionInfo;
import org.apache.iotdb.confignode.persistence.partition.maintainer.RegionCreateTask;
import org.apache.iotdb.confignode.persistence.partition.maintainer.RegionDeleteTask;
@@ -214,7 +214,7 @@ public class PartitionInfoTest {
Assert.assertEquals(
regionInfo.getConsensusGroupId().getType(), TConsensusGroupType.DataRegion));
showRegionReq.setConsensusGroupType(null);
- showRegionReq.setStorageGroups(Collections.singletonList("root.test1"));
+ showRegionReq.setDatabases(Collections.singletonList("root.test1"));
RegionInfoListResp regionInfoList4 =
(RegionInfoListResp) partitionInfo.getRegionInfoList(regionReq);
Assert.assertEquals(regionInfoList4.getRegionInfoList().size(), 10);
@@ -223,7 +223,7 @@ public class PartitionInfoTest {
.forEach(
(regionInfo) -> {
Assert.assertEquals(regionInfo.getClientRpcIp(), "127.0.0.1");
- Assert.assertEquals(regionInfo.getStorageGroup(), "root.test1");
+ Assert.assertEquals(regionInfo.getDatabase(), "root.test1");
});
}
diff --git a/integration-test/src/test/java/org/apache/iotdb/confignode/it/database/IoTDBDatabaseSetAndDeleteIT.java b/integration-test/src/test/java/org/apache/iotdb/confignode/it/database/IoTDBDatabaseSetAndDeleteIT.java
index 12b73af4a7..e39a1a1462 100644
--- a/integration-test/src/test/java/org/apache/iotdb/confignode/it/database/IoTDBDatabaseSetAndDeleteIT.java
+++ b/integration-test/src/test/java/org/apache/iotdb/confignode/it/database/IoTDBDatabaseSetAndDeleteIT.java
@@ -23,10 +23,10 @@ import org.apache.iotdb.common.rpc.thrift.TSStatus;
import org.apache.iotdb.common.rpc.thrift.TSetTTLReq;
import org.apache.iotdb.commons.client.sync.SyncConfigNodeIServiceClient;
import org.apache.iotdb.commons.path.PartialPath;
-import org.apache.iotdb.confignode.rpc.thrift.TCountStorageGroupResp;
+import org.apache.iotdb.confignode.rpc.thrift.TCountDatabaseResp;
import org.apache.iotdb.confignode.rpc.thrift.TDatabaseSchema;
import org.apache.iotdb.confignode.rpc.thrift.TDatabaseSchemaResp;
-import org.apache.iotdb.confignode.rpc.thrift.TDeleteStorageGroupsReq;
+import org.apache.iotdb.confignode.rpc.thrift.TDeleteDatabasesReq;
import org.apache.iotdb.confignode.rpc.thrift.TSetDataReplicationFactorReq;
import org.apache.iotdb.confignode.rpc.thrift.TSetSchemaReplicationFactorReq;
import org.apache.iotdb.confignode.rpc.thrift.TSetTimePartitionIntervalReq;
@@ -86,24 +86,22 @@ public class IoTDBDatabaseSetAndDeleteIT {
Assert.assertEquals(TSStatusCode.SUCCESS_STATUS.getStatusCode(), status.getCode());
// test count all Databases
- TCountStorageGroupResp countResp =
- client.countMatchedStorageGroups(Arrays.asList("root", "**"));
+ TCountDatabaseResp countResp = client.countMatchedDatabases(Arrays.asList("root", "**"));
Assert.assertEquals(
TSStatusCode.SUCCESS_STATUS.getStatusCode(), countResp.getStatus().getCode());
Assert.assertEquals(2, countResp.getCount());
// test count one Database
- countResp = client.countMatchedStorageGroups(Arrays.asList("root", "sg0"));
+ countResp = client.countMatchedDatabases(Arrays.asList("root", "sg0"));
Assert.assertEquals(
TSStatusCode.SUCCESS_STATUS.getStatusCode(), countResp.getStatus().getCode());
Assert.assertEquals(1, countResp.getCount());
// test query all DatabaseSchemas
- TDatabaseSchemaResp getResp =
- client.getMatchedStorageGroupSchemas(Arrays.asList("root", "**"));
+ TDatabaseSchemaResp getResp = client.getMatchedDatabaseSchemas(Arrays.asList("root", "**"));
Assert.assertEquals(
TSStatusCode.SUCCESS_STATUS.getStatusCode(), getResp.getStatus().getCode());
- Map<String, TDatabaseSchema> schemaMap = getResp.getStorageGroupSchemaMap();
+ Map<String, TDatabaseSchema> schemaMap = getResp.getDatabaseSchemaMap();
Assert.assertEquals(2, schemaMap.size());
TDatabaseSchema storageGroupSchema = schemaMap.get(sg0);
Assert.assertNotNull(storageGroupSchema);
@@ -136,10 +134,10 @@ public class IoTDBDatabaseSetAndDeleteIT {
Assert.assertEquals(TSStatusCode.SUCCESS_STATUS.getStatusCode(), status.getCode());
// test setter results
- getResp = client.getMatchedStorageGroupSchemas(Arrays.asList("root", "sg1"));
+ getResp = client.getMatchedDatabaseSchemas(Arrays.asList("root", "sg1"));
Assert.assertEquals(
TSStatusCode.SUCCESS_STATUS.getStatusCode(), getResp.getStatus().getCode());
- schemaMap = getResp.getStorageGroupSchemaMap();
+ schemaMap = getResp.getDatabaseSchemaMap();
Assert.assertEquals(1, schemaMap.size());
storageGroupSchema = schemaMap.get(sg1);
Assert.assertNotNull(storageGroupSchema);
@@ -167,12 +165,12 @@ public class IoTDBDatabaseSetAndDeleteIT {
TDatabaseSchema storageGroupSchema1 = new TDatabaseSchema(sg1);
status = client.setDatabase(storageGroupSchema1);
Assert.assertEquals(TSStatusCode.SUCCESS_STATUS.getStatusCode(), status.getCode());
- TDeleteStorageGroupsReq deleteStorageGroupsReq = new TDeleteStorageGroupsReq();
+ TDeleteDatabasesReq deleteStorageGroupsReq = new TDeleteDatabasesReq();
List<String> sgs = Arrays.asList(sg0, sg1);
deleteStorageGroupsReq.setPrefixPathList(sgs);
- TSStatus deleteSgStatus = client.deleteStorageGroups(deleteStorageGroupsReq);
- TDatabaseSchemaResp root = client.getMatchedStorageGroupSchemas(Arrays.asList("root", "*"));
- Assert.assertTrue(root.getStorageGroupSchemaMap().isEmpty());
+ TSStatus deleteSgStatus = client.deleteDatabases(deleteStorageGroupsReq);
+ TDatabaseSchemaResp root = client.getMatchedDatabaseSchemas(Arrays.asList("root", "*"));
+ Assert.assertTrue(root.getDatabaseSchemaMap().isEmpty());
Assert.assertEquals(TSStatusCode.SUCCESS_STATUS.getStatusCode(), deleteSgStatus.getCode());
}
}
diff --git a/integration-test/src/test/java/org/apache/iotdb/confignode/it/partition/IoTDBAutoRegionGroupExtensionIT.java b/integration-test/src/test/java/org/apache/iotdb/confignode/it/partition/IoTDBAutoRegionGroupExtensionIT.java
index 5d72ff2a36..608fdaa68a 100644
--- a/integration-test/src/test/java/org/apache/iotdb/confignode/it/partition/IoTDBAutoRegionGroupExtensionIT.java
+++ b/integration-test/src/test/java/org/apache/iotdb/confignode/it/partition/IoTDBAutoRegionGroupExtensionIT.java
@@ -27,7 +27,7 @@ import org.apache.iotdb.confignode.it.utils.ConfigNodeTestUtils;
import org.apache.iotdb.confignode.rpc.thrift.TDataPartitionReq;
import org.apache.iotdb.confignode.rpc.thrift.TDataPartitionTableResp;
import org.apache.iotdb.confignode.rpc.thrift.TDatabaseSchema;
-import org.apache.iotdb.confignode.rpc.thrift.TDeleteStorageGroupReq;
+import org.apache.iotdb.confignode.rpc.thrift.TDeleteDatabaseReq;
import org.apache.iotdb.confignode.rpc.thrift.TSchemaPartitionReq;
import org.apache.iotdb.confignode.rpc.thrift.TSchemaPartitionTableResp;
import org.apache.iotdb.confignode.rpc.thrift.TShowRegionReq;
@@ -102,7 +102,7 @@ public class IoTDBAutoRegionGroupExtensionIT {
// Delete all StorageGroups
for (int i = 0; i < testSgNum; i++) {
String curSg = sg + i;
- client.deleteStorageGroup(new TDeleteStorageGroupReq(curSg));
+ client.deleteDatabase(new TDeleteDatabaseReq(curSg));
}
boolean isAllRegionGroupDeleted = false;
for (int retry = 0; retry < retryNum; retry++) {
@@ -170,7 +170,7 @@ public class IoTDBAutoRegionGroupExtensionIT {
.forEach(
regionInfo ->
regionCounter
- .computeIfAbsent(regionInfo.getStorageGroup(), empty -> new AtomicInteger(0))
+ .computeIfAbsent(regionInfo.getDatabase(), empty -> new AtomicInteger(0))
.getAndIncrement());
Assert.assertEquals(testSgNum, regionCounter.size());
regionCounter.forEach(
@@ -188,7 +188,7 @@ public class IoTDBAutoRegionGroupExtensionIT {
.forEach(
regionInfo ->
regionCounter
- .computeIfAbsent(regionInfo.getStorageGroup(), empty -> new AtomicInteger(0))
+ .computeIfAbsent(regionInfo.getDatabase(), empty -> new AtomicInteger(0))
.getAndIncrement());
Assert.assertEquals(testSgNum, regionCounter.size());
regionCounter.forEach(
diff --git a/integration-test/src/test/java/org/apache/iotdb/confignode/it/partition/IoTDBPartitionGetterIT.java b/integration-test/src/test/java/org/apache/iotdb/confignode/it/partition/IoTDBPartitionGetterIT.java
index e9e19f6eaf..f8afd8d2d4 100644
--- a/integration-test/src/test/java/org/apache/iotdb/confignode/it/partition/IoTDBPartitionGetterIT.java
+++ b/integration-test/src/test/java/org/apache/iotdb/confignode/it/partition/IoTDBPartitionGetterIT.java
@@ -327,9 +327,9 @@ public class IoTDBPartitionGetterIT {
// Check the number of DataRegionGroup.
// And this number should be greater than or equal to leastDataRegionGroupNum
TShowDatabaseResp showStorageGroupResp =
- client.showStorageGroup(Arrays.asList(storageGroup.split("\\.")));
+ client.showDatabase(Arrays.asList(storageGroup.split("\\.")));
Assert.assertTrue(
- showStorageGroupResp.getStorageGroupInfoMap().get(storageGroup).getDataRegionNum()
+ showStorageGroupResp.getDatabaseInfoMap().get(storageGroup).getDataRegionNum()
>= leastDataRegionGroupNum);
}
}
@@ -405,7 +405,7 @@ public class IoTDBPartitionGetterIT {
TSchemaPartitionReq schemaPartitionReq = new TSchemaPartitionReq(buffer);
TSchemaPartitionTableResp schemaPartitionTableResp =
client.getSchemaPartitionTable(schemaPartitionReq);
- getRegionIdReq.setStorageGroup(sg0);
+ getRegionIdReq.setDatabase(sg0);
getRegionIdReq.setSeriesSlotId(
new ArrayList<>(schemaPartitionTableResp.getSchemaPartitionTable().get(sg0).keySet())
.get(0));
diff --git a/server/src/main/java/org/apache/iotdb/db/client/ConfigNodeClient.java b/server/src/main/java/org/apache/iotdb/db/client/ConfigNodeClient.java
index 46498c02b8..aa169cd3eb 100644
--- a/server/src/main/java/org/apache/iotdb/db/client/ConfigNodeClient.java
+++ b/server/src/main/java/org/apache/iotdb/db/client/ConfigNodeClient.java
@@ -38,7 +38,7 @@ import org.apache.iotdb.confignode.rpc.thrift.TCheckUserPrivilegesReq;
import org.apache.iotdb.confignode.rpc.thrift.TConfigNodeRegisterReq;
import org.apache.iotdb.confignode.rpc.thrift.TConfigNodeRegisterResp;
import org.apache.iotdb.confignode.rpc.thrift.TConfigNodeRestartReq;
-import org.apache.iotdb.confignode.rpc.thrift.TCountStorageGroupResp;
+import org.apache.iotdb.confignode.rpc.thrift.TCountDatabaseResp;
import org.apache.iotdb.confignode.rpc.thrift.TCreateCQReq;
import org.apache.iotdb.confignode.rpc.thrift.TCreateFunctionReq;
import org.apache.iotdb.confignode.rpc.thrift.TCreateModelReq;
@@ -58,8 +58,8 @@ import org.apache.iotdb.confignode.rpc.thrift.TDataPartitionTableResp;
import org.apache.iotdb.confignode.rpc.thrift.TDatabaseSchema;
import org.apache.iotdb.confignode.rpc.thrift.TDatabaseSchemaResp;
import org.apache.iotdb.confignode.rpc.thrift.TDeactivateSchemaTemplateReq;
-import org.apache.iotdb.confignode.rpc.thrift.TDeleteStorageGroupReq;
-import org.apache.iotdb.confignode.rpc.thrift.TDeleteStorageGroupsReq;
+import org.apache.iotdb.confignode.rpc.thrift.TDeleteDatabaseReq;
+import org.apache.iotdb.confignode.rpc.thrift.TDeleteDatabasesReq;
import org.apache.iotdb.confignode.rpc.thrift.TDeleteTimeSeriesReq;
import org.apache.iotdb.confignode.rpc.thrift.TDropCQReq;
import org.apache.iotdb.confignode.rpc.thrift.TDropFunctionReq;
@@ -534,10 +534,10 @@ public class ConfigNodeClient implements IConfigNodeRPCService.Iface, ThriftClie
}
@Override
- public TSStatus deleteStorageGroup(TDeleteStorageGroupReq req) throws TException {
+ public TSStatus deleteDatabase(TDeleteDatabaseReq req) throws TException {
for (int i = 0; i < RETRY_NUM; i++) {
try {
- TSStatus status = client.deleteStorageGroup(req);
+ TSStatus status = client.deleteDatabase(req);
if (!updateConfigNodeLeader(status)) {
return status;
}
@@ -555,10 +555,10 @@ public class ConfigNodeClient implements IConfigNodeRPCService.Iface, ThriftClie
}
@Override
- public TSStatus deleteStorageGroups(TDeleteStorageGroupsReq req) throws TException {
+ public TSStatus deleteDatabases(TDeleteDatabasesReq req) throws TException {
for (int i = 0; i < RETRY_NUM; i++) {
try {
- TSStatus status = client.deleteStorageGroups(req);
+ TSStatus status = client.deleteDatabases(req);
if (!updateConfigNodeLeader(status)) {
return status;
}
@@ -576,11 +576,11 @@ public class ConfigNodeClient implements IConfigNodeRPCService.Iface, ThriftClie
}
@Override
- public TCountStorageGroupResp countMatchedStorageGroups(List<String> storageGroupPathPattern)
+ public TCountDatabaseResp countMatchedDatabases(List<String> storageGroupPathPattern)
throws TException {
for (int i = 0; i < RETRY_NUM; i++) {
try {
- TCountStorageGroupResp resp = client.countMatchedStorageGroups(storageGroupPathPattern);
+ TCountDatabaseResp resp = client.countMatchedDatabases(storageGroupPathPattern);
if (!updateConfigNodeLeader(resp.status)) {
return resp;
}
@@ -598,11 +598,11 @@ public class ConfigNodeClient implements IConfigNodeRPCService.Iface, ThriftClie
}
@Override
- public TDatabaseSchemaResp getMatchedStorageGroupSchemas(List<String> storageGroupPathPattern)
+ public TDatabaseSchemaResp getMatchedDatabaseSchemas(List<String> storageGroupPathPattern)
throws TException {
for (int i = 0; i < RETRY_NUM; i++) {
try {
- TDatabaseSchemaResp resp = client.getMatchedStorageGroupSchemas(storageGroupPathPattern);
+ TDatabaseSchemaResp resp = client.getMatchedDatabaseSchemas(storageGroupPathPattern);
if (!updateConfigNodeLeader(resp.status)) {
return resp;
}
@@ -1148,11 +1148,10 @@ public class ConfigNodeClient implements IConfigNodeRPCService.Iface, ThriftClie
}
@Override
- public TShowDatabaseResp showStorageGroup(List<String> storageGroupPathPattern)
- throws TException {
+ public TShowDatabaseResp showDatabase(List<String> storageGroupPathPattern) throws TException {
for (int i = 0; i < RETRY_NUM; i++) {
try {
- TShowDatabaseResp showStorageGroupResp = client.showStorageGroup(storageGroupPathPattern);
+ TShowDatabaseResp showStorageGroupResp = client.showDatabase(storageGroupPathPattern);
if (!updateConfigNodeLeader(showStorageGroupResp.getStatus())) {
return showStorageGroupResp;
}
diff --git a/server/src/main/java/org/apache/iotdb/db/mpp/plan/analyze/cache/PartitionCache.java b/server/src/main/java/org/apache/iotdb/db/mpp/plan/analyze/cache/PartitionCache.java
index 898db7c635..8ff3f587cf 100644
--- a/server/src/main/java/org/apache/iotdb/db/mpp/plan/analyze/cache/PartitionCache.java
+++ b/server/src/main/java/org/apache/iotdb/db/mpp/plan/analyze/cache/PartitionCache.java
@@ -190,12 +190,10 @@ public class PartitionCache {
result.reset();
getStorageGroupMap(result, devicePaths, true);
if (!result.isSuccess()) {
- TDatabaseSchemaResp storageGroupSchemaResp =
- client.getMatchedStorageGroupSchemas(ROOT_PATH);
+ TDatabaseSchemaResp storageGroupSchemaResp = client.getMatchedDatabaseSchemas(ROOT_PATH);
if (storageGroupSchemaResp.getStatus().getCode()
== TSStatusCode.SUCCESS_STATUS.getStatusCode()) {
- Set<String> storageGroupNames =
- storageGroupSchemaResp.getStorageGroupSchemaMap().keySet();
+ Set<String> storageGroupNames = storageGroupSchemaResp.getDatabaseSchemaMap().keySet();
// update all database into cache
updateStorageCache(storageGroupNames);
}
diff --git a/server/src/main/java/org/apache/iotdb/db/mpp/plan/execution/config/executor/ClusterConfigTaskExecutor.java b/server/src/main/java/org/apache/iotdb/db/mpp/plan/execution/config/executor/ClusterConfigTaskExecutor.java
index e74d93a428..d1ac9cff16 100644
--- a/server/src/main/java/org/apache/iotdb/db/mpp/plan/execution/config/executor/ClusterConfigTaskExecutor.java
+++ b/server/src/main/java/org/apache/iotdb/db/mpp/plan/execution/config/executor/ClusterConfigTaskExecutor.java
@@ -34,7 +34,7 @@ import org.apache.iotdb.commons.path.PathPatternTree;
import org.apache.iotdb.commons.trigger.service.TriggerExecutableManager;
import org.apache.iotdb.commons.udf.service.UDFClassLoader;
import org.apache.iotdb.commons.udf.service.UDFExecutableManager;
-import org.apache.iotdb.confignode.rpc.thrift.TCountStorageGroupResp;
+import org.apache.iotdb.confignode.rpc.thrift.TCountDatabaseResp;
import org.apache.iotdb.confignode.rpc.thrift.TCreateCQReq;
import org.apache.iotdb.confignode.rpc.thrift.TCreateFunctionReq;
import org.apache.iotdb.confignode.rpc.thrift.TCreatePipeReq;
@@ -42,7 +42,7 @@ import org.apache.iotdb.confignode.rpc.thrift.TCreateTriggerReq;
import org.apache.iotdb.confignode.rpc.thrift.TDatabaseSchema;
import org.apache.iotdb.confignode.rpc.thrift.TDatabaseSchemaResp;
import org.apache.iotdb.confignode.rpc.thrift.TDeactivateSchemaTemplateReq;
-import org.apache.iotdb.confignode.rpc.thrift.TDeleteStorageGroupsReq;
+import org.apache.iotdb.confignode.rpc.thrift.TDeleteDatabasesReq;
import org.apache.iotdb.confignode.rpc.thrift.TDeleteTimeSeriesReq;
import org.apache.iotdb.confignode.rpc.thrift.TDropCQReq;
import org.apache.iotdb.confignode.rpc.thrift.TDropFunctionReq;
@@ -262,9 +262,9 @@ public class ClusterConfigTaskExecutor implements IConfigTaskExecutor {
try (ConfigNodeClient client =
CONFIG_NODE_CLIENT_MANAGER.borrowClient(ConfigNodeInfo.configNodeRegionId)) {
// Send request to some API server
- TShowDatabaseResp resp = client.showStorageGroup(storageGroupPathPattern);
+ TShowDatabaseResp resp = client.showDatabase(storageGroupPathPattern);
// build TSBlock
- showStorageGroupStatement.buildTSBlock(resp.getStorageGroupInfoMap(), future);
+ showStorageGroupStatement.buildTSBlock(resp.getDatabaseInfoMap(), future);
} catch (ClientManagerException | TException e) {
future.setException(e);
}
@@ -280,7 +280,7 @@ public class ClusterConfigTaskExecutor implements IConfigTaskExecutor {
Arrays.asList(countStorageGroupStatement.getPathPattern().getNodes());
try (ConfigNodeClient client =
CONFIG_NODE_CLIENT_MANAGER.borrowClient(ConfigNodeInfo.configNodeRegionId)) {
- TCountStorageGroupResp resp = client.countMatchedStorageGroups(storageGroupPathPattern);
+ TCountDatabaseResp resp = client.countMatchedDatabases(storageGroupPathPattern);
storageGroupNum = resp.getCount();
// build TSBlock
CountStorageGroupTask.buildTSBlock(storageGroupNum, future);
@@ -294,11 +294,10 @@ public class ClusterConfigTaskExecutor implements IConfigTaskExecutor {
public SettableFuture<ConfigTaskResult> deleteStorageGroup(
DeleteStorageGroupStatement deleteStorageGroupStatement) {
SettableFuture<ConfigTaskResult> future = SettableFuture.create();
- TDeleteStorageGroupsReq req =
- new TDeleteStorageGroupsReq(deleteStorageGroupStatement.getPrefixPath());
+ TDeleteDatabasesReq req = new TDeleteDatabasesReq(deleteStorageGroupStatement.getPrefixPath());
try (ConfigNodeClient client =
CONFIG_NODE_CLIENT_MANAGER.borrowClient(ConfigNodeInfo.configNodeRegionId)) {
- TSStatus tsStatus = client.deleteStorageGroups(req);
+ TSStatus tsStatus = client.deleteDatabases(req);
if (TSStatusCode.SUCCESS_STATUS.getStatusCode() != tsStatus.getCode()) {
LOGGER.warn(
"Failed to execute delete database {} in config node, status is {}.",
@@ -856,17 +855,15 @@ public class ClusterConfigTaskExecutor implements IConfigTaskExecutor {
CONFIG_NODE_CLIENT_MANAGER.borrowClient(ConfigNodeInfo.configNodeRegionId)) {
if (showTTLStatement.isAll()) {
List<String> allStorageGroupPathPattern = Arrays.asList("root", "**");
- TDatabaseSchemaResp resp = client.getMatchedStorageGroupSchemas(allStorageGroupPathPattern);
- for (Map.Entry<String, TDatabaseSchema> entry :
- resp.getStorageGroupSchemaMap().entrySet()) {
+ TDatabaseSchemaResp resp = client.getMatchedDatabaseSchemas(allStorageGroupPathPattern);
+ for (Map.Entry<String, TDatabaseSchema> entry : resp.getDatabaseSchemaMap().entrySet()) {
storageGroupToTTL.put(entry.getKey(), entry.getValue().getTTL());
}
} else {
for (PartialPath storageGroupPath : storageGroupPaths) {
List<String> storageGroupPathPattern = Arrays.asList(storageGroupPath.getNodes());
- TDatabaseSchemaResp resp = client.getMatchedStorageGroupSchemas(storageGroupPathPattern);
- for (Map.Entry<String, TDatabaseSchema> entry :
- resp.getStorageGroupSchemaMap().entrySet()) {
+ TDatabaseSchemaResp resp = client.getMatchedDatabaseSchemas(storageGroupPathPattern);
+ for (Map.Entry<String, TDatabaseSchema> entry : resp.getDatabaseSchemaMap().entrySet()) {
if (!storageGroupToTTL.containsKey(entry.getKey())) {
storageGroupToTTL.put(entry.getKey(), entry.getValue().getTTL());
}
@@ -888,9 +885,9 @@ public class ClusterConfigTaskExecutor implements IConfigTaskExecutor {
TShowRegionReq showRegionReq = new TShowRegionReq();
showRegionReq.setConsensusGroupType(showRegionStatement.getRegionType());
if (showRegionStatement.getStorageGroups() == null) {
- showRegionReq.setStorageGroups(null);
+ showRegionReq.setDatabases(null);
} else {
- showRegionReq.setStorageGroups(
+ showRegionReq.setDatabases(
showRegionStatement.getStorageGroups().stream()
.map(PartialPath::getFullPath)
.collect(Collectors.toList()));
diff --git a/server/src/main/java/org/apache/iotdb/db/mpp/plan/execution/config/metadata/ShowRegionTask.java b/server/src/main/java/org/apache/iotdb/db/mpp/plan/execution/config/metadata/ShowRegionTask.java
index 0847ba9759..4cee887fa4 100644
--- a/server/src/main/java/org/apache/iotdb/db/mpp/plan/execution/config/metadata/ShowRegionTask.java
+++ b/server/src/main/java/org/apache/iotdb/db/mpp/plan/execution/config/metadata/ShowRegionTask.java
@@ -83,7 +83,7 @@ public class ShowRegionTask implements IConfigTask {
.getColumnBuilder(2)
.writeBinary(
Binary.valueOf(regionInfo.getStatus() == null ? "" : regionInfo.getStatus()));
- builder.getColumnBuilder(3).writeBinary(Binary.valueOf(regionInfo.getStorageGroup()));
+ builder.getColumnBuilder(3).writeBinary(Binary.valueOf(regionInfo.getDatabase()));
builder.getColumnBuilder(4).writeInt(regionInfo.getSeriesSlots());
builder.getColumnBuilder(5).writeLong(regionInfo.getTimeSlots());
builder.getColumnBuilder(6).writeInt(regionInfo.getDataNodeId());
diff --git a/thrift-confignode/src/main/thrift/confignode.thrift b/thrift-confignode/src/main/thrift/confignode.thrift
index 46c55a955f..654617349a 100644
--- a/thrift-confignode/src/main/thrift/confignode.thrift
+++ b/thrift-confignode/src/main/thrift/confignode.thrift
@@ -146,30 +146,30 @@ struct TSetDataNodeStatusReq {
}
// Database
-struct TDeleteStorageGroupReq {
+struct TDeleteDatabaseReq {
1: required string prefixPath
}
-struct TDeleteStorageGroupsReq {
+struct TDeleteDatabasesReq {
1: required list<string> prefixPathList
}
struct TSetSchemaReplicationFactorReq {
- 1: required string storageGroup
+ 1: required string database
2: required i32 schemaReplicationFactor
}
struct TSetDataReplicationFactorReq {
- 1: required string storageGroup
+ 1: required string database
2: required i32 dataReplicationFactor
}
struct TSetTimePartitionIntervalReq {
- 1: required string storageGroup
+ 1: required string database
2: required i64 timePartitionInterval
}
-struct TCountStorageGroupResp {
+struct TCountDatabaseResp {
1: required common.TSStatus status
2: optional i32 count
}
@@ -177,7 +177,7 @@ struct TCountStorageGroupResp {
struct TDatabaseSchemaResp {
1: required common.TSStatus status
// map<string, TDatabaseSchema>
- 2: optional map<string, TDatabaseSchema> storageGroupSchemaMap
+ 2: optional map<string, TDatabaseSchema> databaseSchemaMap
}
struct TDatabaseSchema {
@@ -199,7 +199,7 @@ struct TSchemaPartitionReq {
struct TSchemaPartitionTableResp {
1: required common.TSStatus status
- // map<StorageGroupName, map<TSeriesPartitionSlot, TConsensusGroupId>>
+ // map<DatabaseName, map<TSeriesPartitionSlot, TConsensusGroupId>>
2: optional map<string, map<common.TSeriesPartitionSlot, common.TConsensusGroupId>> schemaPartitionTable
}
@@ -211,7 +211,7 @@ struct TSchemaNodeManagementReq {
struct TSchemaNodeManagementResp {
1: required common.TSStatus status
- // map<StorageGroupName, map<TSeriesPartitionSlot, TRegionReplicaSet>>
+ // map<DatabaseName, map<TSeriesPartitionSlot, TRegionReplicaSet>>
2: optional map<string, map<common.TSeriesPartitionSlot, common.TRegionReplicaSet>> schemaRegionMap
3: optional set<common.TSchemaNode> matchedNode
}
@@ -224,18 +224,18 @@ struct TTimeSlotList {
// Data
struct TDataPartitionReq {
- // map<StorageGroupName, map<TSeriesPartitionSlot, TTimePartionSlotList>>
+ // map<DatabaseName, map<TSeriesPartitionSlot, TTimePartionSlotList>>
1: required map<string, map<common.TSeriesPartitionSlot, TTimeSlotList>> partitionSlotsMap
}
struct TDataPartitionTableResp {
1: required common.TSStatus status
- // map<StorageGroupName, map<TSeriesPartitionSlot, map<TTimePartitionSlot, list<TConsensusGroupId>>>>
+ // map<DatabaseName, map<TSeriesPartitionSlot, map<TTimePartitionSlot, list<TConsensusGroupId>>>>
2: optional map<string, map<common.TSeriesPartitionSlot, map<common.TTimePartitionSlot, list<common.TConsensusGroupId>>>> dataPartitionTable
}
struct TGetRegionIdReq {
- 1: required string storageGroup
+ 1: required string database
2: required common.TConsensusGroupType type
3: optional common.TSeriesPartitionSlot seriesSlotId
4: optional string deviceId
@@ -249,7 +249,7 @@ struct TGetRegionIdResp {
}
struct TGetTimeSlotListReq {
- 1: required string storageGroup
+ 1: required string database
2: required common.TSeriesPartitionSlot seriesSlotId
3: optional i64 startTime
4: optional i64 endTime
@@ -261,7 +261,7 @@ struct TGetTimeSlotListResp {
}
struct TGetSeriesSlotListReq {
- 1: required string storageGroup
+ 1: required string database
2: optional common.TConsensusGroupType type
}
@@ -500,18 +500,18 @@ struct TDatabaseInfo {
struct TShowDatabaseResp {
1: required common.TSStatus status
// map<DatabaseName, TDatabaseInfo>
- 2: optional map<string, TDatabaseInfo> storageGroupInfoMap
+ 2: optional map<string, TDatabaseInfo> databaseInfoMap
}
// Show regions
struct TShowRegionReq {
1: optional common.TConsensusGroupType consensusGroupType;
- 2: optional list<string> storageGroups
+ 2: optional list<string> databases
}
struct TRegionInfo {
1: required common.TConsensusGroupId consensusGroupId
- 2: required string storageGroup
+ 2: required string database
3: required i32 dataNodeId
4: required string clientRpcIp
5: required i32 clientRpcPort
@@ -803,40 +803,40 @@ service IConfigNodeRPCService {
common.TSStatus alterDatabase(TDatabaseSchema databaseSchema)
/**
- * Generate a DeleteStorageGroupProcedure to delete a specific StorageGroup
+ * Generate a DeleteDatabaseProcedure to delete a specified Database
*
- * @return SUCCESS_STATUS if the DeleteStorageGroupProcedure submitted successfully
- * TIMESERIES_NOT_EXIST if the specific StorageGroup doesn't exist
- * EXECUTE_STATEMENT_ERROR if failed to submit the DeleteStorageGroupProcedure
+ * @return SUCCESS_STATUS if the DeleteDatabaseProcedure submitted successfully
+ * TIMESERIES_NOT_EXIST if the specific Database doesn't exist
+ * EXECUTE_STATEMENT_ERROR if failed to submit the DeleteDatabaseProcedure
*/
- common.TSStatus deleteStorageGroup(TDeleteStorageGroupReq req)
+ common.TSStatus deleteDatabase(TDeleteDatabaseReq req)
/**
- * Generate a set of DeleteStorageGroupProcedure to delete some specific StorageGroups
+ * Generate a set of DeleteDatabaseProcedure to delete some specific Databases
*
- * @return SUCCESS_STATUS if the DeleteStorageGroupProcedure submitted successfully
- * TIMESERIES_NOT_EXIST if the specific StorageGroup doesn't exist
- * EXECUTE_STATEMENT_ERROR if failed to submit the DeleteStorageGroupProcedure
+ * @return SUCCESS_STATUS if the DeleteDatabaseProcedure submitted successfully
+ * TIMESERIES_NOT_EXIST if the specific Database doesn't exist
+ * EXECUTE_STATEMENT_ERROR if failed to submit the DeleteDatabaseProcedure
*/
- common.TSStatus deleteStorageGroups(TDeleteStorageGroupsReq req)
+ common.TSStatus deleteDatabases(TDeleteDatabasesReq req)
- /** Update the specific StorageGroup's TTL */
+ /** Update the specific Database's TTL */
common.TSStatus setTTL(common.TSetTTLReq req)
- /** Update the specific StorageGroup's SchemaReplicationFactor */
+ /** Update the specific Database's SchemaReplicationFactor */
common.TSStatus setSchemaReplicationFactor(TSetSchemaReplicationFactorReq req)
- /** Update the specific StorageGroup's DataReplicationFactor */
+ /** Update the specific Database's DataReplicationFactor */
common.TSStatus setDataReplicationFactor(TSetDataReplicationFactorReq req)
- /** Update the specific StorageGroup's PartitionInterval */
+ /** Update the specific Database's PartitionInterval */
common.TSStatus setTimePartitionInterval(TSetTimePartitionIntervalReq req)
- /** Count the matched StorageGroups */
- TCountStorageGroupResp countMatchedStorageGroups(list<string> storageGroupPathPattern)
+ /** Count the matched Databases */
+ TCountDatabaseResp countMatchedDatabases(list<string> DatabasePathPattern)
- /** Get the matched StorageGroups' TDatabaseSchema */
- TDatabaseSchemaResp getMatchedStorageGroupSchemas(list<string> storageGroupPathPattern)
+ /** Get the matched Databases' TDatabaseSchema */
+ TDatabaseSchemaResp getMatchedDatabaseSchemas(list<string> DatabasePathPattern)
// ======================================================
// SchemaPartition
@@ -856,7 +856,7 @@ service IConfigNodeRPCService {
*
* @return SUCCESS_STATUS if the SchemaPartitionTable got or created successfully
* NOT_ENOUGH_DATA_NODE if the number of cluster DataNodes is not enough for creating new SchemaRegions
- * STORAGE_GROUP_NOT_EXIST if some StorageGroups don't exist
+ * STORAGE_GROUP_NOT_EXIST if some Databases don't exist
*/
TSchemaPartitionTableResp getOrCreateSchemaPartitionTable(TSchemaPartitionReq req)
@@ -886,7 +886,7 @@ service IConfigNodeRPCService {
*
* @return SUCCESS_STATUS if the DataPartitionTable got or created successfully
* NOT_ENOUGH_DATA_NODE if the number of cluster DataNodes is not enough for creating new DataRegions
- * STORAGE_GROUP_NOT_EXIST if some StorageGroups don't exist
+ * STORAGE_GROUP_NOT_EXIST if some Databases don't exist
*/
TDataPartitionTableResp getOrCreateDataPartitionTable(TDataPartitionReq req)
@@ -1101,8 +1101,8 @@ service IConfigNodeRPCService {
/** Show cluster ConfigNodes' information */
TShowConfigNodesResp showConfigNodes()
- /** Show cluster StorageGroups' information */
- TShowDatabaseResp showStorageGroup(list<string> storageGroupPathPattern)
+ /** Show cluster Databases' information */
+ TShowDatabaseResp showDatabase(list<string> databasePathPattern)
/**
* Show the matched cluster Regions' information