aboutsummaryrefslogtreecommitdiff
path: root/python/pyspark/java_gateway.py
diff options
context:
space:
mode:
authorTor Myklebust <tmyklebu@gmail.com>2013-12-19 01:29:51 -0500
committerTor Myklebust <tmyklebu@gmail.com>2013-12-19 01:29:51 -0500
commitbf491bb3c0a9008caa4ac112672a4760b3d1c7b8 (patch)
treede0b56f6ab37714d35548af0229de143a3970618 /python/pyspark/java_gateway.py
parent95915f8b3b6d07a9dddb09a637aa23c8622bff9b (diff)
downloadspark-bf491bb3c0a9008caa4ac112672a4760b3d1c7b8.tar.gz
spark-bf491bb3c0a9008caa4ac112672a4760b3d1c7b8.tar.bz2
spark-bf491bb3c0a9008caa4ac112672a4760b3d1c7b8.zip
The rest of the Python side of those bindings.
Diffstat (limited to 'python/pyspark/java_gateway.py')
-rw-r--r--python/pyspark/java_gateway.py1
1 files changed, 1 insertions, 0 deletions
diff --git a/python/pyspark/java_gateway.py b/python/pyspark/java_gateway.py
index e615c1e9b6..2941984e19 100644
--- a/python/pyspark/java_gateway.py
+++ b/python/pyspark/java_gateway.py
@@ -62,5 +62,6 @@ def launch_gateway():
# Import the classes used by PySpark
java_import(gateway.jvm, "org.apache.spark.api.java.*")
java_import(gateway.jvm, "org.apache.spark.api.python.*")
+ java_import(gateway.jvm, "org.apache.spark.mllib.api.*")
java_import(gateway.jvm, "scala.Tuple2")
return gateway