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 5a9a23ed834 delete show device
add 8557956cdf0 set up TableDeviceSchemaCache
add c1dac7f259e set up validate schema
add 9c47034465a implement schema fetch and auto create
No new revisions were added by this update.
Summary of changes:
.../iotdb/confignode/conf/ConfigNodeConfig.java | 2 +-
.../schema/source/SchemaSourceFactory.java | 8 +
...hemaSource.java => TableDeviceFetchSource.java} | 110 ++--------
.../queryengine/plan/analyze/AnalyzeVisitor.java | 32 ++-
.../plan/planner/LogicalPlanBuilder.java | 19 +-
.../plan/planner/LogicalPlanVisitor.java | 43 +++-
.../plan/planner/OperatorTreeGenerator.java | 23 ++-
.../planner/distribution/ExchangeNodeAdder.java | 8 +-
.../plan/planner/plan/node/PlanNodeType.java | 7 +-
.../plan/planner/plan/node/PlanVisitor.java | 7 +-
.../TableDeviceFetchNode.java} | 123 ++++++-----
.../read/{ => table}/TableDeviceScanNode.java | 22 +-
.../analyzer/schema/TableModelSchemaFetcher.java | 226 ++++++++++++++++++++-
.../analyzer/schema/TableModelSchemaValidator.java | 3 +
.../schema/cache/CacheMemoryControlUtil.java | 9 +
.../schema/cache/TableDeviceCacheEntry.java | 58 ++++++
.../analyzer/schema/cache/TableDeviceId.java} | 41 ++--
.../schema/cache/TableDeviceSchemaCache.java | 77 +++++++
.../relational/analyzer/schema/cache/TableId.java} | 41 ++--
.../plan/statement/StatementVisitor.java | 9 +-
.../CreateTableDeviceStatement.java | 2 +-
.../FetchTableDevicesStatement.java} | 35 ++--
.../ShowTableDevicesStatement.java | 3 +-
.../schemaengine/schemaregion/ISchemaRegion.java | 3 +
.../schemaregion/impl/SchemaRegionMemoryImpl.java | 86 ++++++++
.../schemaregion/impl/SchemaRegionPBTreeImpl.java | 7 +
.../schema/filter/impl/DeviceFilterToPathUtil.java | 16 ++
27 files changed, 784 insertions(+), 236 deletions(-)
copy
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/execution/operator/schema/source/{TableDeviceSchemaSource.java
=> TableDeviceFetchSource.java} (55%)
copy
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/planner/plan/node/metedata/read/{TableDeviceScanNode.java
=> table/TableDeviceFetchNode.java} (60%)
rename
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/planner/plan/node/metedata/read/{
=> table}/TableDeviceScanNode.java (87%)
create mode 100644
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/relational/analyzer/schema/TableModelSchemaValidator.java
create mode 100644
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/relational/analyzer/schema/cache/CacheMemoryControlUtil.java
create mode 100644
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/relational/analyzer/schema/cache/TableDeviceCacheEntry.java
copy
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/{schemaengine/schemaregion/read/resp/info/impl/ShowNodesResult.java
=> queryengine/plan/relational/analyzer/schema/cache/TableDeviceId.java} (51%)
create mode 100644
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/relational/analyzer/schema/cache/TableDeviceSchemaCache.java
copy
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/{schemaengine/schemaregion/read/resp/info/impl/ShowNodesResult.java
=> queryengine/plan/relational/analyzer/schema/cache/TableId.java} (52%)
rename
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/statement/{internal
=> table}/CreateTableDeviceStatement.java (97%)
copy
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/statement/{sys/MergeStatement.java
=> table/FetchTableDevicesStatement.java} (63%)
rename
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/statement/{metadata
=> table}/ShowTableDevicesStatement.java (93%)