flink-issues mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From "ASF GitHub Bot (Jira)" <j...@apache.org>
Subject [jira] [Updated] (FLINK-7629) Scala stream aggregations should support nested field expressions
Date Fri, 18 Oct 2019 12:53:00 GMT

     [ https://issues.apache.org/jira/browse/FLINK-7629?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel

ASF GitHub Bot updated FLINK-7629:
    Labels: pull-request-available  (was: )

> Scala stream aggregations should support nested field expressions
> -----------------------------------------------------------------
>                 Key: FLINK-7629
>                 URL: https://issues.apache.org/jira/browse/FLINK-7629
>             Project: Flink
>          Issue Type: Bug
>          Components: API / Scala
>            Reporter: Gabor Gevay
>            Assignee: Gabor Gevay
>            Priority: Minor
>              Labels: pull-request-available
> In the Scala API, {{KeyedStream.maxBy}} and similar methods currently only work with
a field name, and not with nested field expressions, such as "fieldA.fieldX". (Their documentation
says this should work.)
> The reason for this is that the string overload of {{KeyedStream.aggregate}} uses {{fieldNames2Indices}}
and then calls the integer overload. Instead, it should create a {{SumAggregator}} or {{ComparableAggregator}}
directly, as the integer overload does (and as the Java API does). The ctors of {{SumAggregator}}
or {{ComparableAggregator}} will call {{FieldAccessorFactory.getAccessor}}, which will correctly
handle a nested field expression.

This message was sent by Atlassian Jira

View raw message