[ https://issues.apache.org/jira/browse/FLINK-6637?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ]
Shaoxuan Wang updated FLINK-6637: --------------------------------- Component/s: Table API & SQL > Move registerFunction to TableEnvironment > ----------------------------------------- > > Key: FLINK-6637 > URL: https://issues.apache.org/jira/browse/FLINK-6637 > Project: Flink > Issue Type: Improvement > Components: Table API & SQL > 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)