[jira] [Created] (FLINK-22451) Support (*) as parameter of table UserDefinedFunction

classic Classic list List threaded Threaded
1 message Options
Reply | Threaded
Open this post in threaded view
|

[jira] [Created] (FLINK-22451) Support (*) as parameter of table UserDefinedFunction

Shang Yuanchun (Jira)
Yi Tang created FLINK-22451:
-------------------------------

             Summary: Support (*) as parameter of table UserDefinedFunction
                 Key: FLINK-22451
                 URL: https://issues.apache.org/jira/browse/FLINK-22451
             Project: Flink
          Issue Type: Improvement
            Reporter: Yi Tang


For now, one can use star (*) to act as a wild card, selecting all of the columns in the table.
{code}
Table result = orders.select($("*"));
{code}

When one use a star (*) as parameter of an UDF, it will fail {{ReferenceResolverRule}} in on
{code}
"Cannot resolve field [*], input field list:[...]."
{code}

The cause is that, the parameter of an UDF is not expanded in {{StarReferenceFlatteningRule}}

I think we can support to expand the star parameter to the real fields list if it is the only parameter of the UDF.

then the parameters can be received by
{code}
eval(@DataTypeHint(inputGroup = InputGroup.ANY) Object... row)
{code}



--
This message was sent by Atlassian Jira
(v8.3.4#803005)