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)