Icon

17102_​Mass_​Learning_​Event_​Prediction_​MLlib_​to_​PMML

17102_Mass_Learning_Event_Prediction_MLlib_to_PMML
Mass Learning on all Your Historical Data Prediction Fast Event Prediction Description:This workflow demonstrates the usage of the Spark MLlib to PMML node. Together with the Compiled ModelPredictor and the JSON Input/Output node it can be used to model a so called lambda architecture whichlearns a machine learning model at scale on historical data offline and predicts events online using thelearned model. Requirements:- KNIME Analytics Platform + KNIME JSON-Processing + KNIME Extension for Apache Spark + KNIME Extensions for Local Big Data EnvironmentsFor details see https://www.knime.com/knime-extension-for-apache-sparkCreated with KNIME 3.7 on 25/02/2018 train modelin SparkconvertsPMML toJavatraining datatest dataKNIME tableto RDDNode 187ContainerInput (JSON) ContainerOutput (JSON) Spark k-Means Spark MLlib to PMML PMML Compiler Compiled ModelPredictor JSON to Table Table to JSON File Reader File Reader Entropy Scorer Compiled ModelPredictor Table to Spark Create Local BigData Environment Mass Learning on all Your Historical Data Prediction Fast Event Prediction Description:This workflow demonstrates the usage of the Spark MLlib to PMML node. Together with the Compiled ModelPredictor and the JSON Input/Output node it can be used to model a so called lambda architecture whichlearns a machine learning model at scale on historical data offline and predicts events online using thelearned model. Requirements:- KNIME Analytics Platform + KNIME JSON-Processing + KNIME Extension for Apache Spark + KNIME Extensions for Local Big Data EnvironmentsFor details see https://www.knime.com/knime-extension-for-apache-sparkCreated with KNIME 3.7 on 25/02/2018 train modelin SparkconvertsPMML toJavatraining datatest dataKNIME tableto RDDNode 187ContainerInput (JSON) ContainerOutput (JSON) Spark k-Means Spark MLlib to PMML PMML Compiler Compiled ModelPredictor JSON to Table Table to JSON File Reader File Reader Entropy Scorer Compiled ModelPredictor Table to Spark Create Local BigData Environment

Nodes

Extensions

Links