You are viewing a plain text version of this content. The canonical link for it is here.
Posted to issues@flink.apache.org by "Jark Wu (JIRA)" <ji...@apache.org> on 2017/01/28 06:18:24 UTC
[jira] [Assigned] (FLINK-5678) User-defined TableFunctions do not
support all types of parameters
[ https://issues.apache.org/jira/browse/FLINK-5678?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ]
Jark Wu reassigned FLINK-5678:
------------------------------
Assignee: Jark Wu
> User-defined TableFunctions do not support all types of parameters
> ------------------------------------------------------------------
>
> Key: FLINK-5678
> URL: https://issues.apache.org/jira/browse/FLINK-5678
> Project: Flink
> Issue Type: Bug
> Components: Table API & SQL
> Reporter: Timo Walther
> Assignee: Jark Wu
>
> It seems that TableFunctions do not support all types of parameters. E.g.
> {code}
> XXX.select("1000L AS time").join("mytf(time)");
> public static class MyTableFunction extends TableFunction<Row> {
> public void eval(Long ts) {
> Row r = new Row(2);
> r.setField(0, ts);
> collect(r);
> }
> }
> {code}
> leads to
> {code}
> Exception in thread "main" org.apache.flink.table.codegen.CodeGenException: No matching signature found.
> at org.apache.flink.table.codegen.calls.TableFunctionCallGen$$anonfun$1.apply(TableFunctionCallGen.scala:47)
> at org.apache.flink.table.codegen.calls.TableFunctionCallGen$$anonfun$1.apply(TableFunctionCallGen.scala:47)
> at scala.Option.getOrElse(Option.scala:120)
> at org.apache.flink.table.codegen.calls.TableFunctionCallGen.generate(TableFunctionCallGen.scala:47)
> at org.apache.flink.table.codegen.CodeGenerator.visitCall(CodeGenerator.scala:1011)
> {code}
--
This message was sent by Atlassian JIRA
(v6.3.4#6332)