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)