Hello everyone, I would appreciate if someone could please clarify me several things regarding Flink.
Flink 1.10 I'm trying to develop PYTHON stream application using pyflink-stream. I managed successfully to run wordcount.py (in attachment). Now, I would like to go one step further and to use other sources such are Twitter API, Kafka topics or socket. However, unfortunately I did not succeed. 1. Didn't manage to find any connectors on python docs https://ci.apache.org/projects/flink/flink-docs-master/api/python/pyflink.datastream.html 2. I tried to import org.apache.flink.streaming.connectors.twitter.TwitterSource, but got an error "ImportError: No module named connectors" 3. I developed by myself twitter connector (pure python) but realized that it doesn't have sense to use it because it cannot be distributed in a way it would be with flink. Could you please help me with uncertainties that I have to Flink? I would mean very much to me better understanding flink. * Does flink support any other stream connectors except the one from example? * Could I use libraries from JAVA source code (org.apache...) when writing python program? * How can I efficiently what libraries are available for python hence I didn't manage to find from python flink docs? Or can someone give me a hint how can I browse better through docs? * Could someone share with me examples in python or Scala. I've already examined all available on the internet. * What is you plan with flink and python in general? Do you plan to catch up python with java and scala? Thanks, Milan S.
