Skip to content

Commit

Permalink
update
Browse files Browse the repository at this point in the history
  • Loading branch information
snuyanzin committed Mar 3, 2024
1 parent ea8de8a commit de38468
Showing 1 changed file with 2 additions and 15 deletions.
Original file line number Diff line number Diff line change
Expand Up @@ -30,19 +30,12 @@
import java.util.Collections;

/**
* Planner rule that matches a global [[BatchPhysicalRank]] on a local [[BatchPhysicalRank]], and
* merge them into a global [[BatchPhysicalRank]].
* Planner rule that matches a global {@link BatchPhysicalRank} on a local {@link
* BatchPhysicalRank}, and merge them into a global {@link BatchPhysicalRank}.
*/
@Value.Enclosing
public class RemoveRedundantLocalRankRule
extends RelRule<RemoveRedundantLocalRankRule.RemoveRedundantLocalRankRuleConfig> {
// /*(
// operand(
// classOf[BatchPhysicalRank],
// operand(
// classOf[BatchPhysicalRank],
// operand(classOf[RelNode], FlinkConventions.BATCH_PHYSICAL, any))),
// "RemoveRedundantLocalRankRule") {*/

public RemoveRedundantLocalRankRule(RemoveRedundantLocalRankRuleConfig config) {
super(config);
Expand Down Expand Up @@ -106,9 +99,3 @@ public static class RemoveRedundantLocalRankRuleHolder {
RemoveRedundantLocalRankRuleConfig.DEFAULT.toRule();
}
}

/*
object RemoveRedundantLocalRankRule {
val INSTANCE: RelOptRule = new RemoveRedundantLocalRankRule
}
*/

0 comments on commit de38468

Please sign in to comment.