This is an automated email from the ASF dual-hosted git repository.
jiangtian pushed a change to branch TableModelIngestion
in repository https://gitbox.apache.org/repos/asf/iotdb.git
from 7313ad4850c fix getOrCreateSchemaRegion FetchDevice add
insertRelationalRow in MemTable add measurementColumnCnt
add 7070aacfcdf Add table model distributed plan generate rules
add 9af26e74730 Change bug of validateTableHeaderSchema
add 99bc163d83a Fix some bugs in query schema fetch
add ac889ce8dc4 Try previously break if limit has been consumed up in
TableScanOperator
add 373c9607f12 Fixed the bug of auto creating database
add b301184f07a Subscription IT: fix data insertion logic in
SubscriptionConsumerGroupIT (#12863)
add 180e8fb422b Fixed the bug that a table may be concurrently altered and
cause unordered operations on dataNode table cache
new ac19d1d238c Merge branch 'ty/TableModelGrammar' into
TableModelIngestion
The 1 revisions listed above as "new" are entirely new to this
repository and will be described in separate emails. The revisions
listed as "add" were already present in the repository and have only
been added to this reference.
Summary of changes:
.../iotdb/session/it/IoTDBSessionRelationalIT.java | 2 +-
.../it/dual/IoTDBSubscriptionConsumerGroupIT.java | 48 +-
.../java/org/apache/iotdb/rpc/TSStatusCode.java | 3 +
.../iotdb/confignode/manager/ConfigManager.java | 22 +
.../apache/iotdb/confignode/manager/IManager.java | 9 +
.../iotdb/confignode/manager/ProcedureManager.java | 183 +-
.../PipeConfigPhysicalPlanTSStatusVisitor.java | 16 +-
.../manager/schema/ClusterSchemaManager.java | 18 +-
.../confignode/persistence/schema/ConfigMTree.java | 38 +-
.../impl/schema/DeleteDatabaseProcedure.java | 4 +
.../impl/schema/table/AddTableColumnProcedure.java | 13 +-
.../state/schema/AddTableColumnState.java | 4 +-
.../thrift/ConfigNodeRPCServiceProcessor.java | 8 +
.../metadata/DatabaseAlreadySetException.java | 29 +-
...ception.java => DatabaseConflictException.java} | 26 +-
.../legacy/IoTDBLegacyPipeReceiverAgent.java | 104 +-
.../iotdb/db/protocol/client/ConfigNodeClient.java | 17 +
.../iotdb/db/protocol/session/IClientSession.java | 1 +
.../impl/DataNodeInternalRPCServiceImpl.java | 7 +
.../source/relational/TableScanOperator.java | 4 +-
.../plan/analyze/ClusterPartitionFetcher.java | 52 +-
.../plan/analyze/LoadTsfileAnalyzer.java | 7 +-
.../analyze/cache/partition/PartitionCache.java | 50 +-
.../cache/schema/dualkeycache/IDualKeyCache.java | 13 +
.../schema/dualkeycache/impl/DualKeyCacheImpl.java | 37 +
.../plan/analyze/schema/SchemaValidator.java | 5 +-
.../relational/AlterTableAddColumnTask.java | 3 +
.../TableModelStatementMemorySourceVisitor.java | 30 +-
.../plan/planner/LocalExecutionPlanner.java | 13 +-
.../plan/planner/OperatorTreeGenerator.java | 1 +
.../plan/planner/plan/node/PlanNode.java | 2 +-
.../plan/planner/plan/node/PlanNodeType.java | 1 +
.../planner/plan/parameter/SeriesScanOptions.java | 11 +
.../plan/relational/metadata/ColumnSchema.java | 1 +
.../plan/relational/metadata/Metadata.java | 24 +-
.../plan/relational/metadata/MetadataUtil.java | 2 +-
.../relational/metadata/TableMetadataImpl.java | 8 +-
.../metadata/fetcher/TableDeviceSchemaFetcher.java | 114 +-
.../fetcher/TableDeviceSchemaValidator.java | 122 +-
.../fetcher/TableHeaderSchemaValidator.java | 118 +-
.../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 | 35 +-
.../plan/relational/planner/RelationPlanner.java | 22 +-
.../plan/relational/planner/Symbol.java | 5 +
.../planner/distribute/AddExchangeNodes.java | 94 +
.../distribute/DistributedPlanGenerator.java | 495 +++++
.../planner/distribute/ExchangeNodeGenerator.java | 219 --
.../planner/distribute/SimplePlanRewriter.java | 44 -
.../distribute/TableDistributionPlanner.java | 47 +-
.../TableModelTypeProviderExtractor.java | 7 +
.../plan/relational/planner/node/CollectNode.java | 20 +
.../planner/node/CreateTableDeviceNode.java | 50 +-
.../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 | 43 +-
.../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 | 95 +-
.../RemoveRedundantIdentityProjections.java | 2 +-
.../planner/optimizations/SimplifyExpressions.java | 2 +-
...lPlanOptimizer.java => TablePlanOptimizer.java} | 2 +-
.../attribute/DeviceAttributeStore.java | 28 +-
.../mtree/impl/mem/MTreeBelowSGMemoryImpl.java | 4 +-
.../read/resp/info/impl/ShowDevicesResult.java | 3 +-
.../db/schemaengine/table/DataNodeTableCache.java | 13 +
.../iotdb/db/schemaengine/table/ITableCache.java | 5 +
.../org/apache/iotdb/db/utils/CommonUtils.java | 7 +
.../plan/relational/analyzer/AnalyzerTest.java | 189 +-
.../analyzer/MockTableModelDataPartition.java | 166 ++
.../relational/analyzer/MockTablePartition.java | 174 --
.../plan/relational/analyzer/SortTest.java | 2251 ++++++++++++++++++++
.../plan/relational/analyzer/TestMatadata.java | 35 +-
.../iotdb/commons/partition/DataPartition.java | 17 +-
.../apache/iotdb/commons/schema/table/TsTable.java | 90 +-
.../table/column/TsTableColumnSchemaUtil.java | 2 +-
.../src/main/thrift/confignode.thrift | 10 +
85 files changed, 4605 insertions(+), 1139 deletions(-)
copy
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/exception/metadata/{DatabaseAlreadySetException.java
=> DatabaseConflictException.java} (65%)
create mode 100644
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/relational/planner/distribute/AddExchangeNodes.java
create mode 100644
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/relational/planner/distribute/DistributedPlanGenerator.java
delete mode 100644
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/relational/planner/distribute/ExchangeNodeGenerator.java
delete mode 100644
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/relational/planner/distribute/SimplePlanRewriter.java
rename
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/relational/planner/optimizations/{RelationalPlanOptimizer.java
=> TablePlanOptimizer.java} (96%)
create mode 100644
iotdb-core/datanode/src/test/java/org/apache/iotdb/db/queryengine/plan/relational/analyzer/MockTableModelDataPartition.java
delete mode 100644
iotdb-core/datanode/src/test/java/org/apache/iotdb/db/queryengine/plan/relational/analyzer/MockTablePartition.java
create mode 100644
iotdb-core/datanode/src/test/java/org/apache/iotdb/db/queryengine/plan/relational/analyzer/SortTest.java
