Add missing :

apache · May 2, 2017 · 18c0253 · 18c0253
1 parent e8615c2
commit 18c0253
Show file tree

Hide file tree

Showing 2 changed files with 2 additions and 2 deletions.
diff --git a/python/pyspark/sql/catalog.py b/python/pyspark/sql/catalog.py
@@ -237,7 +237,7 @@ def registerFunction(self, name, f, returnType=StringType()):
         :param name: name of the UDF
         :param f: python function
         :param returnType: a :class:`pyspark.sql.types.DataType` object
-        :return a wrapped :class:`UserDefinedFunction`
+        :return: a wrapped :class:`UserDefinedFunction`
 
         >>> strlen = spark.catalog.registerFunction("stringLengthString", len)
         >>> spark.sql("SELECT stringLengthString('test')").collect()

diff --git a/python/pyspark/sql/context.py b/python/pyspark/sql/context.py
@@ -185,7 +185,7 @@ def registerFunction(self, name, f, returnType=StringType()):
         :param name: name of the UDF
         :param f: python function
         :param returnType: a :class:`pyspark.sql.types.DataType` object
-        :return a wrapped :class:`UserDefinedFunction`
+        :return: a wrapped :class:`UserDefinedFunction`
 
         >>> strlen = sqlContext.registerFunction("stringLengthString", lambda x: len(x))
         >>> sqlContext.sql("SELECT stringLengthString('test')").collect()