diff --git a/Dockerfile b/Dockerfile
index a18c658d81..4f81eed27c 100644
--- a/Dockerfile
+++ b/Dockerfile
@@ -75,10 +75,10 @@ ENV \
  JMETER_VERSION=3.0 \
  CODAHALE_METRICS_VERSION=3.1.2 \
  GUAVA_VERSION=14.0.1 \
- JPMML_SPARKML_VERSION=1.0.4 \
- PMML_MODEL_METRO_VERSION=1.2.15 \
- PMML_MODEL_VERSION=1.2.15 \
- PMML_EVALUATOR_VERSION=1.2.14 \
+ JPMML_SPARKML_VERSION=1.1.3 \
+ PMML_MODEL_VERSION=1.3.3 \
+ PMML_EVALUATOR_VERSION=1.3.2 \
+ PMML_METRO_VERSION=1.3.3 \
  SPRING_PROFILES_ACTIVE=local
 
 RUN \
diff --git a/Dockerfile.kube b/Dockerfile.kube
index 493491c75c..0e72c7ae31 100644
--- a/Dockerfile.kube
+++ b/Dockerfile.kube
@@ -75,10 +75,10 @@ ENV \
  JMETER_VERSION=3.0 \
  CODAHALE_METRICS_VERSION=3.1.2 \
  GUAVA_VERSION=14.0.1 \
- JPMML_SPARKML_VERSION=1.0.4 \
- PMML_MODEL_METRO_VERSION=1.2.15 \
- PMML_MODEL_VERSION=1.2.15 \
- PMML_EVALUATOR_VERSION=1.2.14 \
+ JPMML_SPARKML_VERSION=1.1.3 \
+ PMML_MODEL_VERSION=1.3.3 \
+ PMML_EVALUATOR_VERSION=1.3.2 \
+ PMML_METRO_VERSION=1.3.3 \
  SPRING_PROFILES_ACTIVE=local
 
 RUN \
diff --git a/config/bash/pipeline.bashrc b/config/bash/pipeline.bashrc
index beea9aa20c..8e007b38ca 100755
--- a/config/bash/pipeline.bashrc
+++ b/config/bash/pipeline.bashrc
@@ -1,3 +1,11 @@
+######
+export SPARK_CSV_CONNECTOR_VERSION=1.5.0
+export JPMML_SPARKML_VERSION=1.1.3
+export PMML_MODEL_VERSION=1.3.3
+export PMML_EVALUATOR_VERSION=1.3.2
+export PMML_METRO_VERSION=1.3.3
+######
+
 # Dev Install Home (Tools)
 #export DEV_INSTALL_HOME=~
 
@@ -91,7 +99,7 @@ export SPARK_SUBMIT_JARS=$MYAPPS_HOME/pmml/spark/1.6.1/lib/jpmml-sparkml-package
 # --py-files
 #export SPARK_SUBMIT_PYFILES=$MYAPPS_HOME/pmml/spark/1.6.1/lib/jpmml.py
 
-export SPARK_SUBMIT_ARGS="--jars $SPARK_SUBMIT_JARS --repositories $SPARK_REPOSITORIES --packages $SPARK_SUBMIT_PACKAGES"
+export SPARK_SUBMIT_ARGS="--driver-class-path $SPARK_SUBMIT_JARS --jars $SPARK_SUBMIT_JARS --repositories $SPARK_REPOSITORIES --packages $SPARK_SUBMIT_PACKAGES"
 # --py-files $SPARK_SUBMIT_PYFILES"
 export PYTHONPATH=/root/pipeline/myapps/pmml/spark/1.6.1/lib/jpmml_sparkml-1.0rc0-py2.7.egg
 
