You are viewing a plain text version of this content. The canonical link for it is here.

Posted to dev@flink.apache.org by "Hequn Cheng (Jira)" <ji...@apache.org> on 2020/02/17 13:48:00 UTC

[jira] [Created] (FLINK-16119) Port base RelNode classes from Scala to Java

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)