Spark Collaborative Filtering Learner


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 Model The matrix factorization model. <b>The model is not selfcontained and thus can not be saved to file.</b>

Find here

Tools & Services > Apache Spark > Mining

Make sure to have this extension installed:

KNIME Extension for Apache Spark

Update site for KNIME Analytics Platform 3.7:
KNIME Analytics Platform 3.7 Update Site

How to install extensions