You are viewing a plain text version of this content. The canonical link for it is here.

Posted to issues@flink.apache.org by "Dian Fu (Jira)" <ji...@apache.org> on 2022/05/13 08:43:00 UTC

[jira] [Closed] (FLINK-27564) Split PyFlink DataStream connectors into separate files

     [ https://issues.apache.org/jira/browse/FLINK-27564?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ]

Dian Fu closed FLINK-27564.
---------------------------
    Resolution: Fixed

Merged to master via 3595a73d8cb0750cafcc4b7dc7ff91ef86ed7147

> Split PyFlink DataStream connectors into separate files
> -------------------------------------------------------
>
>                 Key: FLINK-27564
>                 URL: https://issues.apache.org/jira/browse/FLINK-27564
>             Project: Flink
>          Issue Type: Technical Debt
>          Components: API / Python
>            Reporter: Dian Fu
>            Assignee: Dian Fu
>            Priority: Major
>              Labels: pull-request-available
>             Fix For: 1.16.0
>
>
> Currently all the connectors are located in [connectors.py|https://github.com/apache/flink/blob/master/flink-python/pyflink/datastream/connectors.py]. As more and more connectors are added, it makes this file more and more big. Besides, it's confusing for users as it's not clear for users which classes belonging to which connectors. It would be great to split different connectors into different files, e.g. pyflink/datastream/connectors/jdbc.py, 
> pyflink/datastream/connectors/file_system.py, etc.
> However, it should be taken into account to keep backward compatibility when performing this refactor.



--
This message was sent by Atlassian Jira
(v8.20.7#820007)