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

Posted to issues@flink.apache.org by "Wei Zhong (Jira)" <ji...@apache.org> on 2021/01/28 07:59:00 UTC

[jira] [Created] (FLINK-21180) Move the state module from 'pyflink.common' to 'pyflink.datastream'

Wei Zhong created FLINK-21180:
---------------------------------

             Summary: Move the state module from 'pyflink.common' to 'pyflink.datastream'
                 Key: FLINK-21180
                 URL: https://issues.apache.org/jira/browse/FLINK-21180
             Project: Flink
          Issue Type: Sub-task
          Components: API / Python
            Reporter: Wei Zhong
             Fix For: 1.13.0


Currently we put all the DataStream Functions to 'pyflink.datastream.functions' module and all the State API to 'pyflink.common.state' module. But the ReducingState and AggregatingState depend on ReduceFunction and AggregateFunction, which means the 'state' module will depend the 'functions' module. So we need to move the 'state' module to 'pyflink.datastream' package to avoid circular dependencies between 'pyflink.datastream' and 'pyflink.common'.



--
This message was sent by Atlassian Jira
(v8.3.4#803005)