aboutsummaryrefslogtreecommitdiff
path: root/python/pyspark/mllib/feature.py
diff options
context:
space:
mode:
Diffstat (limited to 'python/pyspark/mllib/feature.py')
-rw-r--r--python/pyspark/mllib/feature.py6
1 files changed, 5 insertions, 1 deletions
diff --git a/python/pyspark/mllib/feature.py b/python/pyspark/mllib/feature.py
index 7b077b058c..7254679ebb 100644
--- a/python/pyspark/mllib/feature.py
+++ b/python/pyspark/mllib/feature.py
@@ -504,7 +504,8 @@ class Word2VecModel(JavaVectorTransformer, JavaSaveable, JavaLoader):
"""
jmodel = sc._jvm.org.apache.spark.mllib.feature \
.Word2VecModel.load(sc._jsc.sc(), path)
- return Word2VecModel(jmodel)
+ model = sc._jvm.Word2VecModelWrapper(jmodel)
+ return Word2VecModel(model)
@ignore_unicode_prefix
@@ -546,6 +547,9 @@ class Word2Vec(object):
>>> sameModel = Word2VecModel.load(sc, path)
>>> model.transform("a") == sameModel.transform("a")
True
+ >>> syms = sameModel.findSynonyms("a", 2)
+ >>> [s[0] for s in syms]
+ [u'b', u'c']
>>> from shutil import rmtree
>>> try:
... rmtree(path)