diff --git a/myapps/jupyter/Spark/PMML/CensusPMML.ipynb b/myapps/jupyter/Spark/PMML/CensusPMML.ipynb
new file mode 100644
index 0000000000..8810891a84
--- /dev/null
+++ b/myapps/jupyter/Spark/PMML/CensusPMML.ipynb
@@ -0,0 +1,145 @@
+{
+ "cells": [
+  {
+   "cell_type": "markdown",
+   "metadata": {},
+   "source": [
+    "## Display Env Vars and Python Sys Path\n",
+    "Make sure all `$VAR`s have been expanded properly "
+   ]
+  },
+  {
+   "cell_type": "code",
+   "execution_count": 2,
+   "metadata": {
+    "collapsed": false
+   },
+   "outputs": [
+    {
+     "data": {
+      "text/plain": [
+       "<pyspark.sql.context.SQLContext at 0x7f2666ed0748>"
+      ]
+     },
+     "execution_count": 2,
+     "metadata": {},
+     "output_type": "execute_result"
+    }
+   ],
+   "source": [
+    "from pyspark import SparkContext\n",
+    "from pyspark import SparkConf\n",
+    "from pyspark.sql import SQLContext\n",
+    "\n",
+    "sparkContext = SparkContext.getOrCreate()\n",
+    "sqlContext = SQLContext(sparkContext)\n",
+    "\n",
+    "sqlContext"
+   ]
+  },
+  {
+   "cell_type": "raw",
+   "metadata": {},
+   "source": [
+    "## Build Decision Tree (Regression) with Spark ML Pipeline"
+   ]
+  },
+  {
+   "cell_type": "code",
+   "execution_count": 3,
+   "metadata": {
+    "collapsed": false
+   },
+   "outputs": [
+    {
+     "data": {
+      "text/plain": [
+       "PipelineModel_49beb865ef16927b1bf8"
+      ]
+     },
+     "execution_count": 3,
+     "metadata": {},
+     "output_type": "execute_result"
+    }
+   ],
+   "source": [
+    "from pyspark.ml import Pipeline\n",
+    "from pyspark.ml.feature import RFormula\n",
+    "from pyspark.ml.regression import DecisionTreeRegressor\n",
+    "\n",
+    "data = sqlContext.read.csv('file:///datasets/datapalooza.ml/R/wine.csv', header = True, inferSchema = True)\n",
+    "\n",
+    "formula = RFormula(formula = \"quality ~ .\")\n",
+    "regressor = DecisionTreeRegressor()\n",
+    "pipeline = Pipeline(stages = [formula, regressor])\n",
+    "pipelineModel = pipeline.fit(data)\n",
+    "\n",
+    "pipelineModel"
+   ]
+  },
+  {
+   "cell_type": "markdown",
+   "metadata": {},
+   "source": [
+    "## Convert Generated Spark ML Pipeline to PMML"
+   ]
+  },
+  {
+   "cell_type": "code",
+   "execution_count": 4,
+   "metadata": {
+    "collapsed": false
+   },
+   "outputs": [
+    {
+     "data": {
+      "text/plain": [
+       "'b\\'<?xml version=\"1.0\" encoding=\"UTF-8\" standalone=\"yes\"?>\\\\n<PMML xmlns=\"http://www.dmg.org/PMML-4_3\" version=\"4.3\">\\\\n\\\\t<Header>\\\\n\\\\t\\\\t<Application/>\\\\n\\\\t\\\\t<Timestamp>2016-10-08T02:27:00Z</Timestamp>\\\\n\\\\t</Header>\\\\n\\\\t<DataDictionary>\\\\n\\\\t\\\\t<DataField name=\"quality\" optype=\"continuous\" dataType=\"double\"/>\\\\n\\\\t\\\\t<DataField name=\"volatile_acidity\" optype=\"continuous\" dataType=\"double\"/>\\\\n\\\\t\\\\t<DataField name=\"citric_acid\" optype=\"continuous\" dataType=\"double\"/>\\\\n\\\\t\\\\t<DataField name=\"residual_sugar\" optype=\"continuous\" dataType=\"double\"/>\\\\n\\\\t\\\\t<DataField name=\"chlorides\" optype=\"continuous\" dataType=\"double\"/>\\\\n\\\\t\\\\t<DataField name=\"free_sulfur_dioxide\" optype=\"continuous\" dataType=\"double\"/>\\\\n\\\\t\\\\t<DataField name=\"total_sulfur_dioxide\" optype=\"continuous\" dataType=\"double\"/>\\\\n\\\\t\\\\t<DataField name=\"density\" optype=\"continuous\" dataType=\"double\"/>\\\\n\\\\t\\\\t<DataField name=\"pH\" optype=\"continuous\" dataType=\"double\"/>\\\\n\\\\t\\\\t<DataField name=\"sulphates\" optype=\"continuous\" dataType=\"double\"/>\\\\n\\\\t\\\\t<DataField name=\"alcohol\" optype=\"continuous\" dataType=\"double\"/>\\\\n\\\\t</DataDictionary>\\\\n\\\\t<TreeModel functionName=\"regression\" splitCharacteristic=\"binarySplit\">\\\\n\\\\t\\\\t<MiningSchema>\\\\n\\\\t\\\\t\\\\t<MiningField name=\"quality\" usageType=\"target\"/>\\\\n\\\\t\\\\t\\\\t<MiningField name=\"volatile_acidity\"/>\\\\n\\\\t\\\\t\\\\t<MiningField name=\"citric_acid\"/>\\\\n\\\\t\\\\t\\\\t<MiningField name=\"residual_sugar\"/>\\\\n\\\\t\\\\t\\\\t<MiningField name=\"chlorides\"/>\\\\n\\\\t\\\\t\\\\t<MiningField name=\"free_sulfur_dioxide\"/>\\\\n\\\\t\\\\t\\\\t<MiningField name=\"total_sulfur_dioxide\"/>\\\\n\\\\t\\\\t\\\\t<MiningField name=\"density\"/>\\\\n\\\\t\\\\t\\\\t<MiningField name=\"pH\"/>\\\\n\\\\t\\\\t\\\\t<MiningField name=\"sulphates\"/>\\\\n\\\\t\\\\t\\\\t<MiningField name=\"alcohol\"/>\\\\n\\\\t\\\\t</MiningSchema>\\\\n\\\\t\\\\t<Node score=\"5.818377712790519\">\\\\n\\\\t\\\\t\\\\t<True/>\\\\n\\\\t\\\\t\\\\t<Node score=\"5.528453181583031\">\\\\n\\\\t\\\\t\\\\t\\\\t<SimplePredicate field=\"alcohol\" operator=\"lessOrEqual\" value=\"10.6\"/>\\\\n\\\\t\\\\t\\\\t\\\\t<Node score=\"5.915719696969697\">\\\\n\\\\t\\\\t\\\\t\\\\t\\\\t<SimplePredicate field=\"volatile_acidity\" operator=\"lessOrEqual\" value=\"0.235\"/>\\\\n\\\\t\\\\t\\\\t\\\\t\\\\t<Node score=\"6.024205748865356\">\\\\n\\\\t\\\\t\\\\t\\\\t\\\\t\\\\t<SimplePredicate field=\"volatile_acidity\" operator=\"lessOrEqual\" value=\"0.205\"/>\\\\n\\\\t\\\\t\\\\t\\\\t\\\\t\\\\t<Node score=\"5.857758620689655\">\\\\n\\\\t\\\\t\\\\t\\\\t\\\\t\\\\t\\\\t<SimplePredicate field=\"residual_sugar\" operator=\"lessOrEqual\" value=\"9.9\"/>\\\\n\\\\t\\\\t\\\\t\\\\t\\\\t\\\\t\\\\t<Node score=\"5.241379310344827\">\\\\n\\\\t\\\\t\\\\t\\\\t\\\\t\\\\t\\\\t\\\\t<SimplePredicate field=\"free_sulfur_dioxide\" operator=\"lessOrEqual\" value=\"10\"/>\\\\n\\\\t\\\\t\\\\t\\\\t\\\\t\\\\t\\\\t</Node>\\\\n\\\\t\\\\t\\\\t\\\\t\\\\t\\\\t\\\\t<Node score=\"5.898850574712644\">\\\\n\\\\t\\\\t\\\\t\\\\t\\\\t\\\\t\\\\t\\\\t<SimplePredicate field=\"free_sulfur_dioxide\" operator=\"greaterThan\" value=\"10\"/>\\\\n\\\\t\\\\t\\\\t\\\\t\\\\t\\\\t\\\\t</Node>\\\\n\\\\t\\\\t\\\\t\\\\t\\\\t\\\\t</Node>\\\\n\\\\t\\\\t\\\\t\\\\t\\\\t\\\\t<Node score=\"6.416243654822335\">\\\\n\\\\t\\\\t\\\\t\\\\t\\\\t\\\\t\\\\t<SimplePredicate field=\"residual_sugar\" operator=\"greaterThan\" value=\"9.9\"/>\\\\n\\\\t\\\\t\\\\t\\\\t\\\\t\\\\t\\\\t<Node score=\"6.808988764044944\">\\\\n\\\\t\\\\t\\\\t\\\\t\\\\t\\\\t\\\\t\\\\t<SimplePredicate field=\"citric_acid\" operator=\"lessOrEqual\" value=\"0.3\"/>\\\\n\\\\t\\\\t\\\\t\\\\t\\\\t\\\\t\\\\t</Node>\\\\n\\\\t\\\\t\\\\t\\\\t\\\\t\\\\t\\\\t<Node score=\"6.092592592592593\">\\\\n\\\\t\\\\t\\\\t\\\\t\\\\t\\\\t\\\\t\\\\t<SimplePredicate field=\"citric_acid\" operator=\"greaterThan\" value=\"0.3\"/>\\\\n\\\\t\\\\t\\\\t\\\\t\\\\t\\\\t\\\\t</Node>\\\\n\\\\t\\\\t\\\\t\\\\t\\\\t\\\\t</Node>\\\\n\\\\t\\\\t\\\\t\\\\t\\\\t</Node>\\\\n\\\\t\\\\t\\\\t\\\\t\\\\t<Node score=\"5.734177215189874\">\\\\n\\\\t\\\\t\\\\t\\\\t\\\\t\\\\t<SimplePredicate field=\"volatile_acidity\" operator=\"greaterThan\" value=\"0.205\"/>\\\\n\\\\t\\\\t\\\\t\\\\t\\\\t\\\\t<Node score=\"5.430769230769231\">\\\\n\\\\t\\\\t\\\\t\\\\t\\\\t\\\\t\\\\t<SimplePredicate field=\"free_sulfur_dioxide\" operator=\"lessOrEqual\" value=\"23\"/>\\\\n\\\\t\\\\t\\\\t\\\\t\\\\t\\\\t\\\\t<Node score=\"4.333333333333333\">\\\\n\\\\t\\\\t\\\\t\\\\t\\\\t\\\\t\\\\t\\\\t<SimplePredicate field=\"pH\" operator=\"lessOrEqual\" value=\"2.93\"/>\\\\n\\\\t\\\\t\\\\t\\\\t\\\\t\\\\t\\\\t</Node>\\\\n\\\\t\\\\t\\\\t\\\\t\\\\t\\\\t\\\\t<Node score=\"5.483870967741935\">\\\\n\\\\t\\\\t\\\\t\\\\t\\\\t\\\\t\\\\t\\\\t<SimplePredicate field=\"pH\" operator=\"greaterThan\" value=\"2.93\"/>\\\\n\\\\t\\\\t\\\\t\\\\t\\\\t\\\\t\\\\t</Node>\\\\n\\\\t\\\\t\\\\t\\\\t\\\\t\\\\t</Node>\\\\n\\\\t\\\\t\\\\t\\\\t\\\\t\\\\t<Node score=\"5.793939393939394\">\\\\n\\\\t\\\\t\\\\t\\\\t\\\\t\\\\t\\\\t<SimplePredicate field=\"free_sulfur_dioxide\" operator=\"greaterThan\" value=\"23\"/>\\\\n\\\\t\\\\t\\\\t\\\\t\\\\t\\\\t\\\\t<Node score=\"5.622047244094488\">\\\\n\\\\t\\\\t\\\\t\\\\t\\\\t\\\\t\\\\t\\\\t<SimplePredicate field=\"sulphates\" operator=\"lessOrEqual\" value=\"0.45\"/>\\\\n\\\\t\\\\t\\\\t\\\\t\\\\t\\\\t\\\\t</Node>\\\\n\\\\t\\\\t\\\\t\\\\t\\\\t\\\\t\\\\t<Node score=\"5.901477832512315\">\\\\n\\\\t\\\\t\\\\t\\\\t\\\\t\\\\t\\\\t\\\\t<SimplePredicate field=\"sulphates\" operator=\"greaterThan\" value=\"0.45\"/>\\\\n\\\\t\\\\t\\\\t\\\\t\\\\t\\\\t\\\\t</Node>\\\\n\\\\t\\\\t\\\\t\\\\t\\\\t\\\\t</Node>\\\\n\\\\t\\\\t\\\\t\\\\t\\\\t</Node>\\\\n\\\\t\\\\t\\\\t\\\\t</Node>\\\\n\\\\t\\\\t\\\\t\\\\t<Node score=\"5.382918149466192\">\\\\n\\\\t\\\\t\\\\t\\\\t\\\\t<SimplePredicate field=\"volatile_acidity\" operator=\"greaterThan\" value=\"0.235\"/>\\\\n\\\\t\\\\t\\\\t\\\\t\\\\t<Node score=\"5.286792452830189\">\\\\n\\\\t\\\\t\\\\t\\\\t\\\\t\\\\t<SimplePredicate field=\"alcohol\" operator=\"lessOrEqual\" value=\"9.8\"/>\\\\n\\\\t\\\\t\\\\t\\\\t\\\\t\\\\t<Node score=\"5.444620253164557\">\\\\n\\\\t\\\\t\\\\t\\\\t\\\\t\\\\t\\\\t<SimplePredicate field=\"volatile_acidity\" operator=\"lessOrEqual\" value=\"0.3\"/>\\\\n\\\\t\\\\t\\\\t\\\\t\\\\t\\\\t\\\\t<Node score=\"5.212643678160919\">\\\\n\\\\t\\\\t\\\\t\\\\t\\\\t\\\\t\\\\t\\\\t<SimplePredicate field=\"citric_acid\" operator=\"lessOrEqual\" value=\"0.26\"/>\\\\n\\\\t\\\\t\\\\t\\\\t\\\\t\\\\t\\\\t</Node>\\\\n\\\\t\\\\t\\\\t\\\\t\\\\t\\\\t\\\\t<Node score=\"5.532751091703057\">\\\\n\\\\t\\\\t\\\\t\\\\t\\\\t\\\\t\\\\t\\\\t<SimplePredicate field=\"citric_acid\" operator=\"greaterThan\" value=\"0.26\"/>\\\\n\\\\t\\\\t\\\\t\\\\t\\\\t\\\\t\\\\t</Node>\\\\n\\\\t\\\\t\\\\t\\\\t\\\\t\\\\t</Node>\\\\n\\\\t\\\\t\\\\t\\\\t\\\\t\\\\t<Node score=\"5.205233033524121\">\\\\n\\\\t\\\\t\\\\t\\\\t\\\\t\\\\t\\\\t<SimplePredicate field=\"volatile_acidity\" operator=\"greaterThan\" value=\"0.3\"/>\\\\n\\\\t\\\\t\\\\t\\\\t\\\\t\\\\t\\\\t<Node score=\"5.104477611940299\">\\\\n\\\\t\\\\t\\\\t\\\\t\\\\t\\\\t\\\\t\\\\t<SimplePredicate field=\"sulphates\" operator=\"lessOrEqual\" value=\"0.53\"/>\\\\n\\\\t\\\\t\\\\t\\\\t\\\\t\\\\t\\\\t</Node>\\\\n\\\\t\\\\t\\\\t\\\\t\\\\t\\\\t\\\\t<Node score=\"5.303225806451613\">\\\\n\\\\t\\\\t\\\\t\\\\t\\\\t\\\\t\\\\t\\\\t<SimplePredicate field=\"sulphates\" operator=\"greaterThan\" value=\"0.53\"/>\\\\n\\\\t\\\\t\\\\t\\\\t\\\\t\\\\t\\\\t</Node>\\\\n\\\\t\\\\t\\\\t\\\\t\\\\t\\\\t</Node>\\\\n\\\\t\\\\t\\\\t\\\\t\\\\t</Node>\\\\n\\\\t\\\\t\\\\t\\\\t\\\\t<Node score=\"5.569633507853403\">\\\\n\\\\t\\\\t\\\\t\\\\t\\\\t\\\\t<SimplePredicate field=\"alcohol\" operator=\"greaterThan\" value=\"9.8\"/>\\\\n\\\\t\\\\t\\\\t\\\\t\\\\t\\\\t<Node score=\"5.628428927680798\">\\\\n\\\\t\\\\t\\\\t\\\\t\\\\t\\\\t\\\\t<SimplePredicate field=\"volatile_acidity\" operator=\"lessOrEqual\" value=\"0.595\"/>\\\\n\\\\t\\\\t\\\\t\\\\t\\\\t\\\\t\\\\t<Node score=\"5.429752066115703\">\\\\n\\\\t\\\\t\\\\t\\\\t\\\\t\\\\t\\\\t\\\\t<SimplePredicate field=\"sulphates\" operator=\"lessOrEqual\" value=\"0.47\"/>\\\\n\\\\t\\\\t\\\\t\\\\t\\\\t\\\\t\\\\t</Node>\\\\n\\\\t\\\\t\\\\t\\\\t\\\\t\\\\t\\\\t<Node score=\"5.714285714285714\">\\\\n\\\\t\\\\t\\\\t\\\\t\\\\t\\\\t\\\\t\\\\t<SimplePredicate field=\"sulphates\" operator=\"greaterThan\" value=\"0.47\"/>\\\\n\\\\t\\\\t\\\\t\\\\t\\\\t\\\\t\\\\t</Node>\\\\n\\\\t\\\\t\\\\t\\\\t\\\\t\\\\t</Node>\\\\n\\\\t\\\\t\\\\t\\\\t\\\\t\\\\t<Node score=\"5.261437908496732\">\\\\n\\\\t\\\\t\\\\t\\\\t\\\\t\\\\t\\\\t<SimplePredicate field=\"volatile_acidity\" operator=\"greaterThan\" value=\"0.595\"/>\\\\n\\\\t\\\\t\\\\t\\\\t\\\\t\\\\t\\\\t<Node score=\"4.25\">\\\\n\\\\t\\\\t\\\\t\\\\t\\\\t\\\\t\\\\t\\\\t<SimplePredicate field=\"density\" operator=\"lessOrEqual\" value=\"0.9942\"/>\\\\n\\\\t\\\\t\\\\t\\\\t\\\\t\\\\t\\\\t</Node>\\\\n\\\\t\\\\t\\\\t\\\\t\\\\t\\\\t\\\\t<Node score=\"5.317241379310345\">\\\\n\\\\t\\\\t\\\\t\\\\t\\\\t\\\\t\\\\t\\\\t<SimplePredicate field=\"density\" operator=\"greaterThan\" value=\"0.9942\"/>\\\\n\\\\t\\\\t\\\\t\\\\t\\\\t\\\\t\\\\t</Node>\\\\n\\\\t\\\\t\\\\t\\\\t\\\\t\\\\t</Node>\\\\n\\\\t\\\\t\\\\t\\\\t\\\\t</Node>\\\\n\\\\t\\\\t\\\\t\\\\t</Node>\\\\n\\\\t\\\\t\\\\t</Node>\\\\n\\\\t\\\\t\\\\t<Node score=\"6.244393766628658\">\\\\n\\\\t\\\\t\\\\t\\\\t<SimplePredicate field=\"alcohol\" operator=\"greaterThan\" value=\"10.6\"/>\\\\n\\\\t\\\\t\\\\t\\\\t<Node score=\"6.022064056939501\">\\\\n\\\\t\\\\t\\\\t\\\\t\\\\t<SimplePredicate field=\"alcohol\" operator=\"lessOrEqual\" value=\"11.65\"/>\\\\n\\\\t\\\\t\\\\t\\\\t\\\\t<Node score=\"6.135913591359136\">\\\\n\\\\t\\\\t\\\\t\\\\t\\\\t\\\\t<SimplePredicate field=\"volatile_acidity\" operator=\"lessOrEqual\" value=\"0.4\"/>\\\\n\\\\t\\\\t\\\\t\\\\t\\\\t\\\\t<Node score=\"6.0586124401913874\">\\\\n\\\\t\\\\t\\\\t\\\\t\\\\t\\\\t\\\\t<SimplePredicate field=\"sulphates\" operator=\"lessOrEqual\" value=\"0.58\"/>\\\\n\\\\t\\\\t\\\\t\\\\t\\\\t\\\\t\\\\t<Node score=\"5.346153846153846\">\\\\n\\\\t\\\\t\\\\t\\\\t\\\\t\\\\t\\\\t\\\\t<SimplePredicate field=\"free_sulfur_dioxide\" operator=\"lessOrEqual\" value=\"10\"/>\\\\n\\\\t\\\\t\\\\t\\\\t\\\\t\\\\t\\\\t</Node>\\\\n\\\\t\\\\t\\\\t\\\\t\\\\t\\\\t\\\\t<Node score=\"6.105867346938775\">\\\\n\\\\t\\\\t\\\\t\\\\t\\\\t\\\\t\\\\t\\\\t<SimplePredicate field=\"free_sulfur_dioxide\" operator=\"greaterThan\" value=\"10\"/>\\\\n\\\\t\\\\t\\\\t\\\\t\\\\t\\\\t\\\\t</Node>\\\\n\\\\t\\\\t\\\\t\\\\t\\\\t\\\\t</Node>\\\\n\\\\t\\\\t\\\\t\\\\t\\\\t\\\\t<Node score=\"6.370909090909091\">\\\\n\\\\t\\\\t\\\\t\\\\t\\\\t\\\\t\\\\t<SimplePredicate field=\"sulphates\" operator=\"greaterThan\" value=\"0.58\"/>\\\\n\\\\t\\\\t\\\\t\\\\t\\\\t\\\\t\\\\t<Node score=\"6.310483870967742\">\\\\n\\\\t\\\\t\\\\t\\\\t\\\\t\\\\t\\\\t\\\\t<SimplePredicate field=\"free_sulfur_dioxide\" operator=\"lessOrEqual\" value=\"51.5\"/>\\\\n\\\\t\\\\t\\\\t\\\\t\\\\t\\\\t\\\\t</Node>\\\\n\\\\t\\\\t\\\\t\\\\t\\\\t\\\\t\\\\t<Node score=\"6.925925925925926\">\\\\n\\\\t\\\\t\\\\t\\\\t\\\\t\\\\t\\\\t\\\\t<SimplePredicate field=\"free_sulfur_dioxide\" operator=\"greaterThan\" value=\"51.5\"/>\\\\n\\\\t\\\\t\\\\t\\\\t\\\\t\\\\t\\\\t</Node>\\\\n\\\\t\\\\t\\\\t\\\\t\\\\t\\\\t</Node>\\\\n\\\\t\\\\t\\\\t\\\\t\\\\t</Node>\\\\n\\\\t\\\\t\\\\t\\\\t\\\\t<Node score=\"5.591836734693878\">\\\\n\\\\t\\\\t\\\\t\\\\t\\\\t\\\\t<SimplePredicate field=\"volatile_acidity\" operator=\"greaterThan\" value=\"0.4\"/>\\\\n\\\\t\\\\t\\\\t\\\\t\\\\t\\\\t<Node score=\"5.711934156378601\">\\\\n\\\\t\\\\t\\\\t\\\\t\\\\t\\\\t\\\\t<SimplePredicate field=\"volatile_acidity\" operator=\"lessOrEqual\" value=\"0.725\"/>\\\\n\\\\t\\\\t\\\\t\\\\t\\\\t\\\\t\\\\t<Node score=\"4.7894736842105265\">\\\\n\\\\t\\\\t\\\\t\\\\t\\\\t\\\\t\\\\t\\\\t<SimplePredicate field=\"residual_sugar\" operator=\"lessOrEqual\" value=\"1.5\"/>\\\\n\\\\t\\\\t\\\\t\\\\t\\\\t\\\\t\\\\t</Node>\\\\n\\\\t\\\\t\\\\t\\\\t\\\\t\\\\t\\\\t<Node score=\"5.790178571428571\">\\\\n\\\\t\\\\t\\\\t\\\\t\\\\t\\\\t\\\\t\\\\t<SimplePredicate field=\"residual_sugar\" operator=\"greaterThan\" value=\"1.5\"/>\\\\n\\\\t\\\\t\\\\t\\\\t\\\\t\\\\t\\\\t</Node>\\\\n\\\\t\\\\t\\\\t\\\\t\\\\t\\\\t</Node>\\\\n\\\\t\\\\t\\\\t\\\\t\\\\t\\\\t<Node score=\"5.019607843137255\">\\\\n\\\\t\\\\t\\\\t\\\\t\\\\t\\\\t\\\\t<SimplePredicate field=\"volatile_acidity\" operator=\"greaterThan\" value=\"0.725\"/>\\\\n\\\\t\\\\t\\\\t\\\\t\\\\t\\\\t\\\\t<Node score=\"5.256410256410256\">\\\\n\\\\t\\\\t\\\\t\\\\t\\\\t\\\\t\\\\t\\\\t<SimplePredicate field=\"residual_sugar\" operator=\"lessOrEqual\" value=\"3\"/>\\\\n\\\\t\\\\t\\\\t\\\\t\\\\t\\\\t\\\\t</Node>\\\\n\\\\t\\\\t\\\\t\\\\t\\\\t\\\\t\\\\t<Node score=\"4.25\">\\\\n\\\\t\\\\t\\\\t\\\\t\\\\t\\\\t\\\\t\\\\t<SimplePredicate field=\"residual_sugar\" operator=\"greaterThan\" value=\"3\"/>\\\\n\\\\t\\\\t\\\\t\\\\t\\\\t\\\\t\\\\t</Node>\\\\n\\\\t\\\\t\\\\t\\\\t\\\\t\\\\t</Node>\\\\n\\\\t\\\\t\\\\t\\\\t\\\\t</Node>\\\\n\\\\t\\\\t\\\\t\\\\t</Node>\\\\n\\\\t\\\\t\\\\t\\\\t<Node score=\"6.499184339314845\">\\\\n\\\\t\\\\t\\\\t\\\\t\\\\t<SimplePredicate field=\"alcohol\" operator=\"greaterThan\" value=\"11.65\"/>\\\\n\\\\t\\\\t\\\\t\\\\t\\\\t<Node score=\"6.255125284738041\">\\\\n\\\\t\\\\t\\\\t\\\\t\\\\t\\\\t<SimplePredicate field=\"free_sulfur_dioxide\" operator=\"lessOrEqual\" value=\"21\"/>\\\\n\\\\t\\\\t\\\\t\\\\t\\\\t\\\\t<Node score=\"6.099071207430341\">\\\\n\\\\t\\\\t\\\\t\\\\t\\\\t\\\\t\\\\t<SimplePredicate field=\"sulphates\" operator=\"lessOrEqual\" value=\"0.68\"/>\\\\n\\\\t\\\\t\\\\t\\\\t\\\\t\\\\t\\\\t<Node score=\"6.809523809523809\">\\\\n\\\\t\\\\t\\\\t\\\\t\\\\t\\\\t\\\\t\\\\t<SimplePredicate field=\"sulphates\" operator=\"lessOrEqual\" value=\"0.33\"/>\\\\n\\\\t\\\\t\\\\t\\\\t\\\\t\\\\t\\\\t</Node>\\\\n\\\\t\\\\t\\\\t\\\\t\\\\t\\\\t\\\\t<Node score=\"6.049668874172186\">\\\\n\\\\t\\\\t\\\\t\\\\t\\\\t\\\\t\\\\t\\\\t<SimplePredicate field=\"sulphates\" operator=\"greaterThan\" value=\"0.33\"/>\\\\n\\\\t\\\\t\\\\t\\\\t\\\\t\\\\t\\\\t</Node>\\\\n\\\\t\\\\t\\\\t\\\\t\\\\t\\\\t</Node>\\\\n\\\\t\\\\t\\\\t\\\\t\\\\t\\\\t<Node score=\"6.689655172413793\">\\\\n\\\\t\\\\t\\\\t\\\\t\\\\t\\\\t\\\\t<SimplePredicate field=\"sulphates\" operator=\"greaterThan\" value=\"0.68\"/>\\\\n\\\\t\\\\t\\\\t\\\\t\\\\t\\\\t\\\\t<Node score=\"6.868421052631579\">\\\\n\\\\t\\\\t\\\\t\\\\t\\\\t\\\\t\\\\t\\\\t<SimplePredicate field=\"total_sulfur_dioxide\" operator=\"lessOrEqual\" value=\"68\"/>\\\\n\\\\t\\\\t\\\\t\\\\t\\\\t\\\\t\\\\t</Node>\\\\n\\\\t\\\\t\\\\t\\\\t\\\\t\\\\t\\\\t<Node score=\"6.35\">\\\\n\\\\t\\\\t\\\\t\\\\t\\\\t\\\\t\\\\t\\\\t<SimplePredicate field=\"total_sulfur_dioxide\" operator=\"greaterThan\" value=\"68\"/>\\\\n\\\\t\\\\t\\\\t\\\\t\\\\t\\\\t\\\\t</Node>\\\\n\\\\t\\\\t\\\\t\\\\t\\\\t\\\\t</Node>\\\\n\\\\t\\\\t\\\\t\\\\t\\\\t</Node>\\\\n\\\\t\\\\t\\\\t\\\\t\\\\t<Node score=\"6.635324015247776\">\\\\n\\\\t\\\\t\\\\t\\\\t\\\\t\\\\t<SimplePredicate field=\"free_sulfur_dioxide\" operator=\"greaterThan\" value=\"21\"/>\\\\n\\\\t\\\\t\\\\t\\\\t\\\\t\\\\t<Node score=\"6.35609756097561\">\\\\n\\\\t\\\\t\\\\t\\\\t\\\\t\\\\t\\\\t<SimplePredicate field=\"residual_sugar\" operator=\"lessOrEqual\" value=\"1.7\"/>\\\\n\\\\t\\\\t\\\\t\\\\t\\\\t\\\\t\\\\t<Node score=\"6.243421052631579\">\\\\n\\\\t\\\\t\\\\t\\\\t\\\\t\\\\t\\\\t\\\\t<SimplePredicate field=\"pH\" operator=\"lessOrEqual\" value=\"3.29\"/>\\\\n\\\\t\\\\t\\\\t\\\\t\\\\t\\\\t\\\\t</Node>\\\\n\\\\t\\\\t\\\\t\\\\t\\\\t\\\\t\\\\t<Node score=\"6.679245283018868\">\\\\n\\\\t\\\\t\\\\t\\\\t\\\\t\\\\t\\\\t\\\\t<SimplePredicate field=\"pH\" operator=\"greaterThan\" value=\"3.29\"/>\\\\n\\\\t\\\\t\\\\t\\\\t\\\\t\\\\t\\\\t</Node>\\\\n\\\\t\\\\t\\\\t\\\\t\\\\t\\\\t</Node>\\\\n\\\\t\\\\t\\\\t\\\\t\\\\t\\\\t<Node score=\"6.733676975945017\">\\\\n\\\\t\\\\t\\\\t\\\\t\\\\t\\\\t\\\\t<SimplePredicate field=\"residual_sugar\" operator=\"greaterThan\" value=\"1.7\"/>\\\\n\\\\t\\\\t\\\\t\\\\t\\\\t\\\\t\\\\t<Node score=\"6.746527777777778\">\\\\n\\\\t\\\\t\\\\t\\\\t\\\\t\\\\t\\\\t\\\\t<SimplePredicate field=\"chlorides\" operator=\"lessOrEqual\" value=\"0.095\"/>\\\\n\\\\t\\\\t\\\\t\\\\t\\\\t\\\\t\\\\t</Node>\\\\n\\\\t\\\\t\\\\t\\\\t\\\\t\\\\t\\\\t<Node score=\"5.5\">\\\\n\\\\t\\\\t\\\\t\\\\t\\\\t\\\\t\\\\t\\\\t<SimplePredicate field=\"chlorides\" operator=\"greaterThan\" value=\"0.095\"/>\\\\n\\\\t\\\\t\\\\t\\\\t\\\\t\\\\t\\\\t</Node>\\\\n\\\\t\\\\t\\\\t\\\\t\\\\t\\\\t</Node>\\\\n\\\\t\\\\t\\\\t\\\\t\\\\t</Node>\\\\n\\\\t\\\\t\\\\t\\\\t</Node>\\\\n\\\\t\\\\t\\\\t</Node>\\\\n\\\\t\\\\t</Node>\\\\n\\\\t</TreeModel>\\\\n</PMML>\\\\n\\''"
+      ]
+     },
+     "execution_count": 4,
+     "metadata": {},
+     "output_type": "execute_result"
+    }
+   ],
+   "source": [
+    "from jpmml import toPMMLBytes\n",
+    "\n",
+    "pmmlBytes = toPMMLBytes(sparkContext, data, pipelineModel)\n",
+    "\n",
+    "str(pmmlBytes)"
+   ]
+  },
+  {
+   "cell_type": "code",
+   "execution_count": null,
+   "metadata": {
+    "collapsed": true
+   },
+   "outputs": [],
+   "source": []
+  }
+ ],
+ "metadata": {
+  "anaconda-cloud": {},
+  "kernelspec": {
+   "display_name": "Python 2",
+   "language": "python",
+   "name": "python2"
+  },
+  "language_info": {
+   "codemirror_mode": {
+    "name": "ipython",
+    "version": 2
+   },
+   "file_extension": ".py",
+   "mimetype": "text/x-python",
+   "name": "python",
+   "nbconvert_exporter": "python",
+   "pygments_lexer": "ipython2",
+   "version": "2.7.6"
+  }
+ },
+ "nbformat": 4,
+ "nbformat_minor": 0
+}
diff --git a/myapps/pmml/spark/2.0.1/pom.xml b/myapps/pmml/spark/2.0.1/pom.xml
index 6044fd020e..15826cedd5 100644
--- a/myapps/pmml/spark/2.0.1/pom.xml
+++ b/myapps/pmml/spark/2.0.1/pom.xml
@@ -173,12 +173,12 @@
     <dependency>
       <groupId>org.jpmml</groupId>
       <artifactId>pmml-model</artifactId>
