This is an automated email from the ASF dual-hosted git repository.
zyk pushed a change to branch table-model-debug
in repository https://gitbox.apache.org/repos/asf/iotdb.git
from 1b5f92328f5 implement is null
add 987f06f0338 set up table validate
add 66fc5f46d70 implement drop table
No new revisions were added by this update.
Summary of changes:
.../consensus/request/ConfigPhysicalPlan.java | 12 +
.../consensus/request/ConfigPhysicalPlanType.java | 3 +
...eateTablePlan.java => CommitDropTablePlan.java} | 10 +-
...tCreateTablePlan.java => PreDropTablePlan.java} | 10 +-
...teTablePlan.java => RollbackDropTablePlan.java} | 10 +-
.../iotdb/confignode/manager/ConfigManager.java | 10 +
.../iotdb/confignode/manager/ProcedureManager.java | 44 +++
.../manager/schema/ClusterSchemaManager.java | 5 +
.../persistence/executor/ConfigPlanExecutor.java | 9 +
.../persistence/schema/ClusterSchemaInfo.java | 57 +++
.../confignode/persistence/schema/ConfigMTree.java | 49 +++
.../impl/schema/table/DropTableProcedure.java | 415 +++++++++++++++++++++
...eStorageGroupState.java => DropTableState.java} | 7 +-
.../procedure/store/ProcedureFactory.java | 6 +
.../confignode/procedure/store/ProcedureType.java | 1 +
.../thrift/ConfigNodeRPCServiceProcessor.java | 6 +
.../schemaregion/SchemaExecutionVisitor.java | 12 +
.../iotdb/db/protocol/client/ConfigNodeClient.java | 7 +
.../impl/DataNodeInternalRPCServiceImpl.java | 73 ++++
.../queryengine/plan/analyze/AnalyzeVisitor.java | 22 +-
.../execution/config/TableConfigTaskVisitor.java | 12 +-
.../config/executor/ClusterConfigTaskExecutor.java | 36 ++
.../config/executor/IConfigTaskExecutor.java | 2 +
.../{CreateTableTask.java => DropTableTask.java} | 17 +-
.../plan/planner/plan/node/PlanNodeType.java | 6 +-
.../plan/planner/plan/node/PlanVisitor.java | 5 +
...ackListNode.java => DeleteTableDeviceNode.java} | 54 ++-
.../analyzer/schema/TableModelSchemaFetcher.java | 106 ++++++
.../plan/statement/crud/InsertTableStatement.java | 55 ++-
.../schemaengine/schemaregion/ISchemaRegion.java | 2 +
.../schemaregion/impl/SchemaRegionMemoryImpl.java | 5 +
.../schemaregion/impl/SchemaRegionPBTreeImpl.java | 5 +
.../mtree/impl/mem/MTreeBelowSGMemoryImpl.java | 4 +
.../db/schemaengine/table/DataNodeTableCache.java | 34 ++
.../iotdb/db/schemaengine/table/ITableCache.java | 4 +
.../schema/table/TsTableInternalRPCType.java | 12 +-
.../src/main/thrift/confignode.thrift | 11 +
37 files changed, 1064 insertions(+), 74 deletions(-)
copy
iotdb-core/confignode/src/main/java/org/apache/iotdb/confignode/consensus/request/write/table/{CommitCreateTablePlan.java
=> CommitDropTablePlan.java} (87%)
copy
iotdb-core/confignode/src/main/java/org/apache/iotdb/confignode/consensus/request/write/table/{CommitCreateTablePlan.java
=> PreDropTablePlan.java} (87%)
copy
iotdb-core/confignode/src/main/java/org/apache/iotdb/confignode/consensus/request/write/table/{CommitCreateTablePlan.java
=> RollbackDropTablePlan.java} (87%)
create mode 100644
iotdb-core/confignode/src/main/java/org/apache/iotdb/confignode/procedure/impl/schema/table/DropTableProcedure.java
copy
iotdb-core/confignode/src/main/java/org/apache/iotdb/confignode/procedure/state/schema/{DeleteStorageGroupState.java
=> DropTableState.java} (91%)
copy
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/execution/config/metadata/relational/{CreateTableTask.java
=> DropTableTask.java} (78%)
copy
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/planner/plan/node/metedata/write/{RollbackSchemaBlackListNode.java
=> DeleteTableDeviceNode.java} (63%)
