From 18c025332318f547902888db981e5c7c25c1ea72 Mon Sep 17 00:00:00 2001 From: zero323 Date: Tue, 2 May 2017 15:08:29 +0200 Subject: [PATCH] Add missing : --- python/pyspark/sql/catalog.py | 2 +- python/pyspark/sql/context.py | 2 +- 2 files changed, 2 insertions(+), 2 deletions(-) diff --git a/python/pyspark/sql/catalog.py b/python/pyspark/sql/catalog.py index 51df93aeb0764..fc5f2ed8acbe0 100644 --- 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 index f4bcf0f8dc44b..4a75fb2d5c41c 100644 --- 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()