-      <version>1.3.1</version>
+      <version>1.3.3</version>
     </dependency>
     <dependency>
       <groupId>org.jpmml</groupId>
       <artifactId>pmml-evaluator</artifactId>
-      <version>1.3.1</version>
+      <version>1.3.2</version>
     </dependency>
 <!--
     <dependency>
@@ -190,7 +190,7 @@
     <dependency>
       <groupId>org.jpmml</groupId>
       <artifactId>jpmml-sparkml</artifactId>
-      <version>1.1.1</version>
+      <version>1.1.3</version>
     </dependency>
     <dependency>
       <groupId>org.apache.httpcomponents</groupId>
diff --git a/myapps/pmml/spark/2.0.1/src/main/scala/com/advancedspark/pmml/spark/ml/EvaluatePMML.scala b/myapps/pmml/spark/2.0.1/src/main/scala/com/advancedspark/pmml/spark/ml/EvaluatePMML.scala
index 70a918e3c7..1d491a4fd6 100644
--- a/myapps/pmml/spark/2.0.1/src/main/scala/com/advancedspark/pmml/spark/ml/EvaluatePMML.scala
+++ b/myapps/pmml/spark/2.0.1/src/main/scala/com/advancedspark/pmml/spark/ml/EvaluatePMML.scala
@@ -78,7 +78,7 @@ object EvaluatePMML {
 
     val results = modelEvaluator.evaluate(arguments)
     val targetField = modelEvaluator.getTargetFields().asScala(0)
-    val targetValue = results.get(targetField)
+    val targetValue = results.get(targetField.getName)
 
     System.out.println(s"**** Predicted value for '${targetField.getName}': ${targetValue} ****")
   }
