database/doris
2
0
Fork 0
Code Issues Pull Requests Actions 3 Packages Projects Releases Wiki Activity

[refactor](Nereids) remove useless explaration job in cascades framework (#13545)

Browse Source
This commit is contained in:
morrySnow
2022-10-24 10:33:24 +08:00
committed by GitHub
parent d266b8fb50
commit 4754ccf16b
3 changed files with 0 additions and 126 deletions
Download Patch File Download Diff File Expand all files Collapse all files

7
fe/fe-core/src/main/java/org/apache/doris/nereids/jobs/cascades/ApplyRuleJob.java
View File

@ -36,7 +36,6 @@ import java.util.List;
public class ApplyRuleJob extends Job {
private final GroupExpression groupExpression;
private final Rule rule;
private final boolean exploredOnly;
/**
* Constructor of ApplyRuleJob.
@ -49,7 +48,6 @@ public class ApplyRuleJob extends Job {
super(JobType.APPLY_RULE, context);
this.groupExpression = groupExpression;
this.rule = rule;
this.exploredOnly = false;
}
@Override
@ -73,11 +71,6 @@ public class ApplyRuleJob extends Job {
GroupExpression newGroupExpression = result.correspondingExpression;
if (newPlan instanceof LogicalPlan) {
if (exploredOnly) {
pushJob(new ExploreGroupExpressionJob(newGroupExpression, context));
pushJob(new DeriveStatsJob(newGroupExpression, context));
continue;
}
pushJob(new OptimizeGroupExpressionJob(newGroupExpression, context));
pushJob(new DeriveStatsJob(newGroupExpression, context));
} else {

66
fe/fe-core/src/main/java/org/apache/doris/nereids/jobs/cascades/ExploreGroupExpressionJob.java
View File

@ -1,66 +0,0 @@
// Licensed to the Apache Software Foundation (ASF) under one
// or more contributor license agreements. See the NOTICE file
// distributed with this work for additional information
// regarding copyright ownership. The ASF licenses this file
// to you under the Apache License, Version 2.0 (the
// "License"); you may not use this file except in compliance
// with the License. You may obtain a copy of the License at
//
// http://www.apache.org/licenses/LICENSE-2.0
//
// Unless required by applicable law or agreed to in writing,
// software distributed under the License is distributed on an
// "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY
// KIND, either express or implied. See the License for the
// specific language governing permissions and limitations
// under the License.
package org.apache.doris.nereids.jobs.cascades;
import org.apache.doris.nereids.jobs.Job;
import org.apache.doris.nereids.jobs.JobContext;
import org.apache.doris.nereids.jobs.JobType;
import org.apache.doris.nereids.memo.Group;
import org.apache.doris.nereids.memo.GroupExpression;
import org.apache.doris.nereids.pattern.Pattern;
import org.apache.doris.nereids.rules.Rule;
import java.util.Comparator;
import java.util.List;
/**
* Job to explore {@link GroupExpression} in {@link org.apache.doris.nereids.memo.Memo}.
*/
public class ExploreGroupExpressionJob extends Job {
private final GroupExpression groupExpression;
/**
* Constructor for ExplorePlanJob.
*
* @param groupExpression {@link GroupExpression} to be explored
* @param context context of current job
*/
public ExploreGroupExpressionJob(GroupExpression groupExpression, JobContext context) {
super(JobType.EXPLORE_PLAN, context);
this.groupExpression = groupExpression;
}
@Override
public void execute() {
// TODO: enable exploration job after we test it
List<Rule> explorationRules = getRuleSet().getExplorationRules();
List<Rule> validRules = getValidRules(groupExpression, explorationRules);
validRules.sort(Comparator.comparingInt(o -> o.getRulePromise().promise()));
for (Rule rule : validRules) {
pushJob(new ApplyRuleJob(groupExpression, rule, context));
for (int i = 0; i < rule.getPattern().children().size(); ++i) {
Pattern childPattern = rule.getPattern().child(i);
if (childPattern.arity() > 0 && !childPattern.isGroup()) {
Group child = groupExpression.child(i);
pushJob(new ExploreGroupJob(child, context));
}
}
}
}
}

53
fe/fe-core/src/main/java/org/apache/doris/nereids/jobs/cascades/ExploreGroupJob.java
View File

@ -1,53 +0,0 @@
// Licensed to the Apache Software Foundation (ASF) under one
// or more contributor license agreements. See the NOTICE file
// distributed with this work for additional information
// regarding copyright ownership. The ASF licenses this file
// to you under the Apache License, Version 2.0 (the
// "License"); you may not use this file except in compliance
// with the License. You may obtain a copy of the License at
//
// http://www.apache.org/licenses/LICENSE-2.0
//
// Unless required by applicable law or agreed to in writing,
// software distributed under the License is distributed on an
// "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY
// KIND, either express or implied. See the License for the
// specific language governing permissions and limitations
// under the License.
package org.apache.doris.nereids.jobs.cascades;
import org.apache.doris.nereids.jobs.Job;
import org.apache.doris.nereids.jobs.JobContext;
import org.apache.doris.nereids.jobs.JobType;
import org.apache.doris.nereids.memo.Group;
import org.apache.doris.nereids.memo.GroupExpression;
/**
* Job to explore {@link Group} in {@link org.apache.doris.nereids.memo.Memo}.
*/
public class ExploreGroupJob extends Job {
private final Group group;
/**
* Constructor for ExploreGroupJob.
*
* @param group {@link Group} to be explored
* @param context context of current job
*/
public ExploreGroupJob(Group group, JobContext context) {
super(JobType.EXPLORE_PLAN_SET, context);
this.group = group;
}
@Override
public void execute() {
if (group.isExplored()) {
return;
}
for (GroupExpression groupExpression : group.getLogicalExpressions()) {
pushJob(new ExploreGroupExpressionJob(groupExpression, context));
}
group.setExplored(true);
}
}