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)
