This is an automated email from the ASF dual-hosted git repository. jackietien pushed a commit to branch ty/useXX in repository https://gitbox.apache.org/repos/asf/iotdb.git
commit c312d332c66b3ec16802c83a59ccad69efe05b61 Merge: b495005747c 373c9607f12 Author: JackieTien97 <[email protected]> AuthorDate: Mon Jul 8 21:21:34 2024 +0800 Merge remote-tracking branch 'origin/ty/TableModelGrammar' into ty/useXX .../java/org/apache/iotdb/rpc/TSStatusCode.java | 3 + .../PipeConfigPhysicalPlanTSStatusVisitor.java | 16 +- .../manager/schema/ClusterSchemaManager.java | 18 +- .../confignode/persistence/schema/ConfigMTree.java | 38 +- .../impl/schema/table/AddTableColumnProcedure.java | 13 +- .../state/schema/AddTableColumnState.java | 4 +- .../metadata/DatabaseAlreadySetException.java | 29 +- ...ception.java => DatabaseConflictException.java} | 26 +- .../legacy/IoTDBLegacyPipeReceiverAgent.java | 104 +- .../impl/DataNodeInternalRPCServiceImpl.java | 7 + .../operator/process/CollectOperator.java | 130 ++ .../schema/source/TableDeviceQuerySource.java | 17 +- .../source/relational/TableScanOperator.java | 4 +- .../plan/analyze/ClusterPartitionFetcher.java | 102 +- .../plan/analyze/IPartitionFetcher.java | 5 +- .../plan/analyze/LoadTsfileAnalyzer.java | 7 +- ...upCacheResult.java => DatabaseCacheResult.java} | 4 +- .../analyze/cache/partition/PartitionCache.java | 465 ++-- .../cache/schema/dualkeycache/IDualKeyCache.java | 13 + .../schema/dualkeycache/impl/DualKeyCacheImpl.java | 37 + .../execution/config/TableConfigTaskVisitor.java | 35 +- .../relational/AlterTableAddColumnTask.java | 3 + .../TableModelStatementMemorySourceVisitor.java | 30 +- .../plan/planner/TableOperatorGenerator.java | 18 + .../plan/planner/plan/node/PlanNode.java | 2 +- .../plan/planner/plan/node/PlanNodeType.java | 4 +- .../plan/planner/plan/node/PlanVisitor.java | 5 + .../node/metedata/read/TableDeviceQueryNode.java | 4 +- .../planner/plan/parameter/SeriesScanOptions.java | 11 + .../PredicatePushIntoMetadataChecker.java | 7 +- .../schema/CheckSchemaPredicateVisitor.java | 35 +- .../ConvertSchemaPredicateToFilterVisitor.java | 19 +- .../plan/relational/metadata/ColumnSchema.java | 1 + .../plan/relational/metadata/Metadata.java | 24 +- .../plan/relational/metadata/MetadataUtil.java | 2 +- .../relational/metadata/TableMetadataImpl.java | 8 +- .../fetcher/DeviceInCacheFilterVisitor.java | 17 +- .../metadata/fetcher/SchemaPredicateUtil.java | 48 +- .../metadata/fetcher/TableDeviceSchemaFetcher.java | 151 +- .../fetcher/TableDeviceSchemaValidator.java | 122 +- .../fetcher/TableHeaderSchemaValidator.java | 177 +- .../fetcher/cache/TableDeviceCacheEntry.java | 25 +- .../metadata/fetcher/cache/TableDeviceId.java | 12 +- .../fetcher/cache/TableDeviceSchemaCache.java | 11 +- .../relational/metadata/fetcher/cache/TableId.java | 16 +- .../plan/relational/planner/LogicalPlanner.java | 33 +- .../plan/relational/planner/RelationPlanner.java | 22 +- .../plan/relational/planner/Symbol.java | 5 + .../planner/distribute/AddExchangeNodes.java | 94 + .../distribute/DistributedPlanGenerator.java | 493 +++++ .../planner/distribute/ExchangeNodeGenerator.java | 219 -- .../planner/distribute/SimplePlanRewriter.java | 44 - .../distribute/TableDistributionPlanner.java | 47 +- .../TableModelTypeProviderExtractor.java | 7 + .../node/{FilterNode.java => CollectNode.java} | 53 +- .../planner/node/CreateTableDeviceNode.java | 47 +- .../plan/relational/planner/node/FilterNode.java | 21 + .../plan/relational/planner/node/LimitNode.java | 22 +- .../relational/planner/node/MergeSortNode.java | 21 + .../plan/relational/planner/node/OffsetNode.java | 20 + .../plan/relational/planner/node/OutputNode.java | 44 +- .../plan/relational/planner/node/ProjectNode.java | 20 + .../plan/relational/planner/node/SortNode.java | 44 +- .../relational/planner/node/StreamSortNode.java | 43 +- .../relational/planner/node/TableScanNode.java | 68 +- .../plan/relational/planner/node/TopKNode.java | 59 +- .../planner/optimizations/PruneUnUsedColumns.java | 16 +- .../optimizations/PushPredicateIntoTableScan.java | 91 +- .../RemoveRedundantIdentityProjections.java | 2 +- .../planner/optimizations/SimplifyExpressions.java | 2 +- ...lPlanOptimizer.java => TablePlanOptimizer.java} | 2 +- .../plan/relational/sql/ast/ShowDevice.java | 6 +- .../attribute/DeviceAttributeStore.java | 28 +- .../mtree/impl/mem/MTreeBelowSGMemoryImpl.java | 4 +- .../read/req/impl/ShowTableDevicesPlan.java | 4 +- .../read/resp/info/impl/ShowDevicesResult.java | 3 +- .../schemaengine/schemaregion/utils/MetaUtils.java | 4 +- .../db/schemaengine/table/DataNodeTableCache.java | 13 + .../iotdb/db/schemaengine/table/ITableCache.java | 5 + .../iotdb/db/service/metrics/CacheMetrics.java | 28 +- .../apache/iotdb/db/metadata/MetaUtilsTest.java | 8 +- .../plan/analyze/cache/PartitionCacheTest.java | 36 +- .../plan/relational/analyzer/AnalyzerTest.java | 197 +- .../analyzer/MockTableModelDataPartition.java | 166 ++ .../relational/analyzer/MockTablePartition.java | 174 -- .../plan/relational/analyzer/SortTest.java | 2251 ++++++++++++++++++++ .../plan/relational/analyzer/TestMatadata.java | 41 +- .../iotdb/commons/partition/DataPartition.java | 17 +- .../executor/SeriesPartitionExecutor.java | 2 + .../partition/executor/hash/APHashExecutor.java | 18 +- .../partition/executor/hash/BKDRHashExecutor.java | 11 +- .../partition/executor/hash/JSHashExecutor.java | 12 +- .../partition/executor/hash/SDBMHashExecutor.java | 12 +- .../apache/iotdb/commons/schema/table/TsTable.java | 90 +- .../table/column/TsTableColumnSchemaUtil.java | 2 +- 95 files changed, 5032 insertions(+), 1468 deletions(-)
