根据这里的文件： https://ci.apache.org/projects/flink/flink-docs-release-1.11/dev/table/connectors/ 和 https://ci.apache.org/projects/flink/flink-docs-release-1.11/dev/table/connectors/ 有没有可能创建一个自定义的ddl rabbitmq连接器，以便在pyflink表api 1.11中使用？怎样？
https://ci.apache.org/projects/flink/flink-docs-release-1.11/dev/table/connectors/
jum4pzuy1#
首先，您需要基于java提供的接口实现自定义连接器实现。然后您需要使用api或命令行参数来引用您可以引用的jarhttps://ci.apache.org/projects/flink/flink-docs-release-1.11/dev/table/python/common_questions.html#adding-jar文件
1条答案
按热度按时间jum4pzuy1#
首先，您需要基于java提供的接口实现自定义连接器实现。然后您需要使用api或命令行参数来引用您可以引用的jarhttps://ci.apache.org/projects/flink/flink-docs-release-1.11/dev/table/python/common_questions.html#adding-jar文件