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)

Reply via email to