[ https://issues.apache.org/jira/browse/FLINK-4575?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=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)