aboutsummaryrefslogtreecommitdiff
path: root/python/pyspark/mllib/linalg.py
diff options
context:
space:
mode:
Diffstat (limited to 'python/pyspark/mllib/linalg.py')
-rw-r--r--python/pyspark/mllib/linalg.py12
1 files changed, 0 insertions, 12 deletions
diff --git a/python/pyspark/mllib/linalg.py b/python/pyspark/mllib/linalg.py
index 1b9bf59624..d0a0e102a1 100644
--- a/python/pyspark/mllib/linalg.py
+++ b/python/pyspark/mllib/linalg.py
@@ -29,7 +29,6 @@ import copy_reg
import numpy as np
-from pyspark.serializers import AutoBatchedSerializer, PickleSerializer
__all__ = ['Vector', 'DenseVector', 'SparseVector', 'Vectors']
@@ -52,17 +51,6 @@ except:
_have_scipy = False
-# this will call the MLlib version of pythonToJava()
-def _to_java_object_rdd(rdd):
- """ Return an JavaRDD of Object by unpickling
-
- It will convert each Python object into Java object by Pyrolite, whenever the
- RDD is serialized in batch or not.
- """
- rdd = rdd._reserialize(AutoBatchedSerializer(PickleSerializer()))
- return rdd.ctx._jvm.SerDe.pythonToJava(rdd._jrdd, True)
-
-
def _convert_to_vector(l):
if isinstance(l, Vector):
return l