MatrixFactorizationModel is serializable. Instantiate it on the
driver, not on the executors.
On Wed, Aug 3, 2016 at 2:01 AM, wrote:
> hello guys:
> I have an app which consumes json messages from kafka and recommend
> movies for the users in those messages ,the code like this :
>
>
>
PS: I am using Spark1.6.1, kafka 0.10.0.0
Thanks&Best regards!
San.Luo
- 原始邮件 -
发件人：
收件人："user"
主题：How to get recommand result for users in a kafka SparkStreaming Application
日期：2016年08月03日 15点01分
hello guys: I have an app which
hello guys: I have an app which consumes json messages from kafka and
recommend movies for the users in those messages ,the code like this :
conf.setAppName("KafkaStreaming")
val storageLevel = StorageLevel.DISK_ONLY
val ssc = new StreamingContext(conf, Seconds(batchInterval.toIn
