[jira] [Created] (FLINK-5678) User-defined TableFunctions do not support all types of parameters

["Timo Walther (JIRA)" <ji...@apache.org>]

Timo Walther created FLINK-5678:
-----------------------------------

             Summary: 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


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)