diff --git a/myapps/pmml/spark/2.0.1/src/main/scala/com/advancedspark/pmml/spark/ml/PMMLSparkML.scala b/myapps/pmml/spark/2.0.1/src/main/scala/com/advancedspark/pmml/spark/ml/PMMLSparkML.scala
index 7c3c1cd304..2aca9370d7 100644
--- a/myapps/pmml/spark/2.0.1/src/main/scala/com/advancedspark/pmml/spark/ml/PMMLSparkML.scala
+++ b/myapps/pmml/spark/2.0.1/src/main/scala/com/advancedspark/pmml/spark/ml/PMMLSparkML.scala
@@ -127,7 +127,6 @@ object PMMLSparkML {
 
     System.out.println("Input schema:");
     System.out.println("\t" + "Input fields: " + inputFields) 
-//    System.out.println("\t" + "Group fields: " + modelEvaluator.getGroupFields())
 
     System.out.println("Output schema:");
     System.out.println("\t" + "Target fields: " + modelEvaluator.getTargetFields())
@@ -154,20 +153,13 @@ object PMMLSparkML {
         //   2) missing value treatment, 
         //   3) invalid value treatment 
         //   4) type conversion
-//        yield (inputField -> modelEvaluator.prepare(inputField, inputs(inputField.getValue)))
         yield (inputField.getName -> inputField.prepare(inputs(inputField.getName.getValue)))
       ).toMap.asJava
 
     val results = modelEvaluator.evaluate(arguments)
     val targetField = modelEvaluator.getTargetFields().asScala(0)
-    val targetValue = results.get(targetField)
+    val targetValue = results.get(targetField.getName)
     
     System.out.println(s"**** Predicted value for '${targetField.getName}': ${targetValue} ****")
-
-    //if (targetValue instanceof Computable) {
-    //    Computable computable = (Computable)targetValue;
-
-    //    Object primitiveValue = computable.getResult();
-    //}
   }
 }
