remove duplicate code

maropu · Jun 25, 2015 · 21bae35 · 21bae35
1 parent eb12f95
commit 21bae35
Showing 1 changed file with 0 additions and 3 deletions.
diff --git a/python/pyspark/mllib/clustering.py b/python/pyspark/mllib/clustering.py
@@ -101,9 +101,6 @@ def k(self):
 
     def predict(self, x):
         """Find the cluster to which x belongs in this model."""
-        if isinstance(x, RDD):
-            return x.map(lambda v: self.predict(v))
-
         best = 0
         best_distance = float("inf")
         if isinstance(x, RDD):