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

classic Classic list List threaded Threaded
1 message Options
Reply | Threaded
Open this post in threaded view
|

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

Shang Yuanchun (Jira)
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)