This is an automated email from the ASF dual-hosted git repository. rong pushed a commit to branch multi-cyclic-pipe in repository https://gitbox.apache.org/repos/asf/iotdb.git
commit bfdbc022a5e3b3574f61006b93b5232a54461b3b Author: Steve Yurong Su <[email protected]> AuthorDate: Mon Aug 14 20:58:02 2023 +0800 refactor package name --- .../queryengine/plan/execution/config/ConfigTaskVisitor.java | 10 +++++----- .../execution/config/executor/ClusterConfigTaskExecutor.java | 10 +++++----- .../plan/execution/config/executor/IConfigTaskExecutor.java | 10 +++++----- .../plan/execution/config/sys/pipe/CreatePipeTask.java | 2 +- .../plan/execution/config/sys/pipe/DropPipeTask.java | 2 +- .../plan/execution/config/sys/pipe/ShowPipeTask.java | 2 +- .../plan/execution/config/sys/pipe/StartPipeTask.java | 2 +- .../plan/execution/config/sys/pipe/StopPipeTask.java | 2 +- .../apache/iotdb/db/queryengine/plan/parser/ASTVisitor.java | 10 +++++----- .../iotdb/db/queryengine/plan/statement/StatementVisitor.java | 10 +++++----- .../statement/{sys => metadata}/pipe/CreatePipeStatement.java | 2 +- .../statement/{sys => metadata}/pipe/DropPipeStatement.java | 2 +- .../statement/{sys => metadata}/pipe/ShowPipesStatement.java | 2 +- .../statement/{sys => metadata}/pipe/StartPipeStatement.java | 2 +- .../statement/{sys => metadata}/pipe/StopPipeStatement.java | 2 +- .../plan/plan/statement/sys/pipe/PipeStatementTest.java | 10 +++++----- 16 files changed, 40 insertions(+), 40 deletions(-) diff --git a/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/execution/config/ConfigTaskVisitor.java b/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/execution/config/ConfigTaskVisitor.java index f98bd503882..57b6a3cbad9 100644 --- a/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/execution/config/ConfigTaskVisitor.java +++ b/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/execution/config/ConfigTaskVisitor.java @@ -119,6 +119,11 @@ import org.apache.iotdb.db.queryengine.plan.statement.metadata.model.CreateModel import org.apache.iotdb.db.queryengine.plan.statement.metadata.model.DropModelStatement; import org.apache.iotdb.db.queryengine.plan.statement.metadata.model.ShowModelsStatement; import org.apache.iotdb.db.queryengine.plan.statement.metadata.model.ShowTrailsStatement; +import org.apache.iotdb.db.queryengine.plan.statement.metadata.pipe.CreatePipeStatement; +import org.apache.iotdb.db.queryengine.plan.statement.metadata.pipe.DropPipeStatement; +import org.apache.iotdb.db.queryengine.plan.statement.metadata.pipe.ShowPipesStatement; +import org.apache.iotdb.db.queryengine.plan.statement.metadata.pipe.StartPipeStatement; +import org.apache.iotdb.db.queryengine.plan.statement.metadata.pipe.StopPipeStatement; import org.apache.iotdb.db.queryengine.plan.statement.metadata.template.AlterSchemaTemplateStatement; import org.apache.iotdb.db.queryengine.plan.statement.metadata.template.CreateSchemaTemplateStatement; import org.apache.iotdb.db.queryengine.plan.statement.metadata.template.DeactivateTemplateStatement; @@ -138,11 +143,6 @@ import org.apache.iotdb.db.queryengine.plan.statement.sys.KillQueryStatement; import org.apache.iotdb.db.queryengine.plan.statement.sys.LoadConfigurationStatement; import org.apache.iotdb.db.queryengine.plan.statement.sys.MergeStatement; import org.apache.iotdb.db.queryengine.plan.statement.sys.SetSystemStatusStatement; -import org.apache.iotdb.db.queryengine.plan.statement.sys.pipe.CreatePipeStatement; -import org.apache.iotdb.db.queryengine.plan.statement.sys.pipe.DropPipeStatement; -import org.apache.iotdb.db.queryengine.plan.statement.sys.pipe.ShowPipesStatement; -import org.apache.iotdb.db.queryengine.plan.statement.sys.pipe.StartPipeStatement; -import org.apache.iotdb.db.queryengine.plan.statement.sys.pipe.StopPipeStatement; import org.apache.iotdb.db.queryengine.plan.statement.sys.quota.SetSpaceQuotaStatement; import org.apache.iotdb.db.queryengine.plan.statement.sys.quota.SetThrottleQuotaStatement; import org.apache.iotdb.db.queryengine.plan.statement.sys.quota.ShowSpaceQuotaStatement; diff --git a/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/execution/config/executor/ClusterConfigTaskExecutor.java b/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/execution/config/executor/ClusterConfigTaskExecutor.java index a2c4783e266..1f25a869d04 100644 --- a/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/execution/config/executor/ClusterConfigTaskExecutor.java +++ b/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/execution/config/executor/ClusterConfigTaskExecutor.java @@ -160,6 +160,11 @@ import org.apache.iotdb.db.queryengine.plan.statement.metadata.ShowDatabaseState import org.apache.iotdb.db.queryengine.plan.statement.metadata.ShowRegionStatement; import org.apache.iotdb.db.queryengine.plan.statement.metadata.ShowTTLStatement; import org.apache.iotdb.db.queryengine.plan.statement.metadata.model.CreateModelStatement; +import org.apache.iotdb.db.queryengine.plan.statement.metadata.pipe.CreatePipeStatement; +import org.apache.iotdb.db.queryengine.plan.statement.metadata.pipe.DropPipeStatement; +import org.apache.iotdb.db.queryengine.plan.statement.metadata.pipe.ShowPipesStatement; +import org.apache.iotdb.db.queryengine.plan.statement.metadata.pipe.StartPipeStatement; +import org.apache.iotdb.db.queryengine.plan.statement.metadata.pipe.StopPipeStatement; import org.apache.iotdb.db.queryengine.plan.statement.metadata.template.AlterSchemaTemplateStatement; import org.apache.iotdb.db.queryengine.plan.statement.metadata.template.CreateSchemaTemplateStatement; import org.apache.iotdb.db.queryengine.plan.statement.metadata.template.DeactivateTemplateStatement; @@ -174,11 +179,6 @@ import org.apache.iotdb.db.queryengine.plan.statement.metadata.view.CreateLogica import org.apache.iotdb.db.queryengine.plan.statement.metadata.view.DeleteLogicalViewStatement; import org.apache.iotdb.db.queryengine.plan.statement.metadata.view.RenameLogicalViewStatement; import org.apache.iotdb.db.queryengine.plan.statement.sys.KillQueryStatement; -import org.apache.iotdb.db.queryengine.plan.statement.sys.pipe.CreatePipeStatement; -import org.apache.iotdb.db.queryengine.plan.statement.sys.pipe.DropPipeStatement; -import org.apache.iotdb.db.queryengine.plan.statement.sys.pipe.ShowPipesStatement; -import org.apache.iotdb.db.queryengine.plan.statement.sys.pipe.StartPipeStatement; -import org.apache.iotdb.db.queryengine.plan.statement.sys.pipe.StopPipeStatement; import org.apache.iotdb.db.queryengine.plan.statement.sys.quota.SetSpaceQuotaStatement; import org.apache.iotdb.db.queryengine.plan.statement.sys.quota.SetThrottleQuotaStatement; import org.apache.iotdb.db.queryengine.plan.statement.sys.quota.ShowSpaceQuotaStatement; diff --git a/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/execution/config/executor/IConfigTaskExecutor.java b/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/execution/config/executor/IConfigTaskExecutor.java index a59ada9d88b..895f81cd9be 100644 --- a/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/execution/config/executor/IConfigTaskExecutor.java +++ b/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/execution/config/executor/IConfigTaskExecutor.java @@ -44,6 +44,11 @@ import org.apache.iotdb.db.queryengine.plan.statement.metadata.ShowDatabaseState import org.apache.iotdb.db.queryengine.plan.statement.metadata.ShowRegionStatement; import org.apache.iotdb.db.queryengine.plan.statement.metadata.ShowTTLStatement; import org.apache.iotdb.db.queryengine.plan.statement.metadata.model.CreateModelStatement; +import org.apache.iotdb.db.queryengine.plan.statement.metadata.pipe.CreatePipeStatement; +import org.apache.iotdb.db.queryengine.plan.statement.metadata.pipe.DropPipeStatement; +import org.apache.iotdb.db.queryengine.plan.statement.metadata.pipe.ShowPipesStatement; +import org.apache.iotdb.db.queryengine.plan.statement.metadata.pipe.StartPipeStatement; +import org.apache.iotdb.db.queryengine.plan.statement.metadata.pipe.StopPipeStatement; import org.apache.iotdb.db.queryengine.plan.statement.metadata.template.AlterSchemaTemplateStatement; import org.apache.iotdb.db.queryengine.plan.statement.metadata.template.CreateSchemaTemplateStatement; import org.apache.iotdb.db.queryengine.plan.statement.metadata.template.DeactivateTemplateStatement; @@ -57,11 +62,6 @@ import org.apache.iotdb.db.queryengine.plan.statement.metadata.view.AlterLogical import org.apache.iotdb.db.queryengine.plan.statement.metadata.view.DeleteLogicalViewStatement; import org.apache.iotdb.db.queryengine.plan.statement.metadata.view.RenameLogicalViewStatement; import org.apache.iotdb.db.queryengine.plan.statement.sys.KillQueryStatement; -import org.apache.iotdb.db.queryengine.plan.statement.sys.pipe.CreatePipeStatement; -import org.apache.iotdb.db.queryengine.plan.statement.sys.pipe.DropPipeStatement; -import org.apache.iotdb.db.queryengine.plan.statement.sys.pipe.ShowPipesStatement; -import org.apache.iotdb.db.queryengine.plan.statement.sys.pipe.StartPipeStatement; -import org.apache.iotdb.db.queryengine.plan.statement.sys.pipe.StopPipeStatement; import org.apache.iotdb.db.queryengine.plan.statement.sys.quota.SetSpaceQuotaStatement; import org.apache.iotdb.db.queryengine.plan.statement.sys.quota.SetThrottleQuotaStatement; import org.apache.iotdb.db.queryengine.plan.statement.sys.quota.ShowSpaceQuotaStatement; diff --git a/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/execution/config/sys/pipe/CreatePipeTask.java b/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/execution/config/sys/pipe/CreatePipeTask.java index 5d71693f6bc..f0213c7d4f7 100644 --- a/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/execution/config/sys/pipe/CreatePipeTask.java +++ b/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/execution/config/sys/pipe/CreatePipeTask.java @@ -22,7 +22,7 @@ package org.apache.iotdb.db.queryengine.plan.execution.config.sys.pipe; import org.apache.iotdb.db.queryengine.plan.execution.config.ConfigTaskResult; import org.apache.iotdb.db.queryengine.plan.execution.config.IConfigTask; import org.apache.iotdb.db.queryengine.plan.execution.config.executor.IConfigTaskExecutor; -import org.apache.iotdb.db.queryengine.plan.statement.sys.pipe.CreatePipeStatement; +import org.apache.iotdb.db.queryengine.plan.statement.metadata.pipe.CreatePipeStatement; import com.google.common.util.concurrent.ListenableFuture; diff --git a/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/execution/config/sys/pipe/DropPipeTask.java b/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/execution/config/sys/pipe/DropPipeTask.java index ec074a0de87..f3449f36990 100644 --- a/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/execution/config/sys/pipe/DropPipeTask.java +++ b/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/execution/config/sys/pipe/DropPipeTask.java @@ -22,7 +22,7 @@ package org.apache.iotdb.db.queryengine.plan.execution.config.sys.pipe; import org.apache.iotdb.db.queryengine.plan.execution.config.ConfigTaskResult; import org.apache.iotdb.db.queryengine.plan.execution.config.IConfigTask; import org.apache.iotdb.db.queryengine.plan.execution.config.executor.IConfigTaskExecutor; -import org.apache.iotdb.db.queryengine.plan.statement.sys.pipe.DropPipeStatement; +import org.apache.iotdb.db.queryengine.plan.statement.metadata.pipe.DropPipeStatement; import com.google.common.util.concurrent.ListenableFuture; diff --git a/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/execution/config/sys/pipe/ShowPipeTask.java b/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/execution/config/sys/pipe/ShowPipeTask.java index 1e7dc50be2c..e5343e3c8eb 100644 --- a/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/execution/config/sys/pipe/ShowPipeTask.java +++ b/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/execution/config/sys/pipe/ShowPipeTask.java @@ -27,7 +27,7 @@ import org.apache.iotdb.db.queryengine.common.header.DatasetHeaderFactory; import org.apache.iotdb.db.queryengine.plan.execution.config.ConfigTaskResult; import org.apache.iotdb.db.queryengine.plan.execution.config.IConfigTask; import org.apache.iotdb.db.queryengine.plan.execution.config.executor.IConfigTaskExecutor; -import org.apache.iotdb.db.queryengine.plan.statement.sys.pipe.ShowPipesStatement; +import org.apache.iotdb.db.queryengine.plan.statement.metadata.pipe.ShowPipesStatement; import org.apache.iotdb.db.utils.DateTimeUtils; import org.apache.iotdb.rpc.TSStatusCode; import org.apache.iotdb.tsfile.file.metadata.enums.TSDataType; diff --git a/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/execution/config/sys/pipe/StartPipeTask.java b/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/execution/config/sys/pipe/StartPipeTask.java index 9b9539c732f..62b55bb017c 100644 --- a/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/execution/config/sys/pipe/StartPipeTask.java +++ b/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/execution/config/sys/pipe/StartPipeTask.java @@ -22,7 +22,7 @@ package org.apache.iotdb.db.queryengine.plan.execution.config.sys.pipe; import org.apache.iotdb.db.queryengine.plan.execution.config.ConfigTaskResult; import org.apache.iotdb.db.queryengine.plan.execution.config.IConfigTask; import org.apache.iotdb.db.queryengine.plan.execution.config.executor.IConfigTaskExecutor; -import org.apache.iotdb.db.queryengine.plan.statement.sys.pipe.StartPipeStatement; +import org.apache.iotdb.db.queryengine.plan.statement.metadata.pipe.StartPipeStatement; import com.google.common.util.concurrent.ListenableFuture; diff --git a/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/execution/config/sys/pipe/StopPipeTask.java b/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/execution/config/sys/pipe/StopPipeTask.java index a0e495cc8bd..c18070a5027 100644 --- a/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/execution/config/sys/pipe/StopPipeTask.java +++ b/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/execution/config/sys/pipe/StopPipeTask.java @@ -22,7 +22,7 @@ package org.apache.iotdb.db.queryengine.plan.execution.config.sys.pipe; import org.apache.iotdb.db.queryengine.plan.execution.config.ConfigTaskResult; import org.apache.iotdb.db.queryengine.plan.execution.config.IConfigTask; import org.apache.iotdb.db.queryengine.plan.execution.config.executor.IConfigTaskExecutor; -import org.apache.iotdb.db.queryengine.plan.statement.sys.pipe.StopPipeStatement; +import org.apache.iotdb.db.queryengine.plan.statement.metadata.pipe.StopPipeStatement; import com.google.common.util.concurrent.ListenableFuture; diff --git a/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/parser/ASTVisitor.java b/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/parser/ASTVisitor.java index ce9bd6b11f4..f21a4496878 100644 --- a/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/parser/ASTVisitor.java +++ b/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/parser/ASTVisitor.java @@ -160,6 +160,11 @@ import org.apache.iotdb.db.queryengine.plan.statement.metadata.model.CreateModel import org.apache.iotdb.db.queryengine.plan.statement.metadata.model.DropModelStatement; import org.apache.iotdb.db.queryengine.plan.statement.metadata.model.ShowModelsStatement; import org.apache.iotdb.db.queryengine.plan.statement.metadata.model.ShowTrailsStatement; +import org.apache.iotdb.db.queryengine.plan.statement.metadata.pipe.CreatePipeStatement; +import org.apache.iotdb.db.queryengine.plan.statement.metadata.pipe.DropPipeStatement; +import org.apache.iotdb.db.queryengine.plan.statement.metadata.pipe.ShowPipesStatement; +import org.apache.iotdb.db.queryengine.plan.statement.metadata.pipe.StartPipeStatement; +import org.apache.iotdb.db.queryengine.plan.statement.metadata.pipe.StopPipeStatement; import org.apache.iotdb.db.queryengine.plan.statement.metadata.template.ActivateTemplateStatement; import org.apache.iotdb.db.queryengine.plan.statement.metadata.template.AlterSchemaTemplateStatement; import org.apache.iotdb.db.queryengine.plan.statement.metadata.template.CreateSchemaTemplateStatement; @@ -185,11 +190,6 @@ import org.apache.iotdb.db.queryengine.plan.statement.sys.MergeStatement; import org.apache.iotdb.db.queryengine.plan.statement.sys.SetSystemStatusStatement; import org.apache.iotdb.db.queryengine.plan.statement.sys.ShowQueriesStatement; import org.apache.iotdb.db.queryengine.plan.statement.sys.ShowVersionStatement; -import org.apache.iotdb.db.queryengine.plan.statement.sys.pipe.CreatePipeStatement; -import org.apache.iotdb.db.queryengine.plan.statement.sys.pipe.DropPipeStatement; -import org.apache.iotdb.db.queryengine.plan.statement.sys.pipe.ShowPipesStatement; -import org.apache.iotdb.db.queryengine.plan.statement.sys.pipe.StartPipeStatement; -import org.apache.iotdb.db.queryengine.plan.statement.sys.pipe.StopPipeStatement; import org.apache.iotdb.db.queryengine.plan.statement.sys.quota.SetSpaceQuotaStatement; import org.apache.iotdb.db.queryengine.plan.statement.sys.quota.SetThrottleQuotaStatement; import org.apache.iotdb.db.queryengine.plan.statement.sys.quota.ShowSpaceQuotaStatement; diff --git a/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/statement/StatementVisitor.java b/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/statement/StatementVisitor.java index 0fc4bd25d98..e3eb02b7927 100644 --- a/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/statement/StatementVisitor.java +++ b/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/statement/StatementVisitor.java @@ -78,6 +78,11 @@ import org.apache.iotdb.db.queryengine.plan.statement.metadata.model.CreateModel import org.apache.iotdb.db.queryengine.plan.statement.metadata.model.DropModelStatement; import org.apache.iotdb.db.queryengine.plan.statement.metadata.model.ShowModelsStatement; import org.apache.iotdb.db.queryengine.plan.statement.metadata.model.ShowTrailsStatement; +import org.apache.iotdb.db.queryengine.plan.statement.metadata.pipe.CreatePipeStatement; +import org.apache.iotdb.db.queryengine.plan.statement.metadata.pipe.DropPipeStatement; +import org.apache.iotdb.db.queryengine.plan.statement.metadata.pipe.ShowPipesStatement; +import org.apache.iotdb.db.queryengine.plan.statement.metadata.pipe.StartPipeStatement; +import org.apache.iotdb.db.queryengine.plan.statement.metadata.pipe.StopPipeStatement; import org.apache.iotdb.db.queryengine.plan.statement.metadata.template.ActivateTemplateStatement; import org.apache.iotdb.db.queryengine.plan.statement.metadata.template.AlterSchemaTemplateStatement; import org.apache.iotdb.db.queryengine.plan.statement.metadata.template.BatchActivateTemplateStatement; @@ -105,11 +110,6 @@ import org.apache.iotdb.db.queryengine.plan.statement.sys.MergeStatement; import org.apache.iotdb.db.queryengine.plan.statement.sys.SetSystemStatusStatement; import org.apache.iotdb.db.queryengine.plan.statement.sys.ShowQueriesStatement; import org.apache.iotdb.db.queryengine.plan.statement.sys.ShowVersionStatement; -import org.apache.iotdb.db.queryengine.plan.statement.sys.pipe.CreatePipeStatement; -import org.apache.iotdb.db.queryengine.plan.statement.sys.pipe.DropPipeStatement; -import org.apache.iotdb.db.queryengine.plan.statement.sys.pipe.ShowPipesStatement; -import org.apache.iotdb.db.queryengine.plan.statement.sys.pipe.StartPipeStatement; -import org.apache.iotdb.db.queryengine.plan.statement.sys.pipe.StopPipeStatement; import org.apache.iotdb.db.queryengine.plan.statement.sys.quota.SetSpaceQuotaStatement; import org.apache.iotdb.db.queryengine.plan.statement.sys.quota.SetThrottleQuotaStatement; import org.apache.iotdb.db.queryengine.plan.statement.sys.quota.ShowSpaceQuotaStatement; diff --git a/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/statement/sys/pipe/CreatePipeStatement.java b/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/statement/metadata/pipe/CreatePipeStatement.java similarity index 97% rename from iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/statement/sys/pipe/CreatePipeStatement.java rename to iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/statement/metadata/pipe/CreatePipeStatement.java index d58eb871bac..8737969d724 100644 --- a/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/statement/sys/pipe/CreatePipeStatement.java +++ b/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/statement/metadata/pipe/CreatePipeStatement.java @@ -17,7 +17,7 @@ * under the License. */ -package org.apache.iotdb.db.queryengine.plan.statement.sys.pipe; +package org.apache.iotdb.db.queryengine.plan.statement.metadata.pipe; import org.apache.iotdb.commons.path.PartialPath; import org.apache.iotdb.db.queryengine.plan.analyze.QueryType; diff --git a/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/statement/sys/pipe/DropPipeStatement.java b/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/statement/metadata/pipe/DropPipeStatement.java similarity index 96% rename from iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/statement/sys/pipe/DropPipeStatement.java rename to iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/statement/metadata/pipe/DropPipeStatement.java index 7c8dbbf4358..e5a1717123a 100644 --- a/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/statement/sys/pipe/DropPipeStatement.java +++ b/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/statement/metadata/pipe/DropPipeStatement.java @@ -17,7 +17,7 @@ * under the License. */ -package org.apache.iotdb.db.queryengine.plan.statement.sys.pipe; +package org.apache.iotdb.db.queryengine.plan.statement.metadata.pipe; import org.apache.iotdb.commons.path.PartialPath; import org.apache.iotdb.db.queryengine.plan.analyze.QueryType; diff --git a/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/statement/sys/pipe/ShowPipesStatement.java b/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/statement/metadata/pipe/ShowPipesStatement.java similarity index 96% rename from iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/statement/sys/pipe/ShowPipesStatement.java rename to iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/statement/metadata/pipe/ShowPipesStatement.java index 84164e012be..0c7d209516c 100644 --- a/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/statement/sys/pipe/ShowPipesStatement.java +++ b/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/statement/metadata/pipe/ShowPipesStatement.java @@ -17,7 +17,7 @@ * under the License. */ -package org.apache.iotdb.db.queryengine.plan.statement.sys.pipe; +package org.apache.iotdb.db.queryengine.plan.statement.metadata.pipe; import org.apache.iotdb.db.queryengine.plan.analyze.QueryType; import org.apache.iotdb.db.queryengine.plan.statement.IConfigStatement; diff --git a/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/statement/sys/pipe/StartPipeStatement.java b/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/statement/metadata/pipe/StartPipeStatement.java similarity index 96% rename from iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/statement/sys/pipe/StartPipeStatement.java rename to iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/statement/metadata/pipe/StartPipeStatement.java index b908e9a9b35..54fa1fd97cf 100644 --- a/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/statement/sys/pipe/StartPipeStatement.java +++ b/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/statement/metadata/pipe/StartPipeStatement.java @@ -17,7 +17,7 @@ * under the License. */ -package org.apache.iotdb.db.queryengine.plan.statement.sys.pipe; +package org.apache.iotdb.db.queryengine.plan.statement.metadata.pipe; import org.apache.iotdb.commons.path.PartialPath; import org.apache.iotdb.db.queryengine.plan.analyze.QueryType; diff --git a/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/statement/sys/pipe/StopPipeStatement.java b/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/statement/metadata/pipe/StopPipeStatement.java similarity index 96% rename from iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/statement/sys/pipe/StopPipeStatement.java rename to iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/statement/metadata/pipe/StopPipeStatement.java index 989bf45bc5f..5dc50ee9eae 100644 --- a/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/statement/sys/pipe/StopPipeStatement.java +++ b/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/statement/metadata/pipe/StopPipeStatement.java @@ -17,7 +17,7 @@ * under the License. */ -package org.apache.iotdb.db.queryengine.plan.statement.sys.pipe; +package org.apache.iotdb.db.queryengine.plan.statement.metadata.pipe; import org.apache.iotdb.commons.path.PartialPath; import org.apache.iotdb.db.queryengine.plan.analyze.QueryType; diff --git a/iotdb-core/datanode/src/test/java/org/apache/iotdb/db/queryengine/plan/plan/statement/sys/pipe/PipeStatementTest.java b/iotdb-core/datanode/src/test/java/org/apache/iotdb/db/queryengine/plan/plan/statement/sys/pipe/PipeStatementTest.java index f3c982ac5d3..dd35996e37e 100644 --- a/iotdb-core/datanode/src/test/java/org/apache/iotdb/db/queryengine/plan/plan/statement/sys/pipe/PipeStatementTest.java +++ b/iotdb-core/datanode/src/test/java/org/apache/iotdb/db/queryengine/plan/plan/statement/sys/pipe/PipeStatementTest.java @@ -21,11 +21,11 @@ package org.apache.iotdb.db.queryengine.plan.plan.statement.sys.pipe; import org.apache.iotdb.db.queryengine.plan.analyze.QueryType; import org.apache.iotdb.db.queryengine.plan.statement.StatementType; -import org.apache.iotdb.db.queryengine.plan.statement.sys.pipe.CreatePipeStatement; -import org.apache.iotdb.db.queryengine.plan.statement.sys.pipe.DropPipeStatement; -import org.apache.iotdb.db.queryengine.plan.statement.sys.pipe.ShowPipesStatement; -import org.apache.iotdb.db.queryengine.plan.statement.sys.pipe.StartPipeStatement; -import org.apache.iotdb.db.queryengine.plan.statement.sys.pipe.StopPipeStatement; +import org.apache.iotdb.db.queryengine.plan.statement.metadata.pipe.CreatePipeStatement; +import org.apache.iotdb.db.queryengine.plan.statement.metadata.pipe.DropPipeStatement; +import org.apache.iotdb.db.queryengine.plan.statement.metadata.pipe.ShowPipesStatement; +import org.apache.iotdb.db.queryengine.plan.statement.metadata.pipe.StartPipeStatement; +import org.apache.iotdb.db.queryengine.plan.statement.metadata.pipe.StopPipeStatement; import org.junit.Assert; import org.junit.Test;
