[jira] [Created] (FLINK-6637) Move registerFunction to TableEnvironment

[Shang Yuanchun (Jira)]

Shaoxuan Wang created FLINK-6637:
------------------------------------

             Summary: Move registerFunction to TableEnvironment
                 Key: FLINK-6637
                 URL: https://issues.apache.org/jira/browse/FLINK-6637
             Project: Flink
          Issue Type: Improvement
            Reporter: Shaoxuan Wang
            Assignee: Shaoxuan Wang


We are trying to unify the stream and batch. This unification should cover the tableAPI&SQL query as well as the function registration (as part of DDL).
Currently the registerFunction for UDTF and UDAGG are defined in BatchTableEnvironment and StreamTableEnvironment separately.  We should move registerFunction to TableEnvironment.

The reason that we did not put registerFunction into TableEnvironment for UDTF and UDAGG is that we need different registerFunction for java and scala codes, as java needs a special way to generate and pass implicit value of typeInfo:
{code:xml}
    implicit val typeInfo: TypeInformation[T] = TypeExtractor
      .createTypeInfo(tf, classOf[TableFunction[_]], tf.getClass, 0)
      .asInstanceOf[TypeInformation[T]]
{code}

It seems that we need duplicate TableEnvironment class, one for java and one for scala.




--
This message was sent by Atlassian JIRA
(v6.3.15#6346)