Hequn Cheng created FLINK-16119: ----------------------------------- Summary: Port base RelNode classes from Scala to Java Key: FLINK-16119 URL: https://issues.apache.org/jira/browse/FLINK-16119 Project: Flink Issue Type: Improvement Components: Table SQL / Legacy Planner, Table SQL / Planner Reporter: Hequn Cheng
Currently, when adding new Flink RelNodes, we have to write a Scala one due to the problem that we can't use the implemented methods of a Scala trait from Java([see details|https://alvinalexander.com/scala/how-to-wrap-scala-traits-used-accessed-java-classes-methods]). Take DataStreamCorrelate as an example, it extends both CommonCorrelate and DataStreamRel and we can't convert DataStreamCorrelate to Java directly. It would be great if we can convert these base RelNode classes(CommonCorrelate, DataStreamRel, etc) from Scala to Java so that we can add new Java RelNodes and convert the existed RelNodes to Java. CC [~twalthr] -- This message was sent by Atlassian Jira (v8.3.4#803005)