This is an automated email from the ASF dual-hosted git repository.
jackietien pushed a change to branch ty/useXX
in repository https://gitbox.apache.org/repos/asf/iotdb.git
from 5c0720e57b5 Add IPooledSession and TableModelJDBCExample
new b495005747c Fix IoTDBConnection bug and add TableModelSessionExample
add 661f436a47a Support auto create table (#12841)
add 751420c9eb9 Add collect node for table model (#12845)
add a472f9d12c1 Add license for code
add 00100faf4b4 Implement new ClusterPartitionFetcher interface
add b17c09c2b79 Support CollectOperator and fix some bugs, add some
comments for Table Schema Fetcher
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
new c312d332c66 Merge remote-tracking branch 'origin/ty/TableModelGrammar'
into ty/useXX
The 2 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:
.../org/apache/iotdb/TableModelJDBCExample.java | 17 +-
.../org/apache/iotdb/TableModelSessionExample.java | 136 ++
.../apache/iotdb/jdbc/IoTDBConnectionParams.java | 2 +-
.../src/main/java/org/apache/iotdb/jdbc/Utils.java | 10 +-
.../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 +
.../CollectOperator.java} | 66 +-
.../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 +-
99 files changed, 5099 insertions(+), 1502 deletions(-)
create mode 100644
example/session/src/main/java/org/apache/iotdb/TableModelSessionExample.java
copy
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/exception/metadata/{DatabaseAlreadySetException.java
=> DatabaseConflictException.java} (65%)
copy
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/execution/operator/{schema/SchemaQueryMergeOperator.java
=> process/CollectOperator.java} (68%)
rename
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/analyze/cache/partition/{StorageGroupCacheResult.java
=> DatabaseCacheResult.java} (94%)
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
copy
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/relational/planner/node/{FilterNode.java
=> CollectNode.java} (65%)
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
