我正在从kafka流读取我的spark应用程序中的数据流。我的需求是当用户提出任何请求(搜索/浏览等)时,为他提供产品推荐。
我已经有了一个包含用户分数的训练模型。我使用Java和org.apache.spark.mllib.recommendation.MatrixFactorizationModel模型在我的spark应用程序开始时读取模型一次。每当有任何浏览事件发生时,我都会调用recommendProducts(user_id,num_of_recommended_products) A