diff --git a/myapps/serving/prediction/build.sbt b/myapps/serving/prediction/build.sbt
index 1b259fd7d4..c6c6a944c4 100644
--- a/myapps/serving/prediction/build.sbt
+++ b/myapps/serving/prediction/build.sbt
@@ -21,7 +21,7 @@ val springCloudVersion = sys.env("SPRING_CLOUD_VERSION")
 val springCoreVersion = sys.env("SPRING_CORE_VERSION")
 val pmmlEvaluatorVersion = sys.env("PMML_EVALUATOR_VERSION")
 val pmmlModelVersion = sys.env("PMML_MODEL_VERSION")
-val pmmlModelMetroVersion = sys.env("PMML_MODEL_METRO_VERSION")
+val pmmlMetroVersion = sys.env("PMML_METRO_VERSION")
 val janinoVersion = sys.env("JANINO_VERSION")
 val codahaleMetricsVersion = sys.env("CODAHALE_METRICS_VERSION")
 
@@ -33,14 +33,13 @@ lazy val deps = Seq(
   "org.springframework.boot" % "spring-boot-starter-web"   % springBootVersion,
   "org.scalanlp"         %% "breeze"                       % breezeVersion % "provided",
   "com.netflix.dyno"     % "dyno-jedis"                    % dynoVersion,
-  "org.jpmml"            % "pmml-evaluator"                % pmmlEvaluatorVersion,
   "org.springframework.boot" % "spring-boot-starter-actuator" % springBootVersion,
   "org.springframework.cloud" % "spring-cloud-starter-spectator" % springCloudVersion,
   "org.springframework.cloud" % "spring-cloud-starter-eureka" % springCloudVersion,
   "org.springframework.cloud" % "spring-cloud-starter-hystrix" % springCloudVersion,
   "org.springframework.cloud" % "spring-cloud-starter-atlas" % springCloudVersion,
   "org.springframework.cloud" % "spring-cloud-starter-config" % springCloudVersion,
-  "org.jpmml" % "pmml-model-metro" % pmmlModelMetroVersion,
+  "org.jpmml" % "pmml-model-metro" % pmmlMetroVersion,
   "org.jpmml" % "pmml-model" % pmmlModelVersion,
   "org.jpmml" % "pmml-evaluator" % pmmlEvaluatorVersion 
 )
