You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@iotdb.apache.org by zy...@apache.org on 2022/10/29 01:28:50 UTC
[iotdb] branch master updated (fb60f603fa -> 4800c36e01)
This is an automated email from the ASF dual-hosted git repository.
zyk pushed a change to branch master
in repository https://gitbox.apache.org/repos/asf/iotdb.git
from fb60f603fa [IOTDB-4790] Make error message of ASTVisitor more specific (#7781)
add 4800c36e01 [IOTDB-3562] Support Unset Template in cluster (#7735)
No new revisions were added by this update.
Summary of changes:
.../confignode/client/DataNodeRequestType.java | 3 +-
.../client/async/AsyncDataNodeClientPool.java | 13 +
.../client/async/handlers/AsyncClientHandler.java | 11 +
...java => CountPathsUsingTemplateRPCHandler.java} | 28 +-
.../consensus/request/ConfigPhysicalPlan.java | 12 +
.../consensus/request/ConfigPhysicalPlanType.java | 5 +-
...tePlan.java => PreUnsetSchemaTemplatePlan.java} | 34 +-
...ava => RollbackPreUnsetSchemaTemplatePlan.java} | 34 +-
...platePlan.java => UnsetSchemaTemplatePlan.java} | 34 +-
.../confignode/manager/ClusterSchemaManager.java | 85 +++-
.../iotdb/confignode/manager/ConfigManager.java | 22 ++
.../apache/iotdb/confignode/manager/IManager.java | 4 +
.../iotdb/confignode/manager/ProcedureManager.java | 45 +++
.../persistence/executor/ConfigPlanExecutor.java | 10 +
.../persistence/schema/ClusterSchemaInfo.java | 64 +++-
.../impl/schema/UnsetTemplateProcedure.java | 426 +++++++++++++++++++++
...eTemplateState.java => UnsetTemplateState.java} | 8 +-
.../procedure/store/ProcedureFactory.java | 9 +-
.../thrift/ConfigNodeRPCServiceProcessor.java | 6 +
.../request/ConfigPhysicalPlanSerDeTest.java | 33 ++
...reTest.java => UnsetTemplateProcedureTest.java} | 48 +--
.../iotdb/db/it/schema/IoTDBSchemaTemplateIT.java | 49 ++-
.../schemaregion/rocksdb/RSchemaRegion.java | 6 +
.../schemaregion/rocksdb/mnode/RMNode.java | 20 +
.../metadata/tagSchemaRegion/TagSchemaRegion.java | 6 +
.../apache/iotdb/db/client/ConfigNodeClient.java | 17 +
.../idtable/entry/InsertMeasurementMNode.java | 20 +
.../org/apache/iotdb/db/metadata/mnode/IMNode.java | 8 +
.../iotdb/db/metadata/mnode/InternalMNode.java | 37 +-
.../iotdb/db/metadata/mnode/MeasurementMNode.java | 14 +
.../iotdb/db/metadata/mtree/ConfigMTree.java | 36 +-
.../db/metadata/mtree/MTreeBelowSGMemoryImpl.java | 23 ++
.../db/metadata/schemaregion/ISchemaRegion.java | 2 +
.../schemaregion/SchemaRegionMemoryImpl.java | 10 +
.../schemaregion/SchemaRegionSchemaFileImpl.java | 6 +
.../metadata/template/ClusterTemplateManager.java | 28 +-
.../metadata/template/TemplateInternalRPCUtil.java | 99 +++++
.../execution/executor/RegionWriteExecutor.java | 31 ++
.../plan/execution/config/ConfigTaskVisitor.java | 8 +
.../config/executor/ClusterConfigTaskExecutor.java | 47 ++-
.../config/executor/IConfigTaskExecutor.java | 4 +
.../executor/StandaloneConfigTaskExecutor.java | 12 +
...plateTask.java => UnsetSchemaTemplateTask.java} | 10 +-
.../iotdb/db/mpp/plan/parser/ASTVisitor.java | 8 +
.../db/mpp/plan/statement/StatementVisitor.java | 6 +
...ment.java => UnsetSchemaTemplateStatement.java} | 18 +-
.../impl/DataNodeInternalRPCServiceImpl.java | 37 ++
.../iotdb/db/metadata/mtree/ConfigMTreeTest.java | 2 +-
.../src/main/thrift/confignode.thrift | 8 +
thrift/src/main/thrift/datanode.thrift | 13 +
50 files changed, 1330 insertions(+), 189 deletions(-)
copy confignode/src/main/java/org/apache/iotdb/confignode/client/async/handlers/rpc/{FetchSchemaBlackListRPCHandler.java => CountPathsUsingTemplateRPCHandler.java} (72%)
copy confignode/src/main/java/org/apache/iotdb/confignode/consensus/request/write/template/{SetSchemaTemplatePlan.java => PreUnsetSchemaTemplatePlan.java} (62%)
copy confignode/src/main/java/org/apache/iotdb/confignode/consensus/request/write/template/{SetSchemaTemplatePlan.java => RollbackPreUnsetSchemaTemplatePlan.java} (61%)
copy confignode/src/main/java/org/apache/iotdb/confignode/consensus/request/write/template/{SetSchemaTemplatePlan.java => UnsetSchemaTemplatePlan.java} (63%)
create mode 100644 confignode/src/main/java/org/apache/iotdb/confignode/procedure/impl/schema/UnsetTemplateProcedure.java
copy confignode/src/main/java/org/apache/iotdb/confignode/procedure/state/schema/{DeactivateTemplateState.java => UnsetTemplateState.java} (87%)
copy confignode/src/test/java/org/apache/iotdb/confignode/procedure/impl/{DeactivateTemplateProcedureTest.java => UnsetTemplateProcedureTest.java} (61%)
create mode 100644 server/src/main/java/org/apache/iotdb/db/metadata/template/TemplateInternalRPCUtil.java
copy server/src/main/java/org/apache/iotdb/db/mpp/plan/execution/config/metadata/template/{DeactivateSchemaTemplateTask.java => UnsetSchemaTemplateTask.java} (82%)
copy server/src/main/java/org/apache/iotdb/db/mpp/plan/statement/metadata/template/{SetSchemaTemplateStatement.java => UnsetSchemaTemplateStatement.java} (85%)