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 <dante.vandenbro...@ugent.be> 于2019年7月19日周五 下午10:40写道： > 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 later) > and a kafka producer (written in java intelliJ idea project). The producer > would send JSON data (currently just a local file but later json data from > the website itself) to a flink-kafka connection and the data transformation > (key-windowed by user id) would than happen in the flink framework. > > > The problem i'm facing however is that i wrote all the algorithms for > transformation of the data in python and i'm struggling with initializing a > jython environment to setup the flink-kafka connection. > > I was wondering whether or not there is a working example for this setup / > some documentation regarding the framework as i'm struggling to find a lot > of documentation for my application online. > > > thanks in advance. > > > kind regards, > > Dante Van den Broeke > > -- Best Regards Jeff Zhang
