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)