flink-issues mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From "Shaoxuan Wang (JIRA)" <j...@apache.org>
Subject [jira] [Created] (FLINK-6637) Move registerFunction to TableEnvironment
Date Fri, 19 May 2017 13:14:04 GMT
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)

Mime
View raw message