gustavodemorais commented on code in PR #26707:
URL: https://github.com/apache/flink/pull/26707#discussion_r2161378566
##########
flink-table/flink-table-planner/src/main/java/org/apache/flink/table/planner/plan/rules/logical/JoinToMultiJoinRule.java:
##########
@@ -345,41 +327,25 @@ private List<RelNode> combineInputs(
* The join type is also set.
*
* @param joinRel join rel
- * @param combinedInputs the combined inputs to the join
* @param left left child of the joinrel
- * @param right right child of the joinrel
* @param joinSpecs the list where the join types and conditions will be
copied
*/
private void combineJoinInfo(
- Join joinRel,
- List<RelNode> combinedInputs,
- RelNode left,
- RelNode right,
- List<Pair<JoinRelType, RexNode>> joinSpecs,
- List<Boolean> inputNullGenFieldList) {
+ Join joinRel, RelNode left, List<Pair<JoinRelType, RexNode>>
joinSpecs) {
JoinRelType joinType = joinRel.getJoinType();
- JoinInfo joinInfo = joinRel.analyzeCondition();
- ImmutableIntList leftKeys = joinInfo.leftKeys;
final RexBuilder rexBuilder = joinRel.getCluster().getRexBuilder();
boolean leftCombined = canCombine(left, joinRel);
switch (joinType) {
case LEFT:
- if (leftCombined) {
- copyJoinInfo((MultiJoin) left, joinSpecs);
- } else {
- joinSpecs.add(Pair.of(JoinRelType.INNER,
rexBuilder.makeLiteral(true)));
- }
- joinSpecs.add(Pair.of(joinType, joinRel.getCondition()));
- break;
case INNER:
if (leftCombined) {
copyJoinInfo((MultiJoin) left, joinSpecs);
} else {
joinSpecs.add(Pair.of(JoinRelType.INNER,
rexBuilder.makeLiteral(true)));
}
Review Comment:
They were
##########
flink-table/flink-table-planner/src/main/java/org/apache/flink/table/planner/plan/rules/logical/JoinToMultiJoinRule.java:
##########
@@ -709,9 +673,7 @@ private boolean isIntervalJoin(Join join) {
return true;
}
- FlinkLogicalJoin flinkLogicalJoin =
- (FlinkLogicalJoin) FlinkLogicalJoin.CONVERTER().convert(join);
- return IntervalJoinUtil.satisfyIntervalJoin(flinkLogicalJoin);
+ return IntervalJoinUtil.satisfyIntervalJoin(join);
Review Comment:
👍
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
To unsubscribe, e-mail: [email protected]
For queries about this service, please contact Infrastructure at:
[email protected]
