This is an automated email from the ASF dual-hosted git repository. hui pushed a commit to branch lmh/fixLimitBug1.1 in repository https://gitbox.apache.org/repos/asf/iotdb.git
commit ba723a0cb52b8cd36198592fbfb38ab25511b679 Author: Minghui Liu <[email protected]> AuthorDate: Thu Mar 23 16:04:18 2023 +0800 fix plan visitor --- .../db/mpp/plan/planner/plan/node/PlanVisitor.java | 188 ++++++++++++--------- 1 file changed, 104 insertions(+), 84 deletions(-) diff --git a/server/src/main/java/org/apache/iotdb/db/mpp/plan/planner/plan/node/PlanVisitor.java b/server/src/main/java/org/apache/iotdb/db/mpp/plan/planner/plan/node/PlanVisitor.java index cf3fbe02af..d9430963ff 100644 --- a/server/src/main/java/org/apache/iotdb/db/mpp/plan/planner/plan/node/PlanVisitor.java +++ b/server/src/main/java/org/apache/iotdb/db/mpp/plan/planner/plan/node/PlanVisitor.java @@ -97,15 +97,13 @@ public abstract class PlanVisitor<R, C> { public abstract R visitPlan(PlanNode node, C context); - public R visitSourceNode(SourceNode node, C context) { - return visitPlan(node, context); - } + ///////////////////////////////////////////////////////////////////////////////////////////////// + // Data Query Node + ///////////////////////////////////////////////////////////////////////////////////////////////// - public R visitSingleChildProcess(SingleChildProcessNode node, C context) { - return visitPlan(node, context); - } + // source -------------------------------------------------------------------------------------- - public R visitMultiChildProcess(MultiChildProcessNode node, C context) { + public R visitSourceNode(SourceNode node, C context) { return visitPlan(node, context); } @@ -125,12 +123,18 @@ public abstract class PlanVisitor<R, C> { return visitSourceNode(node, context); } - public R visitDeviceView(DeviceViewNode node, C context) { - return visitMultiChildProcess(node, context); + public R visitLastQueryScan(LastQueryScanNode node, C context) { + return visitSourceNode(node, context); } - public R visitDeviceMerge(DeviceMergeNode node, C context) { - return visitMultiChildProcess(node, context); + public R visitAlignedLastQueryScan(AlignedLastQueryScanNode node, C context) { + return visitSourceNode(node, context); + } + + // single child -------------------------------------------------------------------------------- + + public R visitSingleChildProcess(SingleChildProcessNode node, C context) { + return visitPlan(node, context); } public R visitFill(FillNode node, C context) { @@ -141,239 +145,255 @@ public abstract class PlanVisitor<R, C> { return visitSingleChildProcess(node, context); } - public R visitGroupByLevel(GroupByLevelNode node, C context) { - return visitMultiChildProcess(node, context); + public R visitSlidingWindowAggregation(SlidingWindowAggregationNode node, C context) { + return visitSingleChildProcess(node, context); } - public R visitGroupByTag(GroupByTagNode node, C context) { - return visitMultiChildProcess(node, context); + public R visitLimit(LimitNode node, C context) { + return visitSingleChildProcess(node, context); } - public R visitSlidingWindowAggregation(SlidingWindowAggregationNode node, C context) { + public R visitOffset(OffsetNode node, C context) { return visitSingleChildProcess(node, context); } - public R visitLimit(LimitNode node, C context) { + public R visitSort(SortNode node, C context) { return visitSingleChildProcess(node, context); } - public R visitOffset(OffsetNode node, C context) { + public R visitProject(ProjectNode node, C context) { return visitSingleChildProcess(node, context); } - public R visitAggregation(AggregationNode node, C context) { - return visitMultiChildProcess(node, context); + public R visitExchange(ExchangeNode node, C context) { + return visitSingleChildProcess(node, context); } - public R visitSort(SortNode node, C context) { + public R visitTransform(TransformNode node, C context) { return visitSingleChildProcess(node, context); } - public R visitProject(ProjectNode node, C context) { + public R visitInto(IntoNode node, C context) { return visitSingleChildProcess(node, context); } - public R visitTimeJoin(TimeJoinNode node, C context) { - return visitMultiChildProcess(node, context); + public R visitDeviceViewInto(DeviceViewIntoNode node, C context) { + return visitSingleChildProcess(node, context); } - public R visitExchange(ExchangeNode node, C context) { + public R visitSingleDeviceView(SingleDeviceViewNode node, C context) { return visitSingleChildProcess(node, context); } - public R visitSchemaQueryMerge(SchemaQueryMergeNode node, C context) { + // multi child -------------------------------------------------------------------------------- + + public R visitMultiChildProcess(MultiChildProcessNode node, C context) { return visitPlan(node, context); } - public R visitSchemaQueryScan(SchemaQueryScanNode node, C context) { - return visitPlan(node, context); + public R visitDeviceView(DeviceViewNode node, C context) { + return visitMultiChildProcess(node, context); } - public R visitSchemaQueryOrderByHeat(SchemaQueryOrderByHeatNode node, C context) { - return visitPlan(node, context); + public R visitDeviceMerge(DeviceMergeNode node, C context) { + return visitMultiChildProcess(node, context); } - public R visitTimeSeriesSchemaScan(TimeSeriesSchemaScanNode node, C context) { - return visitPlan(node, context); + public R visitGroupByLevel(GroupByLevelNode node, C context) { + return visitMultiChildProcess(node, context); } - public R visitDevicesSchemaScan(DevicesSchemaScanNode node, C context) { - return visitPlan(node, context); + public R visitGroupByTag(GroupByTagNode node, C context) { + return visitMultiChildProcess(node, context); } - public R visitDevicesCount(DevicesCountNode node, C context) { - return visitPlan(node, context); + public R visitAggregation(AggregationNode node, C context) { + return visitMultiChildProcess(node, context); } - public R visitTimeSeriesCount(TimeSeriesCountNode node, C context) { - return visitPlan(node, context); + public R visitTimeJoin(TimeJoinNode node, C context) { + return visitMultiChildProcess(node, context); } - public R visitLevelTimeSeriesCount(LevelTimeSeriesCountNode node, C context) { - return visitPlan(node, context); + public R visitLastQuery(LastQueryNode node, C context) { + return visitMultiChildProcess(node, context); } - public R visitCountMerge(CountSchemaMergeNode node, C context) { - return visitPlan(node, context); + public R visitLastQueryMerge(LastQueryMergeNode node, C context) { + return visitMultiChildProcess(node, context); } - public R visitCreateTimeSeries(CreateTimeSeriesNode node, C context) { - return visitPlan(node, context); + public R visitLastQueryCollect(LastQueryCollectNode node, C context) { + return visitMultiChildProcess(node, context); } - public R visitSchemaFetchMerge(SchemaFetchMergeNode node, C context) { - return visitPlan(node, context); + public R visitMergeSort(MergeSortNode node, C context) { + return visitMultiChildProcess(node, context); } - public R visitSchemaFetchScan(SchemaFetchScanNode node, C context) { + public R visitHorizontallyConcat(HorizontallyConcatNode node, C context) { + return visitMultiChildProcess(node, context); + } + + // others ----------------------------------------------------------------------------------- + + public R visitShowQueries(ShowQueriesNode node, C context) { return visitPlan(node, context); } - public R visitCreateAlignedTimeSeries(CreateAlignedTimeSeriesNode node, C context) { + public R visitIdentitySink(IdentitySinkNode node, C context) { return visitPlan(node, context); } - public R visitCreateMultiTimeSeries(CreateMultiTimeSeriesNode node, C context) { + public R visitShuffleSink(ShuffleSinkNode node, C context) { return visitPlan(node, context); } - public R visitAlterTimeSeries(AlterTimeSeriesNode node, C context) { + ///////////////////////////////////////////////////////////////////////////////////////////////// + // Schema Write & Query Node + ///////////////////////////////////////////////////////////////////////////////////////////////// + + public R visitSchemaQueryMerge(SchemaQueryMergeNode node, C context) { return visitPlan(node, context); } - public R visitTransform(TransformNode node, C context) { + public R visitSchemaQueryScan(SchemaQueryScanNode node, C context) { return visitPlan(node, context); } - public R visitInsertRow(InsertRowNode node, C context) { + public R visitSchemaQueryOrderByHeat(SchemaQueryOrderByHeatNode node, C context) { return visitPlan(node, context); } - public R visitInsertTablet(InsertTabletNode node, C context) { + public R visitTimeSeriesSchemaScan(TimeSeriesSchemaScanNode node, C context) { return visitPlan(node, context); } - public R visitInsertRows(InsertRowsNode node, C context) { + public R visitDevicesSchemaScan(DevicesSchemaScanNode node, C context) { return visitPlan(node, context); } - public R visitInsertMultiTablets(InsertMultiTabletsNode node, C context) { + public R visitDevicesCount(DevicesCountNode node, C context) { return visitPlan(node, context); } - public R visitInsertRowsOfOneDevice(InsertRowsOfOneDeviceNode node, C context) { + public R visitTimeSeriesCount(TimeSeriesCountNode node, C context) { return visitPlan(node, context); } - public R visitNodePathsSchemaScan(NodePathsSchemaScanNode node, C context) { + public R visitLevelTimeSeriesCount(LevelTimeSeriesCountNode node, C context) { return visitPlan(node, context); } - public R visitNodeManagementMemoryMerge(NodeManagementMemoryMergeNode node, C context) { + public R visitCountMerge(CountSchemaMergeNode node, C context) { return visitPlan(node, context); } - public R visitNodePathConvert(NodePathsConvertNode node, C context) { + public R visitCreateTimeSeries(CreateTimeSeriesNode node, C context) { return visitPlan(node, context); } - public R visitNodePathsCount(NodePathsCountNode node, C context) { + public R visitSchemaFetchMerge(SchemaFetchMergeNode node, C context) { return visitPlan(node, context); } - public R visitLastQueryScan(LastQueryScanNode node, C context) { + public R visitSchemaFetchScan(SchemaFetchScanNode node, C context) { return visitPlan(node, context); } - public R visitAlignedLastQueryScan(AlignedLastQueryScanNode node, C context) { + public R visitCreateAlignedTimeSeries(CreateAlignedTimeSeriesNode node, C context) { return visitPlan(node, context); } - public R visitLastQuery(LastQueryNode node, C context) { + public R visitCreateMultiTimeSeries(CreateMultiTimeSeriesNode node, C context) { return visitPlan(node, context); } - public R visitLastQueryMerge(LastQueryMergeNode node, C context) { + public R visitAlterTimeSeries(AlterTimeSeriesNode node, C context) { return visitPlan(node, context); } - public R visitLastQueryCollect(LastQueryCollectNode node, C context) { + public R visitInternalCreateTimeSeries(InternalCreateTimeSeriesNode node, C context) { return visitPlan(node, context); } - public R visitDeleteTimeseries(DeleteTimeSeriesNode node, C context) { + public R visitActivateTemplate(ActivateTemplateNode node, C context) { return visitPlan(node, context); } - public R visitConstructSchemaBlackList(ConstructSchemaBlackListNode node, C context) { + public R visitPreDeactivateTemplate(PreDeactivateTemplateNode node, C context) { return visitPlan(node, context); } - public R visitRollbackSchemaBlackList(RollbackSchemaBlackListNode node, C context) { + public R visitRollbackPreDeactivateTemplate(RollbackPreDeactivateTemplateNode node, C context) { return visitPlan(node, context); } - public R visitDeleteData(DeleteDataNode node, C context) { + public R visitDeactivateTemplate(DeactivateTemplateNode node, C context) { return visitPlan(node, context); } - public R visitInternalCreateTimeSeries(InternalCreateTimeSeriesNode node, C context) { + public R visitInternalBatchActivateTemplate(InternalBatchActivateTemplateNode node, C context) { return visitPlan(node, context); } - public R visitActivateTemplate(ActivateTemplateNode node, C context) { + public R visitInternalCreateMultiTimeSeries(InternalCreateMultiTimeSeriesNode node, C context) { return visitPlan(node, context); } - public R visitPreDeactivateTemplate(PreDeactivateTemplateNode node, C context) { + public R visitNodePathsSchemaScan(NodePathsSchemaScanNode node, C context) { return visitPlan(node, context); } - public R visitRollbackPreDeactivateTemplate(RollbackPreDeactivateTemplateNode node, C context) { + public R visitNodeManagementMemoryMerge(NodeManagementMemoryMergeNode node, C context) { return visitPlan(node, context); } - public R visitDeactivateTemplate(DeactivateTemplateNode node, C context) { + public R visitNodePathConvert(NodePathsConvertNode node, C context) { return visitPlan(node, context); } - public R visitInto(IntoNode node, C context) { + public R visitNodePathsCount(NodePathsCountNode node, C context) { return visitPlan(node, context); } - public R visitDeviceViewInto(DeviceViewIntoNode node, C context) { + public R visitDeleteTimeseries(DeleteTimeSeriesNode node, C context) { return visitPlan(node, context); } - public R visitSingleDeviceView(SingleDeviceViewNode node, C context) { + public R visitConstructSchemaBlackList(ConstructSchemaBlackListNode node, C context) { return visitPlan(node, context); } - public R visitMergeSort(MergeSortNode node, C context) { + public R visitRollbackSchemaBlackList(RollbackSchemaBlackListNode node, C context) { return visitPlan(node, context); } - public R visitHorizontallyConcat(HorizontallyConcatNode node, C context) { + ///////////////////////////////////////////////////////////////////////////////////////////////// + // Data Write Node + ///////////////////////////////////////////////////////////////////////////////////////////////// + + public R visitInsertRow(InsertRowNode node, C context) { return visitPlan(node, context); } - public R visitShowQueries(ShowQueriesNode node, C context) { + public R visitInsertTablet(InsertTabletNode node, C context) { return visitPlan(node, context); } - public R visitInternalBatchActivateTemplate(InternalBatchActivateTemplateNode node, C context) { + public R visitInsertRows(InsertRowsNode node, C context) { return visitPlan(node, context); } - public R visitInternalCreateMultiTimeSeries(InternalCreateMultiTimeSeriesNode node, C context) { + public R visitInsertMultiTablets(InsertMultiTabletsNode node, C context) { return visitPlan(node, context); } - public R visitIdentitySink(IdentitySinkNode node, C context) { + public R visitInsertRowsOfOneDevice(InsertRowsOfOneDeviceNode node, C context) { return visitPlan(node, context); } - public R visitShuffleSink(ShuffleSinkNode node, C context) { + public R visitDeleteData(DeleteDataNode node, C context) { return visitPlan(node, context); } }
