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

• Type: Sub-task
• Status: Closed
• Priority: Major
• Resolution: Fixed
• Fix Version/s: 1.13.0
• Component/s: API / Python
• Labels: pull-request-available
• Assignee: Wei Zhong
• Reporter: Wei Zhong
• Created: 28/Jan/21 07:58
• Updated: 02/Mar/21 02:32
• Resolved: 02/Mar/21 02:32

Description

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'.

Issue Links

• links to: GitHub Pull Request #14788