Spark Collaborative Filtering Learner (MLlib)

This node utilizes the Apache Spark collaborative filtering implementation.

Notice: The matrix factorization model contains references to Spark DataFrame/RDDs and thus is not selfcontained. The referenced Spark DataFrame/RDDs will be deleted, like any other Spark DataFrame/RDD generated in KNIME, when the node is reset, or when the workflow is closed and the "Delete Spark DataFrame/RDDs on dispose" option is enabled for the current Spark context.

Input ports

1. Type: Spark Data
   Ratings DataFrame/RDD
   Spark DataFrame/RDD with user ratings of products

Output ports

1. Type: Spark Data
   Labeled input
   The input data labeled with the prediction.
2. Type: Spark MLlib Model
   Matrix factorization model (unstorable)
   The matrix factorization model. The model is not selfcontained and thus can not be saved to file.