From 4b52edd5e16aa91b57840f505e9fb7b243f8a233 Mon Sep 17 00:00:00 2001
From: Davies Liu <davies@databricks.com>
Date: Fri, 21 Nov 2014 08:45:12 -0800
Subject: [PATCH] using named argument

---
 .../apache/spark/mllib/api/python/PythonMLLibAPI.scala | 10 +++++-----
 1 file changed, 5 insertions(+), 5 deletions(-)

diff --git a/mllib/src/main/scala/org/apache/spark/mllib/api/python/PythonMLLibAPI.scala b/mllib/src/main/scala/org/apache/spark/mllib/api/python/PythonMLLibAPI.scala
index 7fe7fc456dacd..803fbe0ba9997 100644
--- a/mllib/src/main/scala/org/apache/spark/mllib/api/python/PythonMLLibAPI.scala
+++ b/mllib/src/main/scala/org/apache/spark/mllib/api/python/PythonMLLibAPI.scala
@@ -78,7 +78,7 @@ class PythonMLLibAPI extends Serializable {
       val model = learner.run(data.rdd.persist(StorageLevel.MEMORY_AND_DISK), initialWeights)
       List(model.weights, model.intercept).map(_.asInstanceOf[Object]).asJava
     } finally {
-      data.rdd.unpersist(false)
+      data.rdd.unpersist(blocking = false)
     }
   }
 
@@ -274,7 +274,7 @@ class PythonMLLibAPI extends Serializable {
     try {
       kMeansAlg.run(data.rdd.persist(StorageLevel.MEMORY_AND_DISK))
     } finally {
-      data.rdd.unpersist(false)
+      data.rdd.unpersist(blocking = false)
     }
   }
 
@@ -419,7 +419,7 @@ class PythonMLLibAPI extends Serializable {
       val model = word2vec.fit(dataJRDD.rdd.persist(StorageLevel.MEMORY_AND_DISK_SER))
       new Word2VecModelWrapper(model)
     } finally {
-      dataJRDD.rdd.unpersist(false)
+      dataJRDD.rdd.unpersist(blocking = false)
     }
   }
 
@@ -484,7 +484,7 @@ class PythonMLLibAPI extends Serializable {
     try {
       DecisionTree.train(data.rdd.persist(StorageLevel.MEMORY_AND_DISK), strategy)
     } finally {
-      data.rdd.unpersist(false)
+      data.rdd.unpersist(blocking = false)
     }
   }
 
@@ -523,7 +523,7 @@ class PythonMLLibAPI extends Serializable {
         RandomForest.trainRegressor(cached, strategy, numTrees, featureSubsetStrategy, seed)
       }
     } finally {
-      cached.unpersist(false)
+      cached.unpersist(blocking = false)
     }
   }