You are viewing a plain text version of this content. The canonical link for it is here.

Posted to dev@flink.apache.org by "CaoYu (Jira)" <ji...@apache.org> on 2022/03/11 11:14:00 UTC

[jira] [Created] (FLINK-26609) Add a "sum" operator In PyFlink KeyedStream API

CaoYu created FLINK-26609:
-----------------------------

             Summary: Add a "sum" operator In PyFlink KeyedStream API
                 Key: FLINK-26609
                 URL: https://issues.apache.org/jira/browse/FLINK-26609
             Project: Flink
          Issue Type: New Feature
          Components: API / Python
    Affects Versions: 1.14.3
            Reporter: CaoYu


In Java, KeyedStream has a "sum" operator, But when i using in PyFlink. that operator is not found.

 

So i implemented it in Python Flink KeyedStream And test has passed.

 

But i don't know if this feature is necessary in PyFlink.

so i send a jira task in here, we can discuss it.

 

If that feature is necessary, i have already implemented that feature so i can summit a PR in github.

 

Thansks.



--
This message was sent by Atlassian Jira
(v8.20.1#820001)