This is an automated email from the ASF dual-hosted git repository.
rong pushed a change to branch pipe-wal-resource-management
in repository https://gitbox.apache.org/repos/asf/iotdb.git
from 6dbf75842bc fix
add ea3badc24e8 [IOTDB-5915] Adjust the granularity of data migration
example from timeseries to device (#9916)
add a285d428208 Support Delete/Drop Logical View (#9938)
add 3bc6457a5f1 [IOTDB-5919] show variables add a variable
timestamp_precision (#9946)
add a856f55f96a Merge branch 'master' of github.com:apache/iotdb into
pipe-wal-resource-management
No new revisions were added by this update.
Summary of changes:
.../org/apache/iotdb/db/qp/sql/IoTDBSqlParser.g4 | 6 +-
.../confignode/client/DataNodeRequestType.java | 5 +
.../client/async/AsyncDataNodeClientPool.java | 21 +++
.../client/async/handlers/AsyncClientHandler.java | 3 +
.../iotdb/confignode/manager/ConfigManager.java | 11 ++
.../apache/iotdb/confignode/manager/IManager.java | 3 +
.../iotdb/confignode/manager/ProcedureManager.java | 47 +++++++
...cedure.java => DeleteLogicalViewProcedure.java} | 155 +++++++--------------
...plateState.java => DeleteLogicalViewState.java} | 5 +-
.../procedure/store/ProcedureFactory.java | 6 +
.../confignode/procedure/store/ProcedureType.java | 5 +-
.../thrift/ConfigNodeRPCServiceProcessor.java | 6 +
example/session/pom.xml | 6 +
.../org/apache/iotdb/DataMigrationExample.java | 142 ++++++++++---------
.../confignode/it/utils/ConfigNodeTestUtils.java | 1 +
.../org/apache/iotdb/isession/SessionDataSet.java | 8 ++
.../src/main/thrift/confignode.thrift | 7 +
.../thrift/src/main/thrift/datanode.thrift | 21 +++
.../apache/iotdb/db/client/ConfigNodeClient.java | 22 +++
.../db/metadata/mtree/MTreeBelowSGMemoryImpl.java | 54 +++++++
.../plan/schemaregion/SchemaRegionPlanType.java | 3 +
.../plan/schemaregion/SchemaRegionPlanVisitor.java | 17 +++
.../impl/SchemaRegionPlanDeserializer.java | 25 ++++
.../impl/SchemaRegionPlanSerializer.java | 37 +++++
.../impl/SchemaRegionPlanTxtSerializer.java | 25 ++++
...lanImpl.java => DeleteLogicalViewPlanImpl.java} | 8 +-
...Impl.java => PreDeleteLogicalViewPlanImpl.java} | 8 +-
...a => RollbackPreDeleteLogicalViewPlanImpl.java} | 8 +-
.../impl/write/SchemaRegionWritePlanFactory.java | 29 ++++
.../IDeleteLogicalViewPlan.java} | 8 +-
.../IPreDeleteLogicalViewPlan.java} | 8 +-
.../IRollbackPreDeleteLogicalViewPlan.java} | 8 +-
.../db/metadata/schemaregion/ISchemaRegion.java | 7 +
.../schemaregion/SchemaRegionMemoryImpl.java | 85 +++++++++++
.../schemaregion/SchemaRegionSchemaFileImpl.java | 15 ++
.../metadata/visitor/SchemaExecutionVisitor.java | 44 +++++-
.../execution/executor/RegionWriteExecutor.java | 2 +-
.../iotdb/db/mpp/plan/analyze/AnalyzeVisitor.java | 8 +-
.../plan/execution/config/ConfigTaskVisitor.java | 8 ++
.../config/executor/ClusterConfigTaskExecutor.java | 43 ++++++
.../config/executor/IConfigTaskExecutor.java | 4 +
.../DeleteLogicalViewTask.java} | 17 +--
.../iotdb/db/mpp/plan/parser/ASTVisitor.java | 14 +-
.../db/mpp/plan/planner/LogicalPlanVisitor.java | 4 +-
.../mpp/plan/planner/plan/node/PlanNodeType.java | 16 ++-
.../db/mpp/plan/planner/plan/node/PlanVisitor.java | 25 +++-
.../ConstructLogicalViewBlackListNode.java} | 18 +--
.../write/{ => view}/CreateLogicalViewNode.java | 2 +-
.../DeleteLogicalViewNode.java} | 20 +--
.../RollbackLogicalViewBlackListNode.java} | 20 +--
.../iotdb/db/mpp/plan/statement/StatementType.java | 1 +
.../db/mpp/plan/statement/StatementVisitor.java | 8 +-
.../{ => view}/CreateLogicalViewStatement.java | 2 +-
.../DeleteLogicalViewStatement.java} | 13 +-
.../impl/DataNodeInternalRPCServiceImpl.java | 91 ++++++++++++
55 files changed, 920 insertions(+), 265 deletions(-)
copy
confignode/src/main/java/org/apache/iotdb/confignode/procedure/impl/schema/{DeleteTimeSeriesProcedure.java
=> DeleteLogicalViewProcedure.java} (68%)
copy
confignode/src/main/java/org/apache/iotdb/confignode/procedure/state/schema/{DeactivateTemplateState.java
=> DeleteLogicalViewState.java} (92%)
copy
server/src/main/java/org/apache/iotdb/db/metadata/plan/schemaregion/impl/write/{PreDeleteTimeSeriesPlanImpl.java
=> DeleteLogicalViewPlanImpl.java} (81%)
copy
server/src/main/java/org/apache/iotdb/db/metadata/plan/schemaregion/impl/write/{AutoCreateDeviceMNodePlanImpl.java
=> PreDeleteLogicalViewPlanImpl.java} (81%)
copy
server/src/main/java/org/apache/iotdb/db/metadata/plan/schemaregion/impl/write/{AutoCreateDeviceMNodePlanImpl.java
=> RollbackPreDeleteLogicalViewPlanImpl.java} (79%)
copy
server/src/main/java/org/apache/iotdb/db/metadata/plan/schemaregion/write/{IAutoCreateDeviceMNodePlan.java
=> view/IDeleteLogicalViewPlan.java} (83%)
copy
server/src/main/java/org/apache/iotdb/db/metadata/plan/schemaregion/write/{IAutoCreateDeviceMNodePlan.java
=> view/IPreDeleteLogicalViewPlan.java} (83%)
copy
server/src/main/java/org/apache/iotdb/db/metadata/plan/schemaregion/write/{IPreDeleteTimeSeriesPlan.java
=> view/IRollbackPreDeleteLogicalViewPlan.java} (82%)
copy
server/src/main/java/org/apache/iotdb/db/mpp/plan/execution/config/metadata/{template/SetSchemaTemplateTask.java
=> view/DeleteLogicalViewTask.java} (70%)
copy
server/src/main/java/org/apache/iotdb/db/mpp/plan/planner/plan/node/metedata/write/{ConstructSchemaBlackListNode.java
=> view/ConstructLogicalViewBlackListNode.java} (79%)
rename
server/src/main/java/org/apache/iotdb/db/mpp/plan/planner/plan/node/metedata/write/{
=> view}/CreateLogicalViewNode.java (99%)
copy
server/src/main/java/org/apache/iotdb/db/mpp/plan/planner/plan/node/metedata/write/{RollbackSchemaBlackListNode.java
=> view/DeleteLogicalViewNode.java} (78%)
copy
server/src/main/java/org/apache/iotdb/db/mpp/plan/planner/plan/node/metedata/write/{ConstructSchemaBlackListNode.java
=> view/RollbackLogicalViewBlackListNode.java} (77%)
rename server/src/main/java/org/apache/iotdb/db/mpp/plan/statement/metadata/{
=> view}/CreateLogicalViewStatement.java (99%)
copy
server/src/main/java/org/apache/iotdb/db/mpp/plan/statement/metadata/{DeleteTimeSeriesStatement.java
=> view/DeleteLogicalViewStatement.java} (82%)
