You are viewing a plain text version of this content. The canonical link for it is here.
Posted to issues@flink.apache.org by "Shaoxuan Wang (JIRA)" <ji...@apache.org> on 2017/05/19 13:14:04 UTC
[jira] [Created] (FLINK-6637) Move registerFunction to
TableEnvironment
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)