Re: Jython support for Flink

2019-07-20 Thread Zili Chen
te the pipeline > through beam and flink instead of kafka and flink, as i see that python is > a full class citizen in the beam framework! > > Regards, > Dante > > Op 20 jul. 2019 om 01:59 heeft Zili Chen het > volgende geschreven: > > Hi Dante, > > Both Jython

Re: Jython support for Flink

2019-07-20 Thread Dante Van den Broeke
, Dante Op 20 jul. 2019 om 01:59 heeft Zili Chen mailto:wander4...@gmail.com>> het volgende geschreven: Hi Dante, Both Jython and Jython support for Flink are out of development and maintain. As pointed out by Jeff, Flink 1.9 supports Python api via py4j[1] and the document page as posted. I

Re: Jython support for Flink

2019-07-19 Thread Zili Chen
Hi Dante, Both Jython and Jython support for Flink are out of development and maintain. As pointed out by Jeff, Flink 1.9 supports Python api via py4j[1] and the document page as posted. I guess your algorithms are written in CPython instead of Jython and want Jython only for interoperate

Re: Jython support for Flink

2019-07-19 Thread Jeff Zhang
Hi Dante, Flink 1.9 support python api, which may be what you want. See https://ci.apache.org/projects/flink/flink-docs-master/tutorials/python_table_api.html Dante Van den Broeke 于2019年7月19日周五 下午10:40写道: > Dear, > > > I'm a student currently working on a project involving apache kafka and >

Jython support for Flink

2019-07-19 Thread Dante Van den Broeke
Dear, I'm a student currently working on a project involving apache kafka and flink. The project itself is revolved around path prediction and machine learning for websites. To test a prove of concept I setup a kafka server locally (goal is to expend this to a google cloud server or similar