[ https://issues.apache.org/jira/browse/FLINK-4017?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15362300#comment-15362300 ]
ASF GitHub Bot commented on FLINK-4017: --------------------------------------- Github user zentol commented on a diff in the pull request: https://github.com/apache/flink/pull/2115#discussion_r69535980 --- Diff: docs/apis/batch/dataset_transformations.md --- @@ -1010,7 +1013,10 @@ val output = input.aggregate(SUM, 0).and(MIN, 2) <div data-lang="python" markdown="1"> ~~~python -Not supported. +from flink.functions.Aggregation import Sum, Min + +input = # [...] +output = input.aggregate(Sum, 0).agg_and(Min, 2) --- End diff -- documentation wasn't updated for the rename to `and_agg`. The same applies to the `python.md` > [py] Add Aggregation support to Python API > ------------------------------------------ > > Key: FLINK-4017 > URL: https://issues.apache.org/jira/browse/FLINK-4017 > Project: Flink > Issue Type: Improvement > Components: Python API > Reporter: Geoffrey Mon > Priority: Minor > > Aggregations are not currently supported in the Python API. > I was getting started with setting up and working with Flink and figured this > would be a relatively simple task for me to get started with. Currently > working on this at https://github.com/geofbot/flink -- This message was sent by Atlassian JIRA (v6.3.4#6332)