Re: Flink stream python

2019-09-13 Thread Dian Fu
Hi Milan, Hoping Till has answered your questions. WRT whether it supports to use libraries from Java code in Python, the answer is yes. Regarding to use Java connectors in Python, there are two ways: 1) If there is a Java TableFactory[1] defined for the connector, you could try to use the pyf

Re: Flink stream python

2019-09-13 Thread Till Rohrmann
Hi Milan, I can only give you some high level answers because I'm not actively involved in the development of Flink's Python support. But I've cc'ed Jincheng who is driving this effort and can give you more detailed answers. At the moment, Flink's Python API can be seen as a thin wrapper around F

Flink stream python

2019-09-13 Thread Milan Simaković
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