This is an automated email from the ASF dual-hosted git repository.
shuwenwei pushed a change to branch calc_commons
in repository https://gitbox.apache.org/repos/asf/iotdb.git
from dd1cf550bd2 refactor: add IPlanVisitor
new 85a66124ec6 refactor TableOperatorGenerator
new 35344fd9abc move some plannodes
new 604a7475e64 move rowpattern
new 41fe4087b42 add IAstVisitor
The 4 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:
.../plan/planner/TableOperatorGenerator.java | 2163 +-------------------
.../dataregion/DataExecutionVisitor.java | 2 +-
.../schemaregion/SchemaExecutionVisitor.java | 2 +-
.../planner/plan/node/ICoreQueryPlanVisitor.java | 233 +++
.../plan/planner/plan/node/IPlanVisitor.java | 4 +
.../plan/planner/plan/node/IQueryPlanVisitor.java | 812 --------
.../plan/node/process/MultiChildProcessNode.java | 2 +-
.../planner/plan/node/process/ProcessNode.java | 2 +-
.../plan/node/process/SingleChildProcessNode.java | 2 +-
.../plan/relational/planner/Symbol.java | 4 +-
.../relational/planner/node/AggregationNode.java | 14 +-
.../relational/planner/node/AssignUniqueId.java | 10 +-
.../plan/relational/planner/node/CollectNode.java | 10 +-
.../planner/node/EnforceSingleRowNode.java | 10 +-
.../plan/relational/planner/node/FillNode.java | 10 +-
.../plan/relational/planner/node/FilterNode.java | 12 +-
.../plan/relational/planner/node/GapFillNode.java | 10 +-
.../plan/relational/planner/node/GroupNode.java | 6 +-
.../plan/relational/planner/node/JoinNode.java | 14 +-
.../plan/relational/planner/node/LimitNode.java | 10 +-
.../relational/planner/node/LinearFillNode.java | 8 +-
.../relational/planner/node/MarkDistinctNode.java | 10 +-
.../plan/relational/planner/node/Measure.java | 4 +-
.../relational/planner/node/MergeSortNode.java | 10 +-
.../plan/relational/planner/node/OffsetNode.java | 10 +-
.../plan/relational/planner/node/OutputNode.java | 10 +-
.../planner/node/PatternRecognitionNode.java | 18 +-
.../relational/planner/node/PreviousFillNode.java | 8 +-
.../plan/relational/planner/node/ProjectNode.java | 12 +-
.../relational/planner/node/RowNumberNode.java | 10 +-
.../plan/relational/planner/node/SemiJoinNode.java | 8 +-
.../plan/relational/planner/node/SortNode.java | 10 +-
.../relational/planner/node/StreamSortNode.java | 6 +-
.../relational/planner/node/TableFunctionNode.java | 10 +-
.../planner/node/TableFunctionProcessorNode.java | 10 +-
.../plan/relational/planner/node/TopKNode.java | 10 +-
.../relational/planner/node/TopKRankingNode.java | 10 +-
.../plan/relational/planner/node/UnionNode.java | 9 +-
.../relational/planner/node/ValueFillNode.java | 8 +-
.../plan/relational/planner/node/ValuesNode.java | 10 +-
.../plan/relational/planner/node/WindowNode.java | 12 +-
.../rowpattern/AggregationLabelSet.java | 2 +-
.../rowpattern/AggregationValuePointer.java | 6 +-
.../rowpattern/ClassifierValuePointer.java | 2 +-
.../rowpattern/ExpressionAndValuePointers.java | 6 +-
.../rowpattern}/rowpattern/IrAlternation.java | 2 +-
.../planner/rowpattern}/rowpattern/IrAnchor.java | 4 +-
.../rowpattern}/rowpattern/IrConcatenation.java | 2 +-
.../planner/rowpattern}/rowpattern/IrEmpty.java | 2 +-
.../rowpattern}/rowpattern/IrExclusion.java | 2 +-
.../planner/rowpattern}/rowpattern/IrLabel.java | 2 +-
.../rowpattern/IrPatternAlternationOptimizer.java | 4 +-
.../rowpattern}/rowpattern/IrPermutation.java | 2 +-
.../rowpattern}/rowpattern/IrQuantified.java | 2 +-
.../rowpattern}/rowpattern/IrQuantifier.java | 2 +-
.../rowpattern}/rowpattern/IrRowPattern.java | 2 +-
.../rowpattern/IrRowPatternFlattener.java | 2 +-
.../rowpattern/IrRowPatternVisitor.java | 2 +-
.../rowpattern/LogicalIndexPointer.java | 2 +-
.../rowpattern/MatchNumberValuePointer.java | 2 +-
.../planner/rowpattern}/rowpattern/Patterns.java | 12 +-
.../rowpattern/RowPatternToIrRewriter.java | 12 +-
.../rowpattern}/rowpattern/ScalarValuePointer.java | 4 +-
.../rowpattern}/rowpattern/ValuePointer.java | 2 +-
.../relational/sql/ast/CommonQueryAstVisitor.java} | 28 +-
.../plan/relational/sql/ast/Expression.java | 47 +-
.../plan/relational/sql/ast/IAstVisitor.java} | 4 +-
.../plan/relational/sql/ast/Node.java | 14 +-
.../relational/sql/ast/StackableAstVisitor.java | 4 +-
.../visitor/PipePlanToStatementVisitor.java | 2 +-
.../schemaregion/IoTDBSchemaRegionSource.java | 2 +-
.../PipePlanTablePatternParseVisitor.java | 2 +-
.../PipePlanTablePrivilegeParseVisitor.java | 2 +-
.../PipePlanTreePatternParseVisitor.java | 2 +-
.../PipePlanTreePrivilegeParseVisitor.java | 2 +-
.../PipeTableStatementToPlanVisitor.java | 2 +-
.../queryengine/common/header/DatasetHeader.java | 4 +-
.../execution/executor/RegionWriteExecutor.java | 80 +-
.../operator/process/copyto/CopyToOptions.java | 2 +-
.../process/copyto/tsfile/CopyToTsFileOptions.java | 2 +-
.../process/rowpattern/expression/Computation.java | 6 +-
.../matcher/IrRowPatternToProgramRewriter.java | 22 +-
.../process/window/TopKRankingOperator.java | 2 +-
.../relational/AbstractAggTableScanOperator.java | 2 +-
.../InformationSchemaContentSupplierFactory.java | 2 +-
.../relational/aggregation/AccumulatorFactory.java | 2 +-
.../relational/aggregation/TableAggregator.java | 2 +-
.../aggregation/grouped/GroupedAggregator.java | 2 +-
.../grouped/HashAggregationOperator.java | 2 +-
.../grouped/StreamingHashAggregationOperator.java | 2 +-
.../builder/InMemoryHashAggregationBuilder.java | 2 +-
.../relational/ColumnTransformerBuilder.java | 4 +-
.../iotdb/db/queryengine/plan/Coordinator.java | 2 +-
.../db/queryengine/plan/analyze/AnalyzeUtils.java | 2 +-
.../queryengine/plan/analyze/PredicateUtils.java | 8 +-
.../db/queryengine/plan/analyze/TypeProvider.java | 2 +-
.../execution/config/TableConfigTaskVisitor.java | 4 +-
.../TableModelStatementMemorySourceVisitor.java | 2 +-
.../plan/optimization/AggregationPushDown.java | 6 +-
.../plan/optimization/ColumnInjectionPushDown.java | 6 +-
.../plan/optimization/LimitOffsetPushDown.java | 4 +-
.../OrderByExpressionWithLimitChangeToTopK.java | 6 +-
.../plan/optimization/PredicatePushDown.java | 6 +-
.../db/queryengine/plan/parser/ASTVisitor.java | 4 +-
.../planner/DataNodeTableOperatorGenerator.java | 2103 +++++++++++++++++++
.../plan/planner/LocalExecutionPlanner.java | 2 +-
.../plan/planner/LogicalPlanBuilder.java | 2 +-
.../plan/planner/OperatorTreeGenerator.java | 4 +-
.../planner/distribution/ExchangeNodeAdder.java | 4 +-
.../plan/planner/distribution/SourceRewriter.java | 2 +-
.../plan/planner/plan/TableModelTimePredicate.java | 2 +-
.../plan/planner/plan/TimePredicate.java | 2 +-
.../plan/planner/plan/node/BaseSourceRewriter.java | 2 +-
.../plan/planner/plan/node/ExplainAnalyzeNode.java | 5 +-
.../plan/planner/plan/node/PlanGraphPrinter.java | 73 +-
.../plan/planner/plan/node/PlanNode.java | 2 +-
.../plan/planner/plan/node/PlanNodeType.java | 70 +-
.../plan/planner/plan/node/PlanVisitor.java | 625 +++++-
.../plan/planner/plan/node/SimplePlanVisitor.java | 2 +-
.../metadata/read/AbstractSchemaMergeNode.java | 2 +-
.../node/metadata/read/CountSchemaMergeNode.java | 4 +-
.../metadata/read/DeviceSchemaFetchScanNode.java | 4 +-
.../read/NodeManagementMemoryMergeNode.java | 6 +-
.../node/metadata/read/NodePathsConvertNode.java | 6 +-
.../node/metadata/read/NodePathsCountNode.java | 6 +-
.../node/metadata/read/SchemaFetchMergeNode.java | 4 +-
.../node/metadata/read/SchemaQueryMergeNode.java | 4 +-
.../metadata/read/SchemaQueryOrderByHeatNode.java | 6 +-
.../node/metadata/read/SchemaQueryScanNode.java | 4 +-
.../metadata/read/SeriesSchemaFetchScanNode.java | 4 +-
.../node/metadata/read/TableDeviceSourceNode.java | 2 +-
.../node/metadata/write/ActivateTemplateNode.java | 4 +-
.../write/AlterEncodingCompressorNode.java | 4 +-
.../metadata/write/BatchActivateTemplateNode.java | 4 +-
.../write/ConstructSchemaBlackListNode.java | 4 +-
.../node/metadata/write/CreateTimeSeriesNode.java | 4 +-
.../metadata/write/DeactivateTemplateNode.java | 4 +-
.../node/metadata/write/DeleteTimeSeriesNode.java | 4 +-
.../write/InternalBatchActivateTemplateNode.java | 4 +-
.../write/InternalCreateMultiTimeSeriesNode.java | 4 +-
.../write/InternalCreateTimeSeriesNode.java | 4 +-
.../metadata/write/PreDeactivateTemplateNode.java | 4 +-
.../write/RollbackPreDeactivateTemplateNode.java | 4 +-
.../write/RollbackSchemaBlackListNode.java | 4 +-
.../metadata/write/view/AlterLogicalViewNode.java | 4 +-
.../view/ConstructLogicalViewBlackListNode.java | 4 +-
.../metadata/write/view/CreateLogicalViewNode.java | 4 +-
.../metadata/write/view/DeleteLogicalViewNode.java | 4 +-
.../view/RollbackLogicalViewBlackListNode.java | 4 +-
.../plan/node/process/AI/InferenceNode.java | 6 +-
.../node/process/ActiveRegionScanMergeNode.java | 5 +-
.../node/process/AggregationMergeSortNode.java | 5 +-
.../planner/plan/node/process/AggregationNode.java | 5 +-
.../planner/plan/node/process/CollectNode.java | 5 +-
.../plan/node/process/ColumnInjectNode.java | 5 +-
.../planner/plan/node/process/DeviceMergeNode.java | 5 +-
.../plan/node/process/DeviceViewIntoNode.java | 5 +-
.../planner/plan/node/process/DeviceViewNode.java | 5 +-
.../planner/plan/node/process/ExchangeNode.java | 7 +-
.../plan/planner/plan/node/process/FillNode.java | 5 +-
.../plan/planner/plan/node/process/FilterNode.java | 4 +-
.../plan/node/process/GroupByLevelNode.java | 5 +-
.../planner/plan/node/process/GroupByTagNode.java | 5 +-
.../plan/node/process/HorizontallyConcatNode.java | 5 +-
.../plan/planner/plan/node/process/IntoNode.java | 5 +-
.../plan/planner/plan/node/process/LimitNode.java | 5 +-
.../planner/plan/node/process/MergeSortNode.java | 5 +-
.../plan/planner/plan/node/process/OffsetNode.java | 5 +-
.../planner/plan/node/process/ProjectNode.java | 5 +-
.../plan/node/process/RawDataAggregationNode.java | 5 +-
.../plan/node/process/SingleDeviceViewNode.java | 5 +-
.../node/process/SlidingWindowAggregationNode.java | 5 +-
.../plan/planner/plan/node/process/SortNode.java | 5 +-
.../plan/planner/plan/node/process/TopKNode.java | 5 +-
.../planner/plan/node/process/TransformNode.java | 5 +-
.../plan/node/process/TwoChildProcessNode.java | 1 +
.../node/process/join/FullOuterTimeJoinNode.java | 6 +-
.../plan/node/process/join/InnerTimeJoinNode.java | 6 +-
.../node/process/join/LeftOuterTimeJoinNode.java | 4 +-
.../node/process/last/LastQueryCollectNode.java | 6 +-
.../plan/node/process/last/LastQueryMergeNode.java | 6 +-
.../plan/node/process/last/LastQueryNode.java | 6 +-
.../node/process/last/LastQueryTransformNode.java | 6 +-
.../planner/plan/node/sink/IdentitySinkNode.java | 4 +-
.../planner/plan/node/sink/ShuffleSinkNode.java | 4 +-
.../source/AlignedSeriesAggregationScanNode.java | 4 +-
.../plan/node/source/AlignedSeriesScanNode.java | 4 +-
.../plan/node/source/DeviceRegionScanNode.java | 4 +-
.../plan/node/source/LastQueryScanNode.java | 4 +-
.../planner/plan/node/source/RegionScanNode.java | 4 +-
.../node/source/SeriesAggregationScanNode.java | 4 +-
.../node/source/SeriesAggregationSourceNode.java | 4 +-
.../planner/plan/node/source/SeriesScanNode.java | 4 +-
.../plan/node/source/SeriesScanSourceNode.java | 4 +-
.../plan/node/source/ShowDiskUsageNode.java | 4 +-
.../planner/plan/node/source/ShowQueriesNode.java | 4 +-
.../plan/node/source/TimeseriesRegionScanNode.java | 4 +-
.../relational/analyzer/AggregationAnalyzer.java | 4 +-
.../plan/relational/analyzer/Analysis.java | 6 +-
.../plan/relational/analyzer/Analyzer.java | 2 +-
.../relational/analyzer/CanonicalizationAware.java | 2 +-
.../relational/analyzer/ExpressionAnalysis.java | 2 +-
.../relational/analyzer/ExpressionAnalyzer.java | 8 +-
.../relational/analyzer/ExpressionTreeUtils.java | 4 +-
.../plan/relational/analyzer/NodeRef.java | 2 +-
.../analyzer/PatternRecognitionAnalysis.java | 2 +-
.../analyzer/PatternRecognitionAnalyzer.java | 2 +-
.../plan/relational/analyzer/RelationId.java | 2 +-
.../plan/relational/analyzer/Scope.java | 2 +-
.../analyzer/ScopeReferenceExtractor.java | 4 +-
.../relational/analyzer/StatementAnalyzer.java | 6 +-
.../predicate/ConvertPredicateToFilterVisitor.java | 4 +-
.../ConvertPredicateToTimeFilterVisitor.java | 2 +-
.../PredicateCombineIntoTableScanChecker.java | 2 +-
.../PredicatePushIntoMetadataChecker.java | 2 +-
.../predicate/PredicatePushIntoScanChecker.java | 2 +-
.../analyzer/predicate/PredicateVisitor.java | 2 +-
.../schema/CheckSchemaPredicateVisitor.java | 2 +-
.../ConvertSchemaPredicateToFilterVisitor.java | 2 +-
.../schema/ExtractPredicateColumnNameVisitor.java | 2 +-
.../tablefunction/TableArgumentAnalysis.java | 2 +-
.../function/ResolvedFunctionCallBuilder.java | 2 +-
.../plan/relational/metadata/Metadata.java | 2 +-
.../relational/metadata/TableMetadataImpl.java | 2 +-
.../metadata/fetcher/SchemaPredicateUtil.java | 2 +-
.../metadata/fetcher/TableDeviceSchemaFetcher.java | 2 +-
.../plan/relational/planner/Assignments.java | 3 +-
.../planner/DataOrganizationSpecification.java | 2 +
.../plan/relational/planner/EqualityInference.java | 3 +-
.../relational/planner/ExpressionExtractor.java | 10 +-
.../planner/ExpressionSymbolInliner.java | 3 +-
.../planner/IrExpressionInterpreter.java | 3 +-
.../plan/relational/planner/IrTypeAnalyzer.java | 5 +-
.../plan/relational/planner/LiteralEncoder.java | 2 +-
.../relational/planner/LiteralInterpreter.java | 2 +-
.../relational/planner/NoOpSymbolResolver.java | 2 +
.../plan/relational/planner/NodeAndMappings.java | 1 +
.../plan/relational/planner/OrderingScheme.java | 2 +
.../plan/relational/planner/PlanBuilder.java | 5 +-
.../plan/relational/planner/PredicateUtils.java | 2 +-
.../plan/relational/planner/QueryPlanner.java | 37 +-
.../plan/relational/planner/RelationPlan.java | 1 +
.../plan/relational/planner/RelationPlanner.java | 47 +-
.../plan/relational/planner/ScopeAware.java | 4 +-
.../relational/planner/SimplePlanRewriter.java | 2 +-
.../plan/relational/planner/SubqueryPlanner.java | 11 +-
.../plan/relational/planner/SymbolAllocator.java | 3 +-
.../plan/relational/planner/SymbolResolver.java | 2 +
.../plan/relational/planner/SymbolsExtractor.java | 7 +-
.../relational/planner/TableLogicalPlanner.java | 13 +-
.../plan/relational/planner/TableModelPlanner.java | 2 +-
.../plan/relational/planner/TranslationMap.java | 5 +-
.../planner/distribute/AddExchangeNodes.java | 6 +-
.../distribute/TableDistributedPlanGenerator.java | 70 +-
.../distribute/TableDistributedPlanner.java | 2 +-
.../TableModelTypeProviderExtractor.java | 34 +-
.../planner/ir/DefaultTraversalVisitor.java | 2 +-
.../planner/ir/DeterminismEvaluator.java | 2 +-
.../planner/ir/ExpressionNodeInliner.java | 2 +-
.../relational/planner/ir/ExpressionRewriter.java | 2 +-
.../planner/ir/ExpressionTreeRewriter.java | 2 +-
.../ExtractCommonPredicatesExpressionRewriter.java | 2 +-
.../ir/GapFillStartAndEndTimeExtractVisitor.java | 6 +-
.../ir/GlobalTimePredicateExtractVisitor.java | 2 +-
.../plan/relational/planner/ir/IrUtils.java | 2 +-
.../planner/ir/NormalizeOrExpressionRewriter.java | 2 +-
...ithUncorrelatedScalarSubqueryReconstructor.java | 2 +-
.../planner/ir/ReplaceSymbolInExpression.java | 4 +-
.../planner/ir/SubExpressionExtractor.java | 4 +-
.../planner/iterative/GroupReference.java | 6 +-
.../plan/relational/planner/iterative/Plans.java | 2 +-
.../iterative/rule/AggregationDecorrelation.java | 4 +-
.../rule/CanonicalizeExpressionRewriter.java | 2 +-
.../rule/EliminateLimitProjectWithTableScan.java | 4 +-
.../rule/EliminateLimitWithTableScan.java | 2 +-
.../iterative/rule/EvaluateEmptyIntersect.java | 4 +-
.../iterative/rule/ExpressionRewriteRuleSet.java | 16 +-
.../iterative/rule/GatherAndMergeWindows.java | 8 +-
.../planner/iterative/rule/ImplementExceptAll.java | 6 +-
.../rule/ImplementExceptDistinctAsUnion.java | 6 +-
.../iterative/rule/ImplementIntersectAll.java | 6 +-
.../rule/ImplementIntersectDistinctAsUnion.java | 6 +-
.../rule/ImplementPatternRecognition.java | 6 +-
.../rule/ImplementTableFunctionSource.java | 8 +-
.../planner/iterative/rule/InlineProjections.java | 6 +-
.../planner/iterative/rule/MergeFilters.java | 2 +-
.../rule/MergeLimitOverProjectWithMergeSort.java | 8 +-
.../rule/MergeLimitOverProjectWithSort.java | 10 +-
.../iterative/rule/MergeLimitWithMergeSort.java | 6 +-
.../planner/iterative/rule/MergeLimitWithSort.java | 8 +-
.../planner/iterative/rule/MergeLimits.java | 2 +-
.../planner/iterative/rule/MergeUnion.java | 2 +-
.../MultipleDistinctAggregationToMarkDistinct.java | 6 +-
.../planner/iterative/rule/OptimizeRowPattern.java | 8 +-
.../iterative/rule/ProjectOffPushDownRule.java | 4 +-
.../iterative/rule/PruneAggregationColumns.java | 4 +-
.../rule/PruneAggregationSourceColumns.java | 4 +-
.../planner/iterative/rule/PruneApplyColumns.java | 2 +-
.../iterative/rule/PruneApplyCorrelation.java | 2 +-
.../iterative/rule/PruneApplySourceColumns.java | 2 +-
.../iterative/rule/PruneAssignUniqueIdColumns.java | 4 +-
.../iterative/rule/PruneCorrelatedJoinColumns.java | 4 +-
.../rule/PruneCorrelatedJoinCorrelation.java | 2 +-
.../iterative/rule/PruneDistinctAggregation.java | 6 +-
.../rule/PruneEnforceSingleRowColumns.java | 4 +-
.../iterative/rule/PruneExceptSourceColumns.java | 2 +-
.../planner/iterative/rule/PruneFillColumns.java | 4 +-
.../planner/iterative/rule/PruneFilterColumns.java | 4 +-
.../iterative/rule/PruneGapFillColumns.java | 4 +-
.../rule/PruneIntersectSourceColumns.java | 2 +-
.../iterative/rule/PruneJoinChildrenColumns.java | 4 +-
.../planner/iterative/rule/PruneJoinColumns.java | 4 +-
.../planner/iterative/rule/PruneLimitColumns.java | 4 +-
.../iterative/rule/PruneMarkDistinctColumns.java | 4 +-
.../planner/iterative/rule/PruneOffsetColumns.java | 4 +-
.../iterative/rule/PruneOutputSourceColumns.java | 2 +-
.../rule/PrunePatternRecognitionSourceColumns.java | 8 +-
.../iterative/rule/PruneProjectColumns.java | 4 +-
.../planner/iterative/rule/PruneSortColumns.java | 4 +-
.../rule/PruneTableFunctionProcessorColumns.java | 6 +-
.../PruneTableFunctionProcessorSourceColumns.java | 6 +-
.../iterative/rule/PruneTableScanColumns.java | 2 +-
.../planner/iterative/rule/PruneTopKColumns.java | 4 +-
.../planner/iterative/rule/PruneUnionColumns.java | 4 +-
.../iterative/rule/PruneUnionSourceColumns.java | 4 +-
.../planner/iterative/rule/PruneWindowColumns.java | 4 +-
.../iterative/rule/PushDownFilterIntoWindow.java | 12 +-
.../iterative/rule/PushDownLimitIntoWindow.java | 8 +-
.../rule/PushDownNegationsExpressionRewriter.java | 2 +-
.../rule/PushDownOffsetIntoTableScan.java | 2 +-
.../iterative/rule/PushLimitThroughOffset.java | 4 +-
.../iterative/rule/PushLimitThroughProject.java | 6 +-
.../iterative/rule/PushLimitThroughUnion.java | 4 +-
.../iterative/rule/PushProjectionThroughUnion.java | 8 +-
.../iterative/rule/PushTopKThroughUnion.java | 6 +-
.../iterative/rule/RemoveDuplicateConditions.java | 2 +-
.../iterative/rule/RemoveEmptyExceptBranches.java | 8 +-
.../iterative/rule/RemoveEmptyUnionBranches.java | 6 +-
.../rule/RemoveRedundantEnforceSingleRowNode.java | 2 +-
.../iterative/rule/RemoveRedundantExists.java | 6 +-
.../rule/RemoveRedundantIdentityProjections.java | 2 +-
.../iterative/rule/RemoveRedundantWindow.java | 4 +-
.../iterative/rule/RemoveTrivialFilters.java | 4 +-
.../rule/RemoveUnreferencedScalarSubqueries.java | 4 +-
.../iterative/rule/ReplaceWindowWithRowNumber.java | 4 +-
.../planner/iterative/rule/SetOperationMerge.java | 4 +-
.../iterative/rule/SetOperationNodeTranslator.java | 16 +-
.../iterative/rule/SimplifyCountOverConstant.java | 8 +-
.../iterative/rule/SimplifyExpressions.java | 2 +-
.../rule/SingleDistinctAggregationToGroupBy.java | 10 +-
...orrelatedDistinctAggregationWithProjection.java | 14 +-
...elatedDistinctAggregationWithoutProjection.java | 12 +-
...mCorrelatedGlobalAggregationWithProjection.java | 18 +-
...rrelatedGlobalAggregationWithoutProjection.java | 18 +-
...CorrelatedGroupedAggregationWithProjection.java | 14 +-
...relatedGroupedAggregationWithoutProjection.java | 12 +-
.../rule/TransformCorrelatedJoinToJoin.java | 8 +-
.../rule/TransformCorrelatedScalarSubquery.java | 16 +-
.../rule/TransformExistsApplyToCorrelatedJoin.java | 16 +-
.../TransformFilteringSemiJoinToInnerJoin.java | 18 +-
...mUncorrelatedInPredicateSubqueryToSemiJoin.java | 4 +-
.../rule/TransformUncorrelatedSubqueryToJoin.java | 8 +-
.../relational/planner/iterative/rule/Util.java | 14 +-
.../planner/node/AggregationTableScanNode.java | 10 +-
.../node/AggregationTreeDeviceViewScanNode.java | 9 +-
.../AlignedAggregationTreeDeviceViewScanNode.java | 10 +-
.../plan/relational/planner/node/ApplyNode.java | 8 +-
.../plan/relational/planner/node/CopyToNode.java | 8 +-
.../planner/node/CorrelatedJoinNode.java | 11 +-
.../plan/relational/planner/node/CteScanNode.java | 6 +-
.../planner/node/DeviceTableScanNode.java | 8 +-
.../plan/relational/planner/node/ExceptNode.java | 6 +-
.../plan/relational/planner/node/ExchangeNode.java | 8 +-
.../planner/node/ExplainAnalyzeNode.java | 8 +-
.../node/InformationSchemaTableScanNode.java | 8 +-
.../relational/planner/node/IntersectNode.java | 6 +-
.../plan/relational/planner/node/IntoNode.java | 8 +-
...onAlignedAggregationTreeDeviceViewScanNode.java | 9 +-
.../plan/relational/planner/node/Patterns.java | 28 +-
.../relational/planner/node/SetOperationNode.java | 4 +-
...bleDiskUsageInformationSchemaTableScanNode.java | 4 +-
.../relational/planner/node/TableScanNode.java | 8 +-
.../node/TreeAlignedDeviceViewScanNode.java | 8 +-
.../planner/node/TreeDeviceViewScanNode.java | 8 +-
.../node/TreeNonAlignedDeviceViewScanNode.java | 8 +-
.../node/schema/AbstractTableDeviceQueryNode.java | 2 +-
...ctTableSchemaQueryAttributeSecurityVisitor.java | 2 +-
.../schema/ConstructTableDevicesBlackListNode.java | 4 +-
.../node/schema/CreateOrUpdateTableDeviceNode.java | 4 +-
.../schema/DeleteTableDevicesInBlackListNode.java | 4 +-
.../schema/RollbackTableDevicesBlackListNode.java | 4 +-
.../node/schema/TableAttributeColumnDropNode.java | 4 +-
.../TableDeviceAttributeCommitUpdateNode.java | 4 +-
.../schema/TableDeviceAttributeUpdateNode.java | 8 +-
.../planner/node/schema/TableDeviceFetchNode.java | 4 +-
.../node/schema/TableDeviceQueryCountNode.java | 6 +-
.../node/schema/TableDeviceQueryScanNode.java | 6 +-
.../node/schema/TableNodeLocationAddNode.java | 4 +-
.../CheckSubqueryNodesAreRewritten.java | 2 +-
.../planner/optimizations/JoinUtils.java | 6 +-
.../planner/optimizations/ParallelizeGrouping.java | 22 +-
.../optimizations/PlanNodeDecorrelator.java | 20 +-
.../PushAggregationIntoTableScan.java | 10 +-
.../PushLimitOffsetIntoTableScan.java | 32 +-
.../optimizations/PushPredicateIntoTableScan.java | 32 +-
.../optimizations/QueryCardinalityUtil.java | 16 +-
.../planner/optimizations/SortElimination.java | 18 +-
.../planner/optimizations/SymbolMapper.java | 36 +-
.../TransformAggregationToStreamable.java | 22 +-
...mQuantifiedComparisonApplyToCorrelatedJoin.java | 14 +-
.../optimizations/TransformSortToStreamSort.java | 14 +-
.../optimizations/UnaliasSymbolReferences.java | 58 +-
.../relational/planner/optimizations/Util.java | 12 +-
.../plan/relational/sql/ParameterExtractor.java | 2 +-
.../sql/ast/AbstractQueryDeviceWithCache.java | 1 +
.../relational/sql/ast/AbstractTraverseDevice.java | 2 +
.../plan/relational/sql/ast/AddColumn.java | 7 +-
.../plan/relational/sql/ast/AliasedRelation.java | 7 +-
.../plan/relational/sql/ast/AllColumns.java | 8 +-
.../plan/relational/sql/ast/AllRows.java | 8 +-
.../relational/sql/ast/AlterColumnDataType.java | 7 +-
.../plan/relational/sql/ast/AlterDB.java | 5 +-
.../plan/relational/sql/ast/AlterPipe.java | 6 +-
.../plan/relational/sql/ast/AnchorPattern.java | 7 +-
.../sql/ast/ArithmeticBinaryExpression.java | 8 +-
.../sql/ast/ArithmeticUnaryExpression.java | 8 +-
.../plan/relational/sql/ast/AsofJoinOn.java | 2 +
.../sql/ast/AstMemoryEstimationHelper.java | 2 +
.../plan/relational/sql/ast/AstVisitor.java | 21 +-
.../plan/relational/sql/ast/BetweenPredicate.java | 8 +-
.../plan/relational/sql/ast/BinaryLiteral.java | 6 +-
.../plan/relational/sql/ast/BooleanLiteral.java | 7 +-
.../queryengine/plan/relational/sql/ast/Cast.java | 8 +-
.../plan/relational/sql/ast/ClearCache.java | 6 +-
.../relational/sql/ast/CoalesceExpression.java | 8 +-
.../plan/relational/sql/ast/ColumnDefinition.java | 6 +-
.../plan/relational/sql/ast/Columns.java | 8 +-
.../relational/sql/ast/ComparisonExpression.java | 8 +-
.../plan/relational/sql/ast/CopyTo.java | 6 +-
.../plan/relational/sql/ast/CountDevice.java | 6 +-
.../plan/relational/sql/ast/CountStatement.java | 8 +-
.../plan/relational/sql/ast/CreateDB.java | 5 +-
.../relational/sql/ast/CreateExternalService.java | 7 +-
.../plan/relational/sql/ast/CreateFunction.java | 7 +-
.../plan/relational/sql/ast/CreateIndex.java | 7 +-
.../plan/relational/sql/ast/CreateModel.java | 7 +-
.../relational/sql/ast/CreateOrUpdateDevice.java | 7 +-
.../plan/relational/sql/ast/CreatePipe.java | 6 +-
.../plan/relational/sql/ast/CreatePipePlugin.java | 6 +-
.../plan/relational/sql/ast/CreateTable.java | 7 +-
.../plan/relational/sql/ast/CreateTopic.java | 6 +-
.../plan/relational/sql/ast/CreateTraining.java | 7 +-
.../plan/relational/sql/ast/CreateView.java | 5 +-
.../plan/relational/sql/ast/CurrentDatabase.java | 8 +-
.../plan/relational/sql/ast/CurrentTime.java | 8 +-
.../plan/relational/sql/ast/CurrentUser.java | 8 +-
.../plan/relational/sql/ast/DataType.java | 2 +
.../plan/relational/sql/ast/DataTypeParameter.java | 7 +-
.../plan/relational/sql/ast/DatabaseStatement.java | 1 +
.../plan/relational/sql/ast/Deallocate.java | 7 +-
.../plan/relational/sql/ast/DecimalLiteral.java | 7 +-
.../sql/ast/DefaultTraversalVisitor.java | 3 +
.../plan/relational/sql/ast/Delete.java | 7 +-
.../plan/relational/sql/ast/DeleteDevice.java | 8 +-
.../relational/sql/ast/DereferenceExpression.java | 8 +-
.../plan/relational/sql/ast/DescribeTable.java | 7 +-
.../plan/relational/sql/ast/DoubleLiteral.java | 7 +-
.../plan/relational/sql/ast/DropColumn.java | 7 +-
.../plan/relational/sql/ast/DropDB.java | 7 +-
.../relational/sql/ast/DropExternalService.java | 7 +-
.../plan/relational/sql/ast/DropFunction.java | 7 +-
.../plan/relational/sql/ast/DropIndex.java | 7 +-
.../plan/relational/sql/ast/DropModel.java | 7 +-
.../plan/relational/sql/ast/DropPipe.java | 6 +-
.../plan/relational/sql/ast/DropPipePlugin.java | 6 +-
.../plan/relational/sql/ast/DropSubscription.java | 6 +-
.../plan/relational/sql/ast/DropTable.java | 7 +-
.../plan/relational/sql/ast/DropTopic.java | 6 +-
.../plan/relational/sql/ast/EmptyPattern.java | 7 +-
.../plan/relational/sql/ast/Except.java | 7 +-
.../plan/relational/sql/ast/ExcludedPattern.java | 7 +-
.../plan/relational/sql/ast/Execute.java | 7 +-
.../plan/relational/sql/ast/ExecuteImmediate.java | 7 +-
.../plan/relational/sql/ast/ExistsPredicate.java | 8 +-
.../plan/relational/sql/ast/Explain.java | 7 +-
.../plan/relational/sql/ast/ExplainAnalyze.java | 7 +-
.../plan/relational/sql/ast/ExtendRegion.java | 7 +-
.../plan/relational/sql/ast/Extract.java | 8 +-
.../plan/relational/sql/ast/FetchDevice.java | 7 +-
.../plan/relational/sql/ast/FieldReference.java | 8 +-
.../queryengine/plan/relational/sql/ast/Fill.java | 6 +-
.../plan/relational/sql/ast/FloatLiteral.java | 6 +-
.../queryengine/plan/relational/sql/ast/Flush.java | 5 +-
.../plan/relational/sql/ast/FrameBound.java | 8 +-
.../plan/relational/sql/ast/FunctionCall.java | 8 +-
.../plan/relational/sql/ast/GenericDataType.java | 7 +-
.../plan/relational/sql/ast/GenericLiteral.java | 6 +-
.../plan/relational/sql/ast/GroupBy.java | 7 +-
.../plan/relational/sql/ast/GroupingElement.java | 8 +-
.../plan/relational/sql/ast/GroupingSets.java | 8 +-
.../plan/relational/sql/ast/Identifier.java | 8 +-
.../plan/relational/sql/ast/IfExpression.java | 8 +-
.../plan/relational/sql/ast/InListExpression.java | 8 +-
.../plan/relational/sql/ast/InPredicate.java | 8 +-
.../plan/relational/sql/ast/Insert.java | 6 +-
.../plan/relational/sql/ast/InsertRow.java | 5 +-
.../plan/relational/sql/ast/InsertRows.java | 5 +-
.../plan/relational/sql/ast/InsertTablet.java | 5 +-
.../plan/relational/sql/ast/Intersect.java | 7 +-
.../relational/sql/ast/IsNotNullPredicate.java | 8 +-
.../plan/relational/sql/ast/IsNullPredicate.java | 8 +-
.../queryengine/plan/relational/sql/ast/Join.java | 7 +-
.../plan/relational/sql/ast/JoinCriteria.java | 2 +
.../plan/relational/sql/ast/JoinOn.java | 3 +
.../plan/relational/sql/ast/JoinUsing.java | 2 +
.../plan/relational/sql/ast/KillQuery.java | 7 +-
.../plan/relational/sql/ast/LikePredicate.java | 8 +-
.../queryengine/plan/relational/sql/ast/Limit.java | 8 +-
.../plan/relational/sql/ast/Literal.java | 8 +-
.../plan/relational/sql/ast/LoadConfiguration.java | 5 +-
.../plan/relational/sql/ast/LoadModel.java | 7 +-
.../plan/relational/sql/ast/LoadTsFile.java | 6 +-
.../plan/relational/sql/ast/LogicalExpression.java | 8 +-
.../plan/relational/sql/ast/LongLiteral.java | 6 +-
.../plan/relational/sql/ast/MeasureDefinition.java | 8 +-
.../plan/relational/sql/ast/MigrateRegion.java | 7 +-
.../plan/relational/sql/ast/NaturalJoin.java | 2 +
.../plan/relational/sql/ast/NotExpression.java | 8 +-
.../plan/relational/sql/ast/NullIfExpression.java | 8 +-
.../plan/relational/sql/ast/NullLiteral.java | 7 +-
.../plan/relational/sql/ast/NumericParameter.java | 7 +-
.../plan/relational/sql/ast/Offset.java | 8 +-
.../relational/sql/ast/OneOrMoreQuantifier.java | 6 +-
.../plan/relational/sql/ast/OrderBy.java | 7 +-
.../plan/relational/sql/ast/Parameter.java | 8 +-
.../relational/sql/ast/PatternAlternation.java | 7 +-
.../relational/sql/ast/PatternConcatenation.java | 7 +-
.../relational/sql/ast/PatternPermutation.java | 7 +-
.../plan/relational/sql/ast/PatternQuantifier.java | 7 +-
.../sql/ast/PatternRecognitionRelation.java | 8 +-
.../plan/relational/sql/ast/PatternVariable.java | 7 +-
.../plan/relational/sql/ast/PipeEnriched.java | 7 +-
.../plan/relational/sql/ast/PipeStatement.java | 2 +
.../plan/relational/sql/ast/Prepare.java | 7 +-
.../plan/relational/sql/ast/ProcessingMode.java | 7 +-
.../plan/relational/sql/ast/Property.java | 8 +-
.../plan/relational/sql/ast/QualifiedName.java | 2 +
.../sql/ast/QuantifiedComparisonExpression.java | 8 +-
.../plan/relational/sql/ast/QuantifiedPattern.java | 7 +-
.../queryengine/plan/relational/sql/ast/Query.java | 6 +-
.../plan/relational/sql/ast/QueryBody.java | 6 +-
.../relational/sql/ast/QuerySpecification.java | 8 +-
.../plan/relational/sql/ast/RangeQuantifier.java | 7 +-
.../plan/relational/sql/ast/ReconstructRegion.java | 7 +-
.../plan/relational/sql/ast/Relation.java | 7 +-
.../sql/ast/RelationalAuthorStatement.java | 6 +-
.../plan/relational/sql/ast/RemoveAINode.java | 7 +-
.../plan/relational/sql/ast/RemoveConfigNode.java | 7 +-
.../plan/relational/sql/ast/RemoveDataNode.java | 7 +-
.../plan/relational/sql/ast/RemoveRegion.java | 7 +-
.../plan/relational/sql/ast/RenameColumn.java | 6 +-
.../plan/relational/sql/ast/RenameTable.java | 6 +-
.../queryengine/plan/relational/sql/ast/Row.java | 8 +-
.../plan/relational/sql/ast/RowPattern.java | 7 +-
.../relational/sql/ast/SearchedCaseExpression.java | 8 +-
.../plan/relational/sql/ast/Select.java | 7 +-
.../plan/relational/sql/ast/SelectItem.java | 2 +
.../plan/relational/sql/ast/SetColumnComment.java | 7 +-
.../plan/relational/sql/ast/SetConfiguration.java | 5 +-
.../plan/relational/sql/ast/SetOperation.java | 6 +-
.../plan/relational/sql/ast/SetProperties.java | 7 +-
.../plan/relational/sql/ast/SetSqlDialect.java | 6 +-
.../plan/relational/sql/ast/SetSystemStatus.java | 5 +-
.../plan/relational/sql/ast/SetTableComment.java | 7 +-
.../plan/relational/sql/ast/ShowAIDevices.java | 7 +-
.../plan/relational/sql/ast/ShowAINodes.java | 7 +-
.../plan/relational/sql/ast/ShowAvailableUrls.java | 7 +-
.../plan/relational/sql/ast/ShowCluster.java | 7 +-
.../plan/relational/sql/ast/ShowClusterId.java | 7 +-
.../plan/relational/sql/ast/ShowConfigNodes.java | 7 +-
.../plan/relational/sql/ast/ShowConfiguration.java | 5 +-
.../relational/sql/ast/ShowCurrentDatabase.java | 7 +-
.../relational/sql/ast/ShowCurrentSqlDialect.java | 7 +-
.../relational/sql/ast/ShowCurrentTimestamp.java | 7 +-
.../plan/relational/sql/ast/ShowCurrentUser.java | 7 +-
.../plan/relational/sql/ast/ShowDB.java | 7 +-
.../plan/relational/sql/ast/ShowDataNodes.java | 7 +-
.../plan/relational/sql/ast/ShowDevice.java | 7 +-
.../relational/sql/ast/ShowExternalService.java | 8 +-
.../plan/relational/sql/ast/ShowFunctions.java | 7 +-
.../plan/relational/sql/ast/ShowIndex.java | 7 +-
.../plan/relational/sql/ast/ShowLoadedModels.java | 7 +-
.../plan/relational/sql/ast/ShowModels.java | 7 +-
.../plan/relational/sql/ast/ShowPipePlugins.java | 6 +-
.../plan/relational/sql/ast/ShowPipes.java | 6 +-
.../relational/sql/ast/ShowQueriesStatement.java | 8 +-
.../plan/relational/sql/ast/ShowRegions.java | 6 +-
.../plan/relational/sql/ast/ShowStatement.java | 8 +-
.../plan/relational/sql/ast/ShowSubscriptions.java | 6 +-
.../plan/relational/sql/ast/ShowTables.java | 7 +-
.../plan/relational/sql/ast/ShowTopics.java | 6 +-
.../plan/relational/sql/ast/ShowVariables.java | 7 +-
.../plan/relational/sql/ast/ShowVersion.java | 7 +-
.../relational/sql/ast/SimpleCaseExpression.java | 8 +-
.../plan/relational/sql/ast/SimpleGroupBy.java | 8 +-
.../plan/relational/sql/ast/SingleColumn.java | 8 +-
.../plan/relational/sql/ast/SkipTo.java | 7 +-
.../plan/relational/sql/ast/SortItem.java | 8 +-
.../relational/sql/ast/StartExternalService.java | 7 +-
.../plan/relational/sql/ast/StartPipe.java | 6 +-
.../plan/relational/sql/ast/StartRepairData.java | 5 +-
.../plan/relational/sql/ast/Statement.java | 7 +-
.../relational/sql/ast/StopExternalService.java | 7 +-
.../plan/relational/sql/ast/StopPipe.java | 6 +-
.../plan/relational/sql/ast/StopRepairData.java | 5 +-
.../plan/relational/sql/ast/StringLiteral.java | 7 +-
.../relational/sql/ast/SubqueryExpression.java | 8 +-
.../relational/sql/ast/SubscriptionStatement.java | 2 +
.../plan/relational/sql/ast/SubsetDefinition.java | 7 +-
.../plan/relational/sql/ast/SymbolReference.java | 8 +-
.../queryengine/plan/relational/sql/ast/Table.java | 7 +-
.../relational/sql/ast/TableFunctionArgument.java | 8 +-
.../sql/ast/TableFunctionInvocation.java | 7 +-
.../sql/ast/TableFunctionTableArgument.java | 8 +-
.../plan/relational/sql/ast/TableSubquery.java | 7 +-
.../plan/relational/sql/ast/TimeRange.java | 2 +
.../queryengine/plan/relational/sql/ast/Trim.java | 8 +-
.../plan/relational/sql/ast/TypeParameter.java | 7 +-
.../queryengine/plan/relational/sql/ast/Union.java | 7 +-
.../plan/relational/sql/ast/UnloadModel.java | 7 +-
.../plan/relational/sql/ast/Update.java | 8 +-
.../plan/relational/sql/ast/UpdateAssignment.java | 8 +-
.../queryengine/plan/relational/sql/ast/Use.java | 7 +-
.../plan/relational/sql/ast/Values.java | 8 +-
.../relational/sql/ast/VariableDefinition.java | 8 +-
.../relational/sql/ast/ViewFieldDefinition.java | 5 +-
.../plan/relational/sql/ast/WhenClause.java | 8 +-
.../plan/relational/sql/ast/WindowDefinition.java | 7 +-
.../plan/relational/sql/ast/WindowFrame.java | 7 +-
.../plan/relational/sql/ast/WindowReference.java | 7 +-
.../relational/sql/ast/WindowSpecification.java | 8 +-
.../queryengine/plan/relational/sql/ast/With.java | 7 +-
.../plan/relational/sql/ast/WithQuery.java | 7 +-
.../plan/relational/sql/ast/WrappedStatement.java | 1 +
.../relational/sql/ast/ZeroOrMoreQuantifier.java | 6 +-
.../relational/sql/ast/ZeroOrOneQuantifier.java | 6 +-
.../plan/relational/sql/parser/AstBuilder.java | 4 +-
.../plan/relational/sql/parser/SqlParser.java | 4 +-
.../plan/relational/sql/rewrite/ShowRewrite.java | 4 +-
.../relational/sql/rewrite/StatementRewrite.java | 2 +-
.../plan/relational/sql/util/AstUtil.java | 4 +-
.../relational/sql/util/ExpressionFormatter.java | 4 +-
.../plan/relational/sql/util/QueryUtil.java | 4 +-
.../relational/sql/util/RowPatternFormatter.java | 2 +-
.../plan/relational/sql/util/SqlFormatter.java | 4 +-
.../schemaregion/impl/SchemaRegionMemoryImpl.java | 6 +-
...ertedInsertTabletStatementExceptionVisitor.java | 2 +-
.../db/trigger/executor/TriggerFireVisitor.java | 2 +-
.../metadata/mtree/schemafile/SchemaFileTest.java | 3 +-
...nAlignedTreeDeviceViewScanOperatorTreeTest.java | 6 +-
.../operator/ViewFromTreeAdaptorOperatorTest.java | 4 +-
.../rowpattern/IrRowPatternOptimizationTest.java | 26 +-
.../operator/process/rowpattern/MatcherTest.java | 22 +-
.../process/window/TopKRankingOperatorTest.java | 2 +-
.../sink/SinkOperatorDownStreamNodeIdTest.java | 2 +-
.../distribution/AggregationTableScanTest.java | 2 +-
.../planner/node/process/IntoNodeSerdeTest.java | 2 +-
.../planner/node/process/WindowNodeSerdeTest.java | 6 +-
.../planner/node/source/SourceNodeSerdeTest.java | 2 +-
.../analyzer/AggregationCornerCaseTest.java | 2 +-
.../plan/relational/analyzer/AggregationTest.java | 8 +-
.../plan/relational/analyzer/AnalyzerTest.java | 16 +-
.../plan/relational/analyzer/AsofJoinTest.java | 2 +-
.../plan/relational/analyzer/DistinctTest.java | 2 +-
.../relational/analyzer/InsertIntoQueryTest.java | 8 +-
.../plan/relational/analyzer/JoinTest.java | 26 +-
.../analyzer/LimitOffsetPushDownTest.java | 10 +-
.../analyzer/PushAggregationThroughUnionTest.java | 4 +-
.../plan/relational/analyzer/SortTest.java | 16 +-
.../plan/relational/analyzer/SubQueryTest.java | 14 +-
.../plan/relational/analyzer/TSBSMetadata.java | 2 +-
.../plan/relational/analyzer/TSBSTest.java | 8 +-
.../relational/analyzer/TableFunctionTest.java | 2 +-
.../plan/relational/analyzer/TestMetadata.java | 2 +-
.../plan/relational/analyzer/TestPlanBuilder.java | 14 +-
.../plan/relational/analyzer/TestUtils.java | 8 +-
.../plan/relational/analyzer/TreeViewTest.java | 6 +-
.../relational/planner/CorrelatedSubqueryTest.java | 6 +-
.../relational/planner/CteMaterializerTest.java | 4 +-
.../plan/relational/planner/ExampleTest.java | 2 +-
.../planner/PatternRecognitionNodeSerdeTest.java | 25 +-
.../relational/planner/PredicateUtilsTest.java | 2 +-
.../planner/UncorrelatedSubqueryTest.java | 10 +-
.../AggregationDeviceTableScanMatcher.java | 4 +-
.../planner/assertions/AggregationFunction.java | 4 +-
.../assertions/AggregationFunctionMatcher.java | 4 +-
.../assertions/AggregationFunctionProvider.java | 4 +-
.../planner/assertions/AggregationMatcher.java | 4 +-
.../planner/assertions/AggregationStepMatcher.java | 2 +-
.../planner/assertions/AliasMatcher.java | 2 +-
.../planner/assertions/AliasPresent.java | 2 +-
.../planner/assertions/AsofJoinClauseProvider.java | 2 +-
.../planner/assertions/AssignUniqueIdMatcher.java | 4 +-
.../assertions/BaseStrictSymbolsMatcher.java | 2 +-
.../planner/assertions/ColumnReference.java | 2 +-
.../planner/assertions/CteScanMatcher.java | 2 +-
.../planner/assertions/DeviceTableScanMatcher.java | 2 +-
.../planner/assertions/EquiJoinClauseProvider.java | 2 +-
.../planner/assertions/ExchangeNodeMatcher.java | 2 +-
.../planner/assertions/ExpressionMatcher.java | 6 +-
.../planner/assertions/ExpressionVerifier.java | 4 +-
.../planner/assertions/FilterMatcher.java | 4 +-
.../planner/assertions/GroupMatcher.java | 2 +-
.../assertions/IdentityProjectionMatcher.java | 2 +-
.../relational/planner/assertions/JoinMatcher.java | 4 +-
.../planner/assertions/LimitMatcher.java | 2 +-
.../planner/assertions/MarkDistinctMatcher.java | 2 +-
.../planner/assertions/OffsetMatcher.java | 2 +-
.../planner/assertions/OutputMatcher.java | 4 +-
.../planner/assertions/PlanMatchPattern.java | 48 +-
.../planner/assertions/PlanMatchingVisitor.java | 4 +-
.../planner/assertions/PlanTestSymbol.java | 2 +-
.../planner/assertions/RvalueMatcher.java | 2 +-
.../planner/assertions/SemiJoinMatcher.java | 2 +-
.../relational/planner/assertions/SortMatcher.java | 2 +-
.../assertions/StrictAssignedSymbolsMatcher.java | 4 +-
.../planner/assertions/StrictSymbolsMatcher.java | 2 +-
.../relational/planner/assertions/SymbolAlias.java | 2 +-
.../planner/assertions/SymbolAliases.java | 4 +-
.../assertions/TableFunctionProcessorMatcher.java | 5 +-
.../planner/assertions/TableScanMatcher.java | 4 +-
.../relational/planner/assertions/TopKMatcher.java | 2 +-
.../plan/relational/planner/assertions/Util.java | 2 +-
.../planner/assertions/WindowFunctionMatcher.java | 4 +-
.../predicate/TablePredicateConversionTest.java | 4 +-
.../settle/SettleCompactionTaskTest.java | 1 -
736 files changed, 5794 insertions(+), 4952 deletions(-)
rename iotdb-core/datanode/src/main/java/org/apache/iotdb/db/{queryengine =>
calc_commons}/plan/planner/TableOperatorGenerator.java (51%)
create mode 100644
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/node_commons/plan/planner/plan/node/ICoreQueryPlanVisitor.java
delete mode 100644
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/node_commons/plan/planner/plan/node/IQueryPlanVisitor.java
rename iotdb-core/datanode/src/main/java/org/apache/iotdb/db/{queryengine =>
node_commons}/plan/planner/plan/node/process/MultiChildProcessNode.java (96%)
rename iotdb-core/datanode/src/main/java/org/apache/iotdb/db/{queryengine =>
node_commons}/plan/planner/plan/node/process/ProcessNode.java (93%)
rename iotdb-core/datanode/src/main/java/org/apache/iotdb/db/{queryengine =>
node_commons}/plan/planner/plan/node/process/SingleChildProcessNode.java (96%)
rename iotdb-core/datanode/src/main/java/org/apache/iotdb/db/{queryengine =>
node_commons}/plan/relational/planner/Symbol.java (94%)
rename iotdb-core/datanode/src/main/java/org/apache/iotdb/db/{queryengine =>
node_commons}/plan/relational/planner/node/AggregationNode.java (98%)
rename iotdb-core/datanode/src/main/java/org/apache/iotdb/db/{queryengine =>
node_commons}/plan/relational/planner/node/AssignUniqueId.java (88%)
rename iotdb-core/datanode/src/main/java/org/apache/iotdb/db/{queryengine =>
node_commons}/plan/relational/planner/node/CollectNode.java (91%)
rename iotdb-core/datanode/src/main/java/org/apache/iotdb/db/{queryengine =>
node_commons}/plan/relational/planner/node/EnforceSingleRowNode.java (86%)
rename iotdb-core/datanode/src/main/java/org/apache/iotdb/db/{queryengine =>
node_commons}/plan/relational/planner/node/FillNode.java (79%)
rename iotdb-core/datanode/src/main/java/org/apache/iotdb/db/{queryengine =>
node_commons}/plan/relational/planner/node/FilterNode.java (87%)
rename iotdb-core/datanode/src/main/java/org/apache/iotdb/db/{queryengine =>
node_commons}/plan/relational/planner/node/GapFillNode.java (94%)
rename iotdb-core/datanode/src/main/java/org/apache/iotdb/db/{queryengine =>
node_commons}/plan/relational/planner/node/GroupNode.java (94%)
rename iotdb-core/datanode/src/main/java/org/apache/iotdb/db/{queryengine =>
node_commons}/plan/relational/planner/node/JoinNode.java (96%)
rename iotdb-core/datanode/src/main/java/org/apache/iotdb/db/{queryengine =>
node_commons}/plan/relational/planner/node/LimitNode.java (90%)
rename iotdb-core/datanode/src/main/java/org/apache/iotdb/db/{queryengine =>
node_commons}/plan/relational/planner/node/LinearFillNode.java (93%)
rename iotdb-core/datanode/src/main/java/org/apache/iotdb/db/{queryengine =>
node_commons}/plan/relational/planner/node/MarkDistinctNode.java (92%)
rename iotdb-core/datanode/src/main/java/org/apache/iotdb/db/{queryengine =>
node_commons}/plan/relational/planner/node/Measure.java (94%)
rename iotdb-core/datanode/src/main/java/org/apache/iotdb/db/{queryengine =>
node_commons}/plan/relational/planner/node/MergeSortNode.java (92%)
rename iotdb-core/datanode/src/main/java/org/apache/iotdb/db/{queryengine =>
node_commons}/plan/relational/planner/node/OffsetNode.java (89%)
rename iotdb-core/datanode/src/main/java/org/apache/iotdb/db/{queryengine =>
node_commons}/plan/relational/planner/node/OutputNode.java (92%)
rename iotdb-core/datanode/src/main/java/org/apache/iotdb/db/{queryengine =>
node_commons}/plan/relational/planner/node/PatternRecognitionNode.java (93%)
rename iotdb-core/datanode/src/main/java/org/apache/iotdb/db/{queryengine =>
node_commons}/plan/relational/planner/node/PreviousFillNode.java (95%)
rename iotdb-core/datanode/src/main/java/org/apache/iotdb/db/{queryengine =>
node_commons}/plan/relational/planner/node/ProjectNode.java (89%)
rename iotdb-core/datanode/src/main/java/org/apache/iotdb/db/{queryengine =>
node_commons}/plan/relational/planner/node/RowNumberNode.java (94%)
rename iotdb-core/datanode/src/main/java/org/apache/iotdb/db/{queryengine =>
node_commons}/plan/relational/planner/node/SemiJoinNode.java (94%)
rename iotdb-core/datanode/src/main/java/org/apache/iotdb/db/{queryengine =>
node_commons}/plan/relational/planner/node/SortNode.java (91%)
rename iotdb-core/datanode/src/main/java/org/apache/iotdb/db/{queryengine =>
node_commons}/plan/relational/planner/node/StreamSortNode.java (94%)
rename iotdb-core/datanode/src/main/java/org/apache/iotdb/db/{queryengine =>
node_commons}/plan/relational/planner/node/TableFunctionNode.java (97%)
rename iotdb-core/datanode/src/main/java/org/apache/iotdb/db/{queryengine =>
node_commons}/plan/relational/planner/node/TableFunctionProcessorNode.java (96%)
rename iotdb-core/datanode/src/main/java/org/apache/iotdb/db/{queryengine =>
node_commons}/plan/relational/planner/node/TopKNode.java (93%)
rename iotdb-core/datanode/src/main/java/org/apache/iotdb/db/{queryengine =>
node_commons}/plan/relational/planner/node/TopKRankingNode.java (94%)
rename iotdb-core/datanode/src/main/java/org/apache/iotdb/db/{queryengine =>
node_commons}/plan/relational/planner/node/UnionNode.java (92%)
rename iotdb-core/datanode/src/main/java/org/apache/iotdb/db/{queryengine =>
node_commons}/plan/relational/planner/node/ValueFillNode.java (91%)
rename iotdb-core/datanode/src/main/java/org/apache/iotdb/db/{queryengine =>
node_commons}/plan/relational/planner/node/ValuesNode.java (95%)
rename iotdb-core/datanode/src/main/java/org/apache/iotdb/db/{queryengine =>
node_commons}/plan/relational/planner/node/WindowNode.java (97%)
rename
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/{queryengine/plan/relational/planner
=>
node_commons/plan/relational/planner/rowpattern}/rowpattern/AggregationLabelSet.java
(97%)
rename
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/{queryengine/plan/relational/planner
=>
node_commons/plan/relational/planner/rowpattern}/rowpattern/AggregationValuePointer.java
(96%)
rename
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/{queryengine/plan/relational/planner
=>
node_commons/plan/relational/planner/rowpattern}/rowpattern/ClassifierValuePointer.java
(96%)
rename
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/{queryengine/plan/relational/planner
=>
node_commons/plan/relational/planner/rowpattern}/rowpattern/ExpressionAndValuePointers.java
(97%)
rename
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/{queryengine/plan/relational/planner
=>
node_commons/plan/relational/planner/rowpattern}/rowpattern/IrAlternation.java
(97%)
rename
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/{queryengine/plan/relational/planner
=> node_commons/plan/relational/planner/rowpattern}/rowpattern/IrAnchor.java
(91%)
rename
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/{queryengine/plan/relational/planner
=>
node_commons/plan/relational/planner/rowpattern}/rowpattern/IrConcatenation.java
(97%)
rename
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/{queryengine/plan/relational/planner
=> node_commons/plan/relational/planner/rowpattern}/rowpattern/IrEmpty.java
(95%)
rename
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/{queryengine/plan/relational/planner
=>
node_commons/plan/relational/planner/rowpattern}/rowpattern/IrExclusion.java
(96%)
rename
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/{queryengine/plan/relational/planner
=> node_commons/plan/relational/planner/rowpattern}/rowpattern/IrLabel.java
(96%)
rename
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/{queryengine/plan/relational/planner
=>
node_commons/plan/relational/planner/rowpattern}/rowpattern/IrPatternAlternationOptimizer.java
(95%)
rename
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/{queryengine/plan/relational/planner
=>
node_commons/plan/relational/planner/rowpattern}/rowpattern/IrPermutation.java
(97%)
rename
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/{queryengine/plan/relational/planner
=>
node_commons/plan/relational/planner/rowpattern}/rowpattern/IrQuantified.java
(96%)
rename
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/{queryengine/plan/relational/planner
=>
node_commons/plan/relational/planner/rowpattern}/rowpattern/IrQuantifier.java
(97%)
rename
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/{queryengine/plan/relational/planner
=>
node_commons/plan/relational/planner/rowpattern}/rowpattern/IrRowPattern.java
(98%)
rename
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/{queryengine/plan/relational/planner
=>
node_commons/plan/relational/planner/rowpattern}/rowpattern/IrRowPatternFlattener.java
(98%)
rename
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/{queryengine/plan/relational/planner
=>
node_commons/plan/relational/planner/rowpattern}/rowpattern/IrRowPatternVisitor.java
(95%)
rename
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/{queryengine/plan/relational/planner
=>
node_commons/plan/relational/planner/rowpattern}/rowpattern/LogicalIndexPointer.java
(98%)
rename
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/{queryengine/plan/relational/planner
=>
node_commons/plan/relational/planner/rowpattern}/rowpattern/MatchNumberValuePointer.java
(94%)
rename
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/{queryengine/plan/relational/planner
=> node_commons/plan/relational/planner/rowpattern}/rowpattern/Patterns.java
(77%)
rename
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/{queryengine/plan/relational/planner
=>
node_commons/plan/relational/planner/rowpattern}/rowpattern/RowPatternToIrRewriter.java
(89%)
rename
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/{queryengine/plan/relational/planner
=>
node_commons/plan/relational/planner/rowpattern}/rowpattern/ScalarValuePointer.java
(94%)
copy
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/{queryengine/plan/relational/planner
=>
node_commons/plan/relational/planner/rowpattern}/rowpattern/ValuePointer.java
(87%)
copy
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/{queryengine/execution/operator/source/relational/aggregation/approximate/ListNode2.java
=> node_commons/plan/relational/sql/ast/CommonQueryAstVisitor.java} (54%)
rename iotdb-core/datanode/src/main/java/org/apache/iotdb/db/{queryengine =>
node_commons}/plan/relational/sql/ast/Expression.java (62%)
rename
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/{queryengine/plan/relational/planner/rowpattern/ValuePointer.java
=> node_commons/plan/relational/sql/ast/IAstVisitor.java} (83%)
rename iotdb-core/datanode/src/main/java/org/apache/iotdb/db/{queryengine =>
node_commons}/plan/relational/sql/ast/Node.java (79%)
rename iotdb-core/datanode/src/main/java/org/apache/iotdb/db/{queryengine =>
node_commons}/plan/relational/sql/ast/StackableAstVisitor.java (92%)
create mode 100644
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/planner/DataNodeTableOperatorGenerator.java
