How to Integrate Spark mllib Streaming Training Models To Spark Structured Streaming
Spark mllib library Streaming Training models work with DStream. So is there any way to use them with spark structured streaming.
How to integrates MLeap to Spark Structured Streaming
So I am trying to integrate MLeap to spark structured streaming, But facing a problem. As the Spark structured Streaming with Kafka works with data frames and for MLeap LeapFrame is required. So I tried to convert data frame to leapframe using mleap spark support library function (toSparkLeapFrame)