AMashenkov commented on code in PR #5398:
URL: https://github.com/apache/ignite-3/pull/5398#discussion_r1991375745
##########
modules/sql-engine/src/main/java/org/apache/ignite/internal/sql/engine/exec/LogicalRelImplementor.java:
##########
@@ -1104,4 +1123,38 @@ private static BinaryTupleSchema
fromTableDescriptor(TableDescriptor descriptor)
return BinaryTupleSchema.create(elements);
}
+
+ private static boolean canFuseProjectionInto(RelNode rel) {
+ if (rel instanceof Join) {
+ Join join = (Join) rel;
+
+ return joinNeedsProjection(join);
+ }
+
+ return false;
+ }
+
+ private static boolean joinNeedsProjection(Join join) {
+ return join.getJoinType() == JoinRelType.INNER
+ || join.getJoinType() == JoinRelType.LEFT
+ || join.getJoinType() == JoinRelType.FULL
+ || join.getJoinType() == JoinRelType.RIGHT;
+ }
Review Comment:
This can be replaced with EnumSet
```suggestion
EnumSet joinNeedsProjection = EnumSet.of(JoinRelType.INNER,
JoinRelType.LEFT, JoinRelType.FULL, JoinRelType.RIGHT);
// replace old method call with `joinNeedsProjection.contains(join)`
```
--
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: notifications-unsubscr...@ignite.apache.org
For queries about this service, please contact Infrastructure at:
us...@infra.apache.org
