aboutsummaryrefslogtreecommitdiff
path: root/python
diff options
context:
space:
mode:
Diffstat (limited to 'python')
-rw-r--r--python/pyspark/mllib/linalg.py3
-rw-r--r--python/pyspark/sql/types.py2
2 files changed, 4 insertions, 1 deletions
diff --git a/python/pyspark/mllib/linalg.py b/python/pyspark/mllib/linalg.py
index 597012b1c9..f5aad28afd 100644
--- a/python/pyspark/mllib/linalg.py
+++ b/python/pyspark/mllib/linalg.py
@@ -152,6 +152,9 @@ class VectorUDT(UserDefinedType):
else:
raise ValueError("do not recognize type %r" % tpe)
+ def simpleString(self):
+ return "vector"
+
class Vector(object):
diff --git a/python/pyspark/sql/types.py b/python/pyspark/sql/types.py
index 31a861e1fe..0169028ccc 100644
--- a/python/pyspark/sql/types.py
+++ b/python/pyspark/sql/types.py
@@ -468,7 +468,7 @@ class UserDefinedType(DataType):
raise NotImplementedError("UDT must implement deserialize().")
def simpleString(self):
- return 'null'
+ return 'udt'
def json(self):
return json.dumps(self.jsonValue(), separators=(',', ':'), sort_keys=True)