Skip to content

Commit

Permalink
[FLINK-34492][table] Fix comment link when migrate calcite rules from…
Browse files Browse the repository at this point in the history
… scala to java
  • Loading branch information
liuyongvs authored Mar 1, 2024
1 parent 7c8e3f5 commit 46cbf22
Show file tree
Hide file tree
Showing 3 changed files with 14 additions and 8 deletions.
Original file line number Diff line number Diff line change
Expand Up @@ -30,18 +30,21 @@
import org.immutables.value.Value;

/**
* This rule is copied from Calcite's [[org.apache.calcite.rel.rules.CalcMergeRule]].
* This rule is copied from Calcite's {@link org.apache.calcite.rel.rules.CalcMergeRule}.
*
* <p>Modification: - Condition in the merged program will be simplified if it exists. - If the two
* [[Calc]] can merge into one, each non-deterministic [[RexNode]] of bottom [[Calc]] should appear
* at most once in the project list and filter list of top [[Calc]].
* {@link org.apache.calcite.rel.core.Calc} can merge into one, each non-deterministic {@link
* org.apache.calcite.rex.RexNode} of bottom {@link org.apache.calcite.rel.core.Calc} should appear
* at most once in the project list and filter list of top {@link org.apache.calcite.rel.core.Calc}.
*/

/**
* Planner rule that merges a [[Calc]] onto a [[Calc]].
* Planner rule that merges a {@link org.apache.calcite.rel.core.Calc} onto a {@link
* org.apache.calcite.rel.core.Calc}.
*
* <p>The resulting [[Calc]] has the same project list as the upper [[Calc]], but expressed in terms
* of the lower [[Calc]]'s inputs.
* <p>The resulting {@link org.apache.calcite.rel.core.Calc} has the same project list as the upper
* {@link org.apache.calcite.rel.core.Calc}, but expressed in terms of the lower {@link
* org.apache.calcite.rel.core.Calc}'s inputs.
*/
@Value.Enclosing
public class FlinkCalcMergeRule extends RelRule<FlinkCalcMergeRule.FlinkCalcMergeRuleConfig> {
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -25,7 +25,7 @@
import org.apache.calcite.rex.RexLiteral;
import org.immutables.value.Value;

/** Planner rule that rewrites `limit 0` to empty [[org.apache.calcite.rel.core.Values]]. */
/** Planner rule that rewrites `limit 0` to empty {@link org.apache.calcite.rel.core.Values}. */
@Value.Enclosing
public class FlinkLimit0RemoveRule
extends RelRule<FlinkLimit0RemoveRule.FlinkLimit0RemoveRuleConfig> {
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -25,7 +25,10 @@
import org.apache.calcite.rel.logical.LogicalTableFunctionScan;
import org.immutables.value.Value;

/** Rule that rewrites Join on TableFunctionScan to Correlate. */
/**
* Rule that rewrites {@link org.apache.calcite.rel.core.Join} on {@link
* org.apache.calcite.rel.core.TableFunctionScan} to {@link org.apache.calcite.rel.core.Correlate}.
*/
@Value.Enclosing
public class JoinTableFunctionScanToCorrelateRule
extends RelRule<JoinTableFunctionScanToCorrelateRule.Config> {
Expand Down

0 comments on commit 46cbf22

Please sign in to comment.