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
    Spark DataFrame/RDD with user ratings of products

Output Ports

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


This node is part of the extension

KNIME Extension for Apache Spark


Short Link

Drag node into KNIME Analytics Platform