[
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}
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}
was:
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}
> 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}
> 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)