diff --git a/myapps/serving/prediction/src/main/scala/com/advancedspark/serving/prediction/PredictionService.scala b/myapps/serving/prediction/src/main/scala/com/advancedspark/serving/prediction/PredictionService.scala
index 1f38c2480d..7f316ecb2e 100644
--- a/myapps/serving/prediction/src/main/scala/com/advancedspark/serving/prediction/PredictionService.scala
+++ b/myapps/serving/prediction/src/main/scala/com/advancedspark/serving/prediction/PredictionService.scala
@@ -242,14 +242,13 @@ class PredictionService {
     import java.io.FileInputStream
     import org.jpmml.model.MetroJAXBUtil
     import org.xml.sax.InputSource
-    import org.jpmml.evaluator.TreeModelEvaluator
     import org.jpmml.evaluator.ModelEvaluatorFactory
     import org.jpmml.evaluator.Evaluator
     import org.jpmml.model.ImportFilter
     import org.jpmml.model.JAXBUtil
 
     try {
-      val inputMap = JSON.parseFull(inputs).get.asInstanceOf[Map[String,Any]]
+      val inputsMap = JSON.parseFull(inputs).get.asInstanceOf[Map[String,Any]]
 
       val pmml: java.io.File = new java.io.File(s"data/${pmmlName}/${pmmlName}.pmml")
 
@@ -261,25 +260,36 @@ class PredictionService {
 
       val modelEvaluatorFactory = ModelEvaluatorFactory.newInstance()
 
-      val modelEvaluator: Evaluator = modelEvaluatorFactory.newModelManager(pmml2)
+      val modelEvaluator: Evaluator = modelEvaluatorFactory.newModelEvaluator(pmml2)
+      System.out.println("Mining function: " + modelEvaluator.getMiningFunction())
 
-      val activeFields = modelEvaluator.getActiveFields().asScala
+      val inputFields = modelEvaluator.getInputFields().asScala
+
+      System.out.println("Input schema:");
+      System.out.println("\t" + "Input fields: " + inputFields)
+//    System.out.println("\t" + "Group fields: " + modelEvaluator.getGroupFields())
+
+      System.out.println("Output schema:");
+      System.out.println("\t" + "Target fields: " + modelEvaluator.getTargetFields())
+      System.out.println("\t" + "Output fields: " + modelEvaluator.getOutputFields())
 
       val arguments =
-        ( for(activeField <- activeFields)
-        // The raw value is passed through:
-        //   1) outlier treatment,
-        //   2) missing value treatment,
-        //   3) invalid value treatment
-        //   4) type conversion
-          yield (activeField -> modelEvaluator.prepare(activeField, inputMap(activeField.getValue)))
+        ( for(inputField <- inputFields)
+          // The raw value is passed through:
+          //   1) outlier treatment,
+          //   2) missing value treatment,
+          //   3) invalid value treatment
+          //   4) type conversion
+          yield (inputField.getName -> inputField.prepare(inputsMap(inputField.getName.getValue)))
         ).toMap.asJava
 
+      System.out.println(arguments)
+
       val results = modelEvaluator.evaluate(arguments)
-      val targetName = modelEvaluator.getTargetField()
-      val targetValue = results.get(targetName)
+      val targetField = modelEvaluator.getTargetFields().asScala(0)
+      val targetValue = results.get(targetField.getName)
 
-      s"""{"results":[{'${targetName.getValue}': '${targetValue}'}]}"""
+      s"""{"results":[{'${targetField.getName}': '${targetValue}'}]}"""
     } catch {
        case e: Throwable => {
          System.out.println(e)
diff --git a/myapps/zeppelin/2BZFV8AQN/note.json b/myapps/zeppelin/2BZFV8AQN/note.json
new file mode 100644
index 0000000000..3d4829a92b
--- /dev/null
+++ b/myapps/zeppelin/2BZFV8AQN/note.json
@@ -0,0 +1,279 @@
+{
+  "paragraphs": [
+    {
+      "text": "%md ### Add the following to your Spark Interpreter Dependency List:  `/root/lib/jpmml-sparkml-package-1.0-SNAPSHOT.jar`",
+      "dateUpdated": "Oct 8, 2016 2:47:51 AM",
+      "config": {
+        "colWidth": 12.0,
+        "graph": {
+          "mode": "table",
+          "height": 300.0,
+          "optionOpen": false,
+          "keys": [],
+          "values": [],
+          "groups": [],
+          "scatter": {},
+          "map": {
+            "baseMapType": "Streets",
+            "isOnline": true,
+            "pinCols": []
+          }
+        },
+        "enabled": true,
+        "editorMode": "ace/mode/markdown"
+      },
+      "settings": {
+        "params": {},
+        "forms": {}
+      },
+      "jobName": "paragraph_1475894871931_-921322153",
+      "id": "20161008-024751_483869385",
+      "result": {
+        "code": "SUCCESS",
+        "type": "HTML",
+        "msg": "\u003ch3\u003eAdd the following to your Spark Interpreter Dependency List:  \u003ccode\u003e/root/lib/jpmml-sparkml-package-1.0-SNAPSHOT.jar\u003c/code\u003e\u003c/h3\u003e\n"
+      },
+      "dateCreated": "Oct 8, 2016 2:47:51 AM",
+      "status": "READY",
+      "errorMessage": "",
+      "progressUpdateIntervalMs": 500
+    },
+    {
+      "text": "val censusDF \u003d sqlContext.read.option(\"header\", \"true\").option(\"inferSchema\", \"true\").csv(\"file:///datasets/datapalooza.ml/R/census.csv\")",
+      "dateUpdated": "Oct 8, 2016 2:47:51 AM",
+      "config": {
+        "colWidth": 12.0,
+        "editorMode": "ace/mode/scala",
+        "graph": {
+          "mode": "table",
+          "height": 300.0,
+          "optionOpen": false,
+          "keys": [],
+          "values": [],
+          "groups": [],
+          "scatter": {},
+          "map": {
+            "baseMapType": "Streets",
+            "isOnline": true,
+            "pinCols": []
+          }
+        },
+        "enabled": true
+      },
+      "settings": {
+        "params": {},
+        "forms": {}
+      },
+      "jobName": "paragraph_1475894871931_-921322153",
+      "id": "20161008-024751_1412012478",
+      "result": {
+        "code": "SUCCESS",
+        "type": "TEXT",
+        "msg": "\ncensusDF: org.apache.spark.sql.DataFrame \u003d [age: int, workclass: string ... 12 more fields]\n"
+      },
+      "dateCreated": "Oct 8, 2016 2:47:51 AM",
+      "status": "READY",
+      "errorMessage": "",
+      "progressUpdateIntervalMs": 500
+    },
+    {
+      "text": "import org.apache.spark.ml.classification.DecisionTreeClassificationModel\nimport org.apache.spark.sql.types.StructType\nimport org.apache.spark.ml.feature.RFormula\nimport org.apache.spark.ml.classification.DecisionTreeClassifier\nimport org.apache.spark.ml.Pipeline\nimport org.apache.spark.ml.PipelineStage\nimport org.apache.spark.ml.Predictor\n\nval formulaStr: String \u003d \"income ~ .\"\n\nval schema: StructType \u003d censusDF.schema\nSystem.out.println(schema.treeString)\n\nval formula: RFormula \u003d new RFormula().setFormula(formulaStr)\n\nvar predictor: Predictor[_, _, _] \u003d new DecisionTreeClassifier().setMinInstancesPerNode(10)\n\npredictor.setLabelCol(formula.getLabelCol)\npredictor.setFeaturesCol(formula.getFeaturesCol)\n\nval pipeline \u003d new Pipeline().setStages(Array[PipelineStage](formula, predictor))\n\nval pipelineModel \u003d pipeline.fit(censusDF)\n\nval predictorModel \u003d pipelineModel.stages(1).asInstanceOf[DecisionTreeClassificationModel]",
+      "dateUpdated": "Oct 8, 2016 2:47:51 AM",
+      "config": {
+        "colWidth": 12.0,
+        "graph": {
+          "mode": "table",
+          "height": 300.0,
+          "optionOpen": false,
+          "keys": [],
+          "values": [],
+          "groups": [],
+          "scatter": {},
+          "map": {
+            "baseMapType": "Streets",
+            "isOnline": true,
+            "pinCols": []
+          }
+        },
+        "enabled": true
+      },
+      "settings": {
+        "params": {},
+        "forms": {}
+      },
+      "jobName": "paragraph_1475894871932_-923245898",
+      "id": "20161008-024751_358935873",
+      "result": {
+        "code": "SUCCESS",
+        "type": "TEXT",
+        "msg": "\nimport org.apache.spark.ml.classification.DecisionTreeClassificationModel\n\nimport org.apache.spark.sql.types.StructType\n\nimport org.apache.spark.ml.feature.RFormula\n\nimport org.apache.spark.ml.classification.DecisionTreeClassifier\n\nimport org.apache.spark.ml.Pipeline\n\nimport org.apache.spark.ml.PipelineStage\n\nimport org.apache.spark.ml.Predictor\n\nformulaStr: String \u003d income ~ .\n\nschema: org.apache.spark.sql.types.StructType \u003d StructType(StructField(age,IntegerType,true), StructField(workclass,StringType,true), StructField(education,StringType,true), StructField(education_num,IntegerType,true), StructField(marital_status,StringType,true), StructField(occupation,StringType,true), StructField(relationship,StringType,true), StructField(race,StringType,true), StructField(sex,StringType,true), StructField(capital_gain,IntegerType,true), StructField(capital_loss,IntegerType,true), StructField(hours_per_week,IntegerType,true), StructField(native_country,StringType,true), StructField(income,StringType,true))\n\nformula: org.apache.spark.ml.feature.RFormula \u003d RFormula(income ~ .) (uid\u003drFormula_d6766b135b6a)\n\npredictor: org.apache.spark.ml.Predictor[_, _, _] \u003d dtc_1b8ed2321084\n\nres1: Any \u003d dtc_1b8ed2321084\n\nres2: Any \u003d dtc_1b8ed2321084\n\npipeline: org.apache.spark.ml.Pipeline \u003d pipeline_83e52a51cbeb\n\npipelineModel: org.apache.spark.ml.PipelineModel \u003d pipeline_83e52a51cbeb\n\npredictorModel: org.apache.spark.ml.classification.DecisionTreeClassificationModel \u003d DecisionTreeClassificationModel (uid\u003ddtc_1b8ed2321084) of depth 5 with 55 nodes\n"
+      },
+      "dateCreated": "Oct 8, 2016 2:47:51 AM",
+      "status": "READY",
+      "errorMessage": "",
+      "progressUpdateIntervalMs": 500
+    },
+    {
+      "text": "predictorModel.toDebugString",
+      "dateUpdated": "Oct 8, 2016 2:47:51 AM",
+      "config": {
+        "colWidth": 12.0,
+        "editorMode": "ace/mode/scala",
+        "graph": {
+          "mode": "table",
+          "height": 300.0,
+          "optionOpen": false,
+          "keys": [],
+          "values": [],
+          "groups": [],
+          "scatter": {},
+          "map": {
+            "baseMapType": "Streets",
+            "isOnline": true,
+            "pinCols": []
+          }
+        },
+        "enabled": true
+      },
+      "settings": {
+        "params": {},
+        "forms": {}
+      },
+      "jobName": "paragraph_1475894871932_-923245898",
+      "id": "20161008-024751_536545078",
+      "result": {
+        "code": "SUCCESS",
+        "type": "TEXT",
+        "msg": "\n\n\n\n\n\n\n\n\n\n\n\n\n\n\n\n\n\n\n\n\n\n\n\n\n\n\n\nres3: String \u003d\n\"DecisionTreeClassificationModel (uid\u003ddtc_1b8ed2321084) of depth 5 with 55 nodes\n  If (feature 23 in {0.0})\n   If (feature 52 \u003c\u003d 7443.0)\n    If (feature 22 \u003c\u003d 13.0)\n     If (feature 54 \u003c\u003d 42.0)\n      If (feature 0 \u003c\u003d 33.0)\n       Predict: 0.0\n      Else (feature 0 \u003e 33.0)\n       Predict: 0.0\n     Else (feature 54 \u003e 42.0)\n      If (feature 9 in {0.0})\n       Predict: 0.0\n      Else (feature 9 not in {0.0})\n       Predict: 0.0\n    Else (feature 22 \u003e 13.0)\n     If (feature 54 \u003c\u003d 43.0)\n      If (feature 0 \u003c\u003d 32.0)\n       Predict: 0.0\n      Else (feature 0 \u003e 32.0)\n       Predict: 0.0\n     Else (feature 54 \u003e 43.0)\n      If (feature 0 \u003c\u003d 32.0)\n       Predict: 0.0\n      Else (feature 0 \u003e 32.0)\n       Predict: 0.0\n   Else (feature 52 \u003e 7443.0)\n    If (feature 54 \u003c\u003d 24.0)\n     Pred..."
+      },
+      "dateCreated": "Oct 8, 2016 2:47:51 AM",
+      "status": "READY",
+      "errorMessage": "",
+      "progressUpdateIntervalMs": 500
+    },
+    {
+      "text": "import org.jpmml.sparkml.ConverterUtil\n\nval pmml \u003d new String(ConverterUtil.toPMMLByteArray(schema, pipelineModel), \"UTF-8\")",
+      "dateUpdated": "Oct 8, 2016 2:47:51 AM",
+      "config": {
+        "colWidth": 12.0,
+        "graph": {
+          "mode": "table",
+          "height": 300.0,
+          "optionOpen": false,
+          "keys": [],
+          "values": [],
+          "groups": [],
+          "scatter": {},
+          "map": {
+            "baseMapType": "Streets",
+            "isOnline": true,
+            "pinCols": []
+          }
+        },
+        "enabled": true
+      },
+      "settings": {
+        "params": {},
+        "forms": {}
+      },
+      "jobName": "paragraph_1475894871932_-923245898",
+      "id": "20161008-024751_966582026",
+      "result": {
+        "code": "SUCCESS",
+        "type": "TEXT",
+        "msg": "\nimport org.jpmml.sparkml.ConverterUtil\n\n\n\n\n\n\n\n\n\n\n\n\n\n\n\n\n\n\n\n\n\n\n\npmml: String \u003d\n\"\u003c?xml version\u003d\"1.0\" encoding\u003d\"UTF-8\" standalone\u003d\"yes\"?\u003e\n\u003cPMML xmlns\u003d\"http://www.dmg.org/PMML-4_3\" version\u003d\"4.3\"\u003e\n\t\u003cHeader\u003e\n\t\t\u003cApplication/\u003e\n\t\t\u003cTimestamp\u003e2016-10-08T02:45:03Z\u003c/Timestamp\u003e\n\t\u003c/Header\u003e\n\t\u003cDataDictionary\u003e\n\t\t\u003cDataField name\u003d\"income\" optype\u003d\"categorical\" dataType\u003d\"string\"\u003e\n\t\t\t\u003cValue value\u003d\"\u0026lt;\u003d50K\"/\u003e\n\t\t\t\u003cValue value\u003d\"\u0026gt;50K\"/\u003e\n\t\t\u003c/DataField\u003e\n\t\t\u003cDataField name\u003d\"workclass\" optype\u003d\"categorical\" dataType\u003d\"string\"\u003e\n\t\t\t\u003cValue value\u003d\"Private\"/\u003e\n\t\t\t\u003cValue value\u003d\"Self-emp-not-inc\"/\u003e\n\t\t\t\u003cValue value\u003d\"Local-gov\"/\u003e\n\t\t\t\u003cValue value\u003d\"State-gov\"/\u003e\n\t\t\t\u003cValue value\u003d\"Self-emp-inc\"/\u003e\n\t\t\t\u003cValue value\u003d\"Federal-gov\"/\u003e\n\t\t\t\u003cValue value\u003d\"Without-pay\"/\u003e\n\t\t\u003c/DataField\u003e\n\t\t\u003cDataField name\u003d\"education\" optype\u003d\"categorical\" dataType\u003d\"string\"\u003e\n\t\t\t\u003cValue value\u003d\"HS-grad\"/\u003e\n\t\t\t\u003cValue value\u003d\"Some-..."
+      },
+      "dateCreated": "Oct 8, 2016 2:47:51 AM",
+      "status": "READY",
+      "errorMessage": "",
+      "progressUpdateIntervalMs": 500
+    },
+    {
+      "text": "import org.apache.http.client.methods.HttpPost\nimport org.apache.http.entity.StringEntity\nimport org.apache.http.impl.client.DefaultHttpClient // TODO:  this is deprecated\n\n// create an HttpPost object\nprintln(\"--- HTTP POST UPDATED PMML ---\")\nval post \u003d new HttpPost(s\"http://demo.pipeline.io:9040/update-pmml/census\")\n\n// set the Content-type\npost.setHeader(\"Content-type\", \"application/xml\")\n\n// add the JSON as a StringEntity\npost.setEntity(new StringEntity(pmml))\n\n// send the post request\nval response \u003d (new DefaultHttpClient).execute(post)\n\n// print the response headers\nprintln(\"--- HTTP RESPONSE HEADERS ---\")\nresponse.getAllHeaders.foreach(arg \u003d\u003e println(arg))",
+      "dateUpdated": "Oct 8, 2016 2:47:51 AM",
+      "config": {
+        "colWidth": 12.0,
+        "graph": {
+          "mode": "table",
+          "height": 300.0,
+          "optionOpen": false,
+          "keys": [],
+          "values": [],
+          "groups": [],
+          "scatter": {},
+          "map": {
+            "baseMapType": "Streets",
+            "isOnline": true,
+            "pinCols": []
+          }
+        },
+        "enabled": true
+      },
+      "settings": {
+        "params": {},
+        "forms": {}
+      },
+      "jobName": "paragraph_1475894871932_-923245898",
+      "id": "20161008-024751_568350190",
+      "result": {
+        "code": "SUCCESS",
+        "type": "TEXT",
+        "msg": "\nimport org.apache.http.client.methods.HttpPost\n\nimport org.apache.http.entity.StringEntity\n\nimport org.apache.http.impl.client.DefaultHttpClient\n--- HTTP POST UPDATED PMML ---\n\npost: org.apache.http.client.methods.HttpPost \u003d POST http://demo.pipeline.io:9040/update-pmml/census HTTP/1.1\n\nwarning: there was one deprecation warning; re-run with -deprecation for details\n\nresponse: org.apache.http.client.methods.CloseableHttpResponse \u003d HTTP/1.1 200 OK [Server: Apache-Coyote/1.1, X-Application-Context: prediction-service:local:9040, Content-Length: 0, Date: Sat, 08 Oct 2016 02:45:20 GMT] org.apache.http.conn.BasicManagedEntity@5a56fd43\n--- HTTP RESPONSE HEADERS ---\nServer: Apache-Coyote/1.1\nX-Application-Context: prediction-service:local:9040\nContent-Length: 0\nDate: Sat, 08 Oct 2016 02:45:20 GMT\n"
+      },
+      "dateCreated": "Oct 8, 2016 2:47:51 AM",
+      "status": "READY",
+      "errorMessage": "",
+      "progressUpdateIntervalMs": 500
+    },
+    {
+      "text": "",
+      "dateUpdated": "Oct 8, 2016 2:47:51 AM",
+      "config": {
+        "colWidth": 12.0,
+        "graph": {
+          "mode": "table",
+          "height": 300.0,
+          "optionOpen": false,
+          "keys": [],
+          "values": [],
+          "groups": [],
+          "scatter": {},
+          "map": {
+            "baseMapType": "Streets",
+            "isOnline": true,
+            "pinCols": []
+          }
+        },
+        "enabled": true
+      },
+      "settings": {
+        "params": {},
+        "forms": {}
+      },
+      "jobName": "paragraph_1475894871932_-923245898",
+      "id": "20161008-024751_333228662",
+      "result": {
+        "code": "SUCCESS",
+        "type": "TEXT",
+        "msg": ""
+      },
+      "dateCreated": "Oct 8, 2016 2:47:51 AM",
+      "status": "READY",
+      "errorMessage": "",
+      "progressUpdateIntervalMs": 500
+    }
+  ],
+  "name": "ZZ_Upload_Census_PMML",
+  "id": "2BZFV8AQN",
+  "angularObjects": {
+    "2BCMAZYZ5": [],
+    "2BDF8WQWY": [],
+    "2ARR8UZDJ": [],
+    "2AS9P7JSA": [],
+    "2AR33ZMZJ": []
+  },
+  "config": {
+    "looknfeel": "default"
+  },
+  "info": {}
+}
\ No newline at end of file