This is an automated email from the ASF dual-hosted git repository. zyk pushed a commit to branch table-model-debug in repository https://gitbox.apache.org/repos/asf/iotdb.git
commit fa7772725fffc300a7f8cd688fb2b0e52c7bd7d8 Merge: 7a1728ce6c9 68c8fc0568b Author: MarcosZyk <[email protected]> AuthorDate: Thu Apr 18 10:19:10 2024 +0800 Merge branch 'ty/TableModelGrammar' into table-model-debug .../iotdb/db/protocol/session/IClientSession.java | 34 +- .../iotdb/db/protocol/session/SessionManager.java | 3 +- .../iotdb/db/queryengine/common/SessionInfo.java | 37 +- .../operator/process/FilterAndProjectOperator.java | 9 + .../source/relational/TableScanOperator.java | 42 +- .../relational/ColumnTransformerBuilder.java | 674 +++++++++++++++++++++ .../queryengine/plan/analyze/PredicateUtils.java | 35 ++ .../db/queryengine/plan/analyze/TypeProvider.java | 12 +- .../plan/planner/LocalExecutionPlanner.java | 14 +- .../plan/planner/TableOperatorGenerator.java | 341 ++++++++++- .../planner/distribution/DistributionPlanner.java | 3 + .../SimpleFragmentParallelPlanner.java | 4 +- .../plan/planner/plan/PlanFragment.java | 5 + .../plan/planner/plan/TableModelTimePredicate.java | 65 ++ .../relational/analyzer/ExpressionAnalyzer.java | 2 +- .../predicate/ConvertPredicateToFilterVisitor.java | 371 ++++++++++++ .../ConvertPredicateToTimeFilterVisitor.java | 218 +++++++ .../predicate/PredicatePushIntoScanChecker.java | 131 ++++ .../analyzer/predicate/PredicateVisitor.java | 87 +++ .../plan/relational/planner/LogicalPlanner.java | 11 +- .../plan/relational/planner/RelationPlanner.java | 22 +- .../relational/planner/RelationalModelPlanner.java | 4 +- .../ExchangeNodeGenerator.java} | 20 +- .../distribute/FragmentInstanceGenerator.java} | 181 ++---- .../distribute/RelationalDistributionPlanner.java | 31 +- .../planner/distribute/SimplePlanRewriter.java | 44 ++ .../planner/distribute/SubPlanGenerator.java | 77 +++ .../TableModelTypeProviderExtractor.java | 64 ++ .../plan/relational/planner/node/LimitNode.java | 4 + .../plan/relational/planner/node/OffsetNode.java | 4 + .../plan/relational/planner/node/ProjectNode.java | 8 + .../relational/planner/node/TableScanNode.java | 16 +- .../planner/optimizations/IndexScan.java | 93 ++- ...Expressions.java => PruneTableScanColumns.java} | 53 +- .../optimizations/RelationalPlanOptimizer.java | 9 +- .../RemoveRedundantIdentityProjections.java | 12 +- .../planner/optimizations/SimplifyExpressions.java | 9 +- .../multi/LogicalAndMultiColumnTransformer.java | 64 ++ .../multi/LogicalMultiColumnTransformer.java | 43 ++ .../multi/LogicalOrMultiColumnTransformer.java | 63 ++ .../dag/column/multi/MultiColumnTransformer.java | 66 ++ .../dag/column/unary/InColumnTransformer.java | 80 +++ .../plan/relational/analyzer/AnalyzerTest.java | 16 +- .../tsfile/read/filter/factory/FilterFactory.java | 18 + 44 files changed, 2896 insertions(+), 203 deletions(-)
