Re: Question Regarding Streaming pipeline

2018-09-13 Thread 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. bhaskar.eba...@gmail.c

Question Regarding Streaming pipeline

2018-09-13 Thread bhaskar . ebay77
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