[
https://issues.apache.org/jira/browse/FLINK-7439?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16143278#comment-16143278
]
ASF GitHub Bot commented on FLINK-7439:
---------------------------------------
Github user sunjincheng121 commented on a diff in the pull request:
https://github.com/apache/flink/pull/4536#discussion_r135426250
--- Diff:
flink-libraries/flink-table/src/test/java/org/apache/flink/table/runtime/utils/JavaUserDefinedTableFunctions.java
---
@@ -35,4 +35,15 @@ public void eval(Integer a, Long b, Long c) {
collect(c);
}
}
+
+ /**
+ * Emit every input string.
+ */
+ public static class JavaVarsArgTableFunc0 extends TableFunction<String>
{
+ public void eval(String... strs) {
+ for (String s : strs) {
+ collect(s);
+ }
+ }
--- End diff --
Add an other eval for method match check.(only a suggestion).
{code}
public void eval(int ival, String sVal) {
while (ival-- > 0) {
collect(sVal);
}
}
{code}
> Support variable arguments for UDTF in SQL
> ------------------------------------------
>
> Key: FLINK-7439
> URL: https://issues.apache.org/jira/browse/FLINK-7439
> Project: Flink
> Issue Type: Improvement
> Components: Table API & SQL
> Reporter: Jark Wu
> Assignee: Jark Wu
>
> Currently, both UDF and UDAF support variable parameters, but UDTF not.
> FLINK-5882 supports variable UDTF for Table API only, but missed SQL.
--
This message was sent by Atlassian JIRA
(v6.4.14#64029)
