flink-issues mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From "Chuyang Wan (JIRA)" <j...@apache.org>
Subject [jira] [Commented] (FLINK-4575) DataSet aggregate methods should support POJOs
Date Fri, 10 Nov 2017 23:13:00 GMT

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

Mime
View raw message