api implementation of a third party pyflink connector
Hi Zhongle Wang,
Your understanding is correct. Firstly, you need to provide an implementation
of a java connector, then add this jar to the dependency[1], and finally add a
python connector wrapper.
[1]
https://ci.apache.org/projects/flink
Hi Zhongle Wang,
Your understanding is correct. Firstly, you need to provide an
implementation of a java connector, then add this jar to the dependency[1],
and finally add a python connector wrapper.
[1]
https://ci.apache.org/projects/flink/flink-docs-release-1.13/docs/dev/python/faq/#adding-jar-
Hi,
I'm working on a pyflink datastream connector for Pravega and wish to use a
datasource other than Kafka.
Currently the Kafka connector for the python datastream api is implemented
using a ` get_gateway` function which creates a binding to java in `
FlinkKafkaConsumer`.
So if I want to cre
