This is an automated email from the ASF dual-hosted git repository. hui pushed a commit to branch lmh/LastPointFetch in repository https://gitbox.apache.org/repos/asf/iotdb.git
commit 38dea3256bced94f16b38909fa137101c8635a09 Author: Minghui Liu <[email protected]> AuthorDate: Thu May 26 17:39:18 2022 +0800 add LastPointFetchStatement --- .../src/main/java/org/apache/iotdb/db/mpp/plan/analyze/Analyzer.java | 4 ++-- .../org/apache/iotdb/db/mpp/plan/analyze/ClusterSchemaFetcher.java | 2 +- .../java/org/apache/iotdb/db/mpp/plan/planner/LogicalPlanner.java | 4 ++-- .../java/org/apache/iotdb/db/mpp/plan/statement/StatementVisitor.java | 4 ++-- .../plan/statement/{crud => internal}/LastPointFetchStatement.java | 2 +- .../plan/statement/{metadata => internal}/SchemaFetchStatement.java | 2 +- 6 files changed, 9 insertions(+), 9 deletions(-) diff --git a/server/src/main/java/org/apache/iotdb/db/mpp/plan/analyze/Analyzer.java b/server/src/main/java/org/apache/iotdb/db/mpp/plan/analyze/Analyzer.java index 26d3bcd95c..2e2bca5fbf 100644 --- a/server/src/main/java/org/apache/iotdb/db/mpp/plan/analyze/Analyzer.java +++ b/server/src/main/java/org/apache/iotdb/db/mpp/plan/analyze/Analyzer.java @@ -55,8 +55,9 @@ import org.apache.iotdb.db.mpp.plan.statement.crud.InsertRowsOfOneDeviceStatemen import org.apache.iotdb.db.mpp.plan.statement.crud.InsertRowsStatement; import org.apache.iotdb.db.mpp.plan.statement.crud.InsertStatement; import org.apache.iotdb.db.mpp.plan.statement.crud.InsertTabletStatement; -import org.apache.iotdb.db.mpp.plan.statement.crud.LastPointFetchStatement; import org.apache.iotdb.db.mpp.plan.statement.crud.QueryStatement; +import org.apache.iotdb.db.mpp.plan.statement.internal.LastPointFetchStatement; +import org.apache.iotdb.db.mpp.plan.statement.internal.SchemaFetchStatement; import org.apache.iotdb.db.mpp.plan.statement.literal.Literal; import org.apache.iotdb.db.mpp.plan.statement.metadata.AlterTimeSeriesStatement; import org.apache.iotdb.db.mpp.plan.statement.metadata.CountDevicesStatement; @@ -68,7 +69,6 @@ import org.apache.iotdb.db.mpp.plan.statement.metadata.CreateMultiTimeSeriesStat import org.apache.iotdb.db.mpp.plan.statement.metadata.CreateTimeSeriesByDeviceStatement; import org.apache.iotdb.db.mpp.plan.statement.metadata.CreateTimeSeriesStatement; import org.apache.iotdb.db.mpp.plan.statement.metadata.DeleteTimeSeriesStatement; -import org.apache.iotdb.db.mpp.plan.statement.metadata.SchemaFetchStatement; import org.apache.iotdb.db.mpp.plan.statement.metadata.ShowChildNodesStatement; import org.apache.iotdb.db.mpp.plan.statement.metadata.ShowChildPathsStatement; import org.apache.iotdb.db.mpp.plan.statement.metadata.ShowDevicesStatement; diff --git a/server/src/main/java/org/apache/iotdb/db/mpp/plan/analyze/ClusterSchemaFetcher.java b/server/src/main/java/org/apache/iotdb/db/mpp/plan/analyze/ClusterSchemaFetcher.java index 49b57c79b5..e92d9b0cbe 100644 --- a/server/src/main/java/org/apache/iotdb/db/mpp/plan/analyze/ClusterSchemaFetcher.java +++ b/server/src/main/java/org/apache/iotdb/db/mpp/plan/analyze/ClusterSchemaFetcher.java @@ -32,9 +32,9 @@ import org.apache.iotdb.db.mpp.common.schematree.SchemaTree; import org.apache.iotdb.db.mpp.plan.Coordinator; import org.apache.iotdb.db.mpp.plan.execution.ExecutionResult; import org.apache.iotdb.db.mpp.plan.statement.Statement; +import org.apache.iotdb.db.mpp.plan.statement.internal.SchemaFetchStatement; import org.apache.iotdb.db.mpp.plan.statement.metadata.CreateAlignedTimeSeriesStatement; import org.apache.iotdb.db.mpp.plan.statement.metadata.CreateTimeSeriesByDeviceStatement; -import org.apache.iotdb.db.mpp.plan.statement.metadata.SchemaFetchStatement; import org.apache.iotdb.db.query.control.SessionManager; import org.apache.iotdb.rpc.TSStatusCode; import org.apache.iotdb.tsfile.common.conf.TSFileDescriptor; diff --git a/server/src/main/java/org/apache/iotdb/db/mpp/plan/planner/LogicalPlanner.java b/server/src/main/java/org/apache/iotdb/db/mpp/plan/planner/LogicalPlanner.java index 5423d543bf..20cbd19ae6 100644 --- a/server/src/main/java/org/apache/iotdb/db/mpp/plan/planner/LogicalPlanner.java +++ b/server/src/main/java/org/apache/iotdb/db/mpp/plan/planner/LogicalPlanner.java @@ -45,8 +45,9 @@ import org.apache.iotdb.db.mpp.plan.statement.crud.InsertRowStatement; import org.apache.iotdb.db.mpp.plan.statement.crud.InsertRowsOfOneDeviceStatement; import org.apache.iotdb.db.mpp.plan.statement.crud.InsertRowsStatement; import org.apache.iotdb.db.mpp.plan.statement.crud.InsertTabletStatement; -import org.apache.iotdb.db.mpp.plan.statement.crud.LastPointFetchStatement; import org.apache.iotdb.db.mpp.plan.statement.crud.QueryStatement; +import org.apache.iotdb.db.mpp.plan.statement.internal.LastPointFetchStatement; +import org.apache.iotdb.db.mpp.plan.statement.internal.SchemaFetchStatement; import org.apache.iotdb.db.mpp.plan.statement.metadata.AlterTimeSeriesStatement; import org.apache.iotdb.db.mpp.plan.statement.metadata.CountDevicesStatement; import org.apache.iotdb.db.mpp.plan.statement.metadata.CountLevelTimeSeriesStatement; @@ -56,7 +57,6 @@ import org.apache.iotdb.db.mpp.plan.statement.metadata.CreateMultiTimeSeriesStat import org.apache.iotdb.db.mpp.plan.statement.metadata.CreateTimeSeriesByDeviceStatement; import org.apache.iotdb.db.mpp.plan.statement.metadata.CreateTimeSeriesStatement; import org.apache.iotdb.db.mpp.plan.statement.metadata.DeleteTimeSeriesStatement; -import org.apache.iotdb.db.mpp.plan.statement.metadata.SchemaFetchStatement; import org.apache.iotdb.db.mpp.plan.statement.metadata.ShowChildNodesStatement; import org.apache.iotdb.db.mpp.plan.statement.metadata.ShowChildPathsStatement; import org.apache.iotdb.db.mpp.plan.statement.metadata.ShowDevicesStatement; diff --git a/server/src/main/java/org/apache/iotdb/db/mpp/plan/statement/StatementVisitor.java b/server/src/main/java/org/apache/iotdb/db/mpp/plan/statement/StatementVisitor.java index daf1f44b3f..e279ba9cb5 100644 --- a/server/src/main/java/org/apache/iotdb/db/mpp/plan/statement/StatementVisitor.java +++ b/server/src/main/java/org/apache/iotdb/db/mpp/plan/statement/StatementVisitor.java @@ -25,8 +25,9 @@ import org.apache.iotdb.db.mpp.plan.statement.crud.InsertRowsOfOneDeviceStatemen import org.apache.iotdb.db.mpp.plan.statement.crud.InsertRowsStatement; import org.apache.iotdb.db.mpp.plan.statement.crud.InsertStatement; import org.apache.iotdb.db.mpp.plan.statement.crud.InsertTabletStatement; -import org.apache.iotdb.db.mpp.plan.statement.crud.LastPointFetchStatement; import org.apache.iotdb.db.mpp.plan.statement.crud.QueryStatement; +import org.apache.iotdb.db.mpp.plan.statement.internal.LastPointFetchStatement; +import org.apache.iotdb.db.mpp.plan.statement.internal.SchemaFetchStatement; import org.apache.iotdb.db.mpp.plan.statement.metadata.AlterTimeSeriesStatement; import org.apache.iotdb.db.mpp.plan.statement.metadata.CountDevicesStatement; import org.apache.iotdb.db.mpp.plan.statement.metadata.CountLevelTimeSeriesStatement; @@ -39,7 +40,6 @@ import org.apache.iotdb.db.mpp.plan.statement.metadata.CreateTimeSeriesByDeviceS import org.apache.iotdb.db.mpp.plan.statement.metadata.CreateTimeSeriesStatement; import org.apache.iotdb.db.mpp.plan.statement.metadata.DeleteStorageGroupStatement; import org.apache.iotdb.db.mpp.plan.statement.metadata.DeleteTimeSeriesStatement; -import org.apache.iotdb.db.mpp.plan.statement.metadata.SchemaFetchStatement; import org.apache.iotdb.db.mpp.plan.statement.metadata.SetStorageGroupStatement; import org.apache.iotdb.db.mpp.plan.statement.metadata.SetTTLStatement; import org.apache.iotdb.db.mpp.plan.statement.metadata.ShowChildNodesStatement; diff --git a/server/src/main/java/org/apache/iotdb/db/mpp/plan/statement/crud/LastPointFetchStatement.java b/server/src/main/java/org/apache/iotdb/db/mpp/plan/statement/internal/LastPointFetchStatement.java similarity index 96% rename from server/src/main/java/org/apache/iotdb/db/mpp/plan/statement/crud/LastPointFetchStatement.java rename to server/src/main/java/org/apache/iotdb/db/mpp/plan/statement/internal/LastPointFetchStatement.java index 7a26b042c5..58347a68e4 100644 --- a/server/src/main/java/org/apache/iotdb/db/mpp/plan/statement/crud/LastPointFetchStatement.java +++ b/server/src/main/java/org/apache/iotdb/db/mpp/plan/statement/internal/LastPointFetchStatement.java @@ -17,7 +17,7 @@ * under the License. */ -package org.apache.iotdb.db.mpp.plan.statement.crud; +package org.apache.iotdb.db.mpp.plan.statement.internal; import org.apache.iotdb.commons.path.PartialPath; import org.apache.iotdb.db.metadata.path.MeasurementPath; diff --git a/server/src/main/java/org/apache/iotdb/db/mpp/plan/statement/metadata/SchemaFetchStatement.java b/server/src/main/java/org/apache/iotdb/db/mpp/plan/statement/internal/SchemaFetchStatement.java similarity index 97% rename from server/src/main/java/org/apache/iotdb/db/mpp/plan/statement/metadata/SchemaFetchStatement.java rename to server/src/main/java/org/apache/iotdb/db/mpp/plan/statement/internal/SchemaFetchStatement.java index f8c1bbbe70..9ab133be35 100644 --- a/server/src/main/java/org/apache/iotdb/db/mpp/plan/statement/metadata/SchemaFetchStatement.java +++ b/server/src/main/java/org/apache/iotdb/db/mpp/plan/statement/internal/SchemaFetchStatement.java @@ -17,7 +17,7 @@ * under the License. */ -package org.apache.iotdb.db.mpp.plan.statement.metadata; +package org.apache.iotdb.db.mpp.plan.statement.internal; import org.apache.iotdb.commons.partition.SchemaPartition; import org.apache.iotdb.commons.path.PartialPath;
