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)
