Question Regarding Streaming pipeline

[Vijay Bhaskar]

Hi
In the streaming pipe line  of Scala  we want to use intermediary Machine Learning module written in  python, Is it possible to use it ?  Or entire pipe line should be either  Python or  Scala, we can't mix?

Regards
Bhaskar

[vino yang]

Hi bhasker,

Currently, using the Jython?Flink Python API in the JVM ecosystem is also based on Jython. 

Maybe you use Apache Beam's Python API to combine with Flink runner is a better choice. 

But maybe Chesnay, can give you better advice. Ping Chesnay for you.

Thanks, vino.

[hidden email] <[hidden email]> 于2018年9月14日周五 上午12:04写道：

Hi
In the streaming pipe line  of Scala  we want to use intermediary Machine Learning module written in  python, Is it possible to use it ?  Or entire pipe line should be either  Python or  Scala, we can't mix?

Regards
Bhaskar