[jira] [Commented] (FLINK-4575) DataSet aggregate methods should support POJOs
[
https://issues.apache.org/jira/browse/FLINK-4575?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16248142#comment-16248142
]
Chuyang Wan commented on FLINK-4575:
[~ggevay], if you are ok with converting the POJO to a Tuple via getFlatFields,
I can take the task. The idea is, to take POJO field for aggregation operators'
argument, and convert it to tuple field, then just use the tuple field as what
the current program does.
> DataSet aggregate methods should support POJOs
> --
>
> Key: FLINK-4575
> URL: https://issues.apache.org/jira/browse/FLINK-4575
> Project: Flink
> Issue Type: Improvement
> Components: DataSet API
>Reporter: Gabor Gevay
>Priority: Minor
> Labels: starter
>
> The aggregate methods of DataSets (aggregate, sum, min, max) currently only
> support Tuples, with the fields specified by indices. With
> https://issues.apache.org/jira/browse/FLINK-3702 resolved, adding support for
> POJOs and field expressions would be easy: {{AggregateOperator}} would create
> {{FieldAccessors}} instead of just storing field positions, and
> {{AggregateOperator.AggregatingUdf}} would use these {{FieldAccessors}}
> instead of the Tuple field access methods.
--
This message was sent by Atlassian JIRA
(v6.4.14#64029)
[jira] [Commented] (FLINK-4575) DataSet aggregate methods should support POJOs
[
https://issues.apache.org/jira/browse/FLINK-4575?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16247175#comment-16247175
]
Chuyang Wan commented on FLINK-4575:
How about converting the POJO to a Tuple via getFlatFields? Just a thought...
> DataSet aggregate methods should support POJOs
> --
>
> Key: FLINK-4575
> URL: https://issues.apache.org/jira/browse/FLINK-4575
> Project: Flink
> Issue Type: Improvement
> Components: DataSet API
>Reporter: Gabor Gevay
>Priority: Minor
> Labels: starter
>
> The aggregate methods of DataSets (aggregate, sum, min, max) currently only
> support Tuples, with the fields specified by indices. With
> https://issues.apache.org/jira/browse/FLINK-3702 resolved, adding support for
> POJOs and field expressions would be easy: {{AggregateOperator}} would create
> {{FieldAccessors}} instead of just storing field positions, and
> {{AggregateOperator.AggregatingUdf}} would use these {{FieldAccessors}}
> instead of the Tuple field access methods.
--
This message was sent by Atlassian JIRA
(v6.4.14#64029)
