[
https://issues.apache.org/jira/browse/FLINK-22451?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Yi Tang updated FLINK-22451:
----------------------------
Description:
For now, one can use star \(*) to act as a wild card, selecting all of the
columns in the table.
{code:java}
Table result = orders.select($("*"));
{code}
When one use a star \(*) as parameter of an UDF, it will fail
{{ReferenceResolverRule}} in on
{code:java}
"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(the last parameter is also ok) of the UDF.
then the parameters can be received by
{code:java}
eval(@DataTypeHint(inputGroup = InputGroup.ANY) Object... row)
{code}
was:
For now, one can use star (*) to act as a wild card, selecting all of the
columns in the table.
{code:java}
Table result = orders.select($("*"));
{code}
When one use a star (*) as parameter of an UDF, it will fail
{{ReferenceResolverRule}} in on
{code:java}
"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(the last parameter is also ok) of the UDF.
then the parameters can be received by
{code:java}
eval(@DataTypeHint(inputGroup = InputGroup.ANY) Object... row)
{code}
> 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
> Priority: Major
>
> For now, one can use star \(*) to act as a wild card, selecting all of the
> columns in the table.
> {code:java}
> Table result = orders.select($("*"));
> {code}
> When one use a star \(*) as parameter of an UDF, it will fail
> {{ReferenceResolverRule}} in on
> {code:java}
> "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(the last parameter is also ok) of the UDF.
> then the parameters can be received by
> {code:java}
> eval(@DataTypeHint(inputGroup = InputGroup.ANY) Object... row)
> {code}
--
This message was sent by Atlassian Jira
(v8.3.4#803005)
