Dian Fu created FLINK-27564:
-------------------------------
Summary: 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
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)