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/03/02 02:33:00 UTC
[jira] [Commented] (FLINK-21180) Move the state module from
'pyflink.common' to 'pyflink.datastream'
[ https://issues.apache.org/jira/browse/FLINK-21180?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17293302#comment-17293302 ]
Wei Zhong commented on FLINK-21180:
-----------------------------------
Merged via 6c998024e97d02a6a94c34c1e1fdd432d29aa122
> 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
> Priority: Major
> Labels: pull-request-available
> 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)