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)