rename

Author: gatorsmile

python/pyspark/sql/catalog.py

@@ -266,7 +266,7 @@ def registerFunction(self, name, f, returnType=StringType()):
         """
 
         if hasattr(f, 'asNondeterministic'):
-            udf = f._set_name(name, returnType)
+            udf = f._set_name_type(name, returnType)
         else:
             udf = UserDefinedFunction(f, returnType=returnType, name=name,
                                       evalType=PythonEvalType.SQL_BATCHED_UDF)

python/pyspark/sql/udf.py

@@ -138,7 +138,7 @@ def __call__(self, *cols):
         sc = SparkContext._active_spark_context
         return Column(judf.apply(_to_seq(sc, cols, _to_java_column)))
 
-    def _set_name(self, name, returnType=StringType()):
+    def _set_name_type(self, name, returnType=StringType()):
         """
         Updates the name of UserDefinedFunction.
         """
@@ -179,7 +179,7 @@ def wrapper(*args):
         wrapper._judf = self._judf
         wrapper._create_judf = self._create_judf
         wrapper._wrapped = self._wrapped
-        wrapper._set_name = self._set_name
+        wrapper._set_name_type = self._set_name_type
 
         return wrapper