Skip to content

Commit 13c790d

Browse files
committed
Fix tests
1 parent 4000c09 commit 13c790d

File tree

1 file changed

+3
-3
lines changed

1 file changed

+3
-3
lines changed

python/pyspark/sql/udf.py

Lines changed: 3 additions & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -376,17 +376,17 @@ def registerJavaFunction(self, name, javaClassName, returnType=None):
376376
>>> spark.udf.registerJavaFunction(
377377
... "javaStringLength", "test.org.apache.spark.sql.JavaStringLength", IntegerType())
378378
>>> spark.sql("SELECT javaStringLength('test')").collect()
379-
[Row(UDF:javaStringLength(test)=4)]
379+
[Row(javaStringLength(test)=4)]
380380
381381
>>> spark.udf.registerJavaFunction(
382382
... "javaStringLength2", "test.org.apache.spark.sql.JavaStringLength")
383383
>>> spark.sql("SELECT javaStringLength2('test')").collect()
384-
[Row(UDF:javaStringLength2(test)=4)]
384+
[Row(javaStringLength2(test)=4)]
385385
386386
>>> spark.udf.registerJavaFunction(
387387
... "javaStringLength3", "test.org.apache.spark.sql.JavaStringLength", "integer")
388388
>>> spark.sql("SELECT javaStringLength3('test')").collect()
389-
[Row(UDF:javaStringLength3(test)=4)]
389+
[Row(javaStringLength3(test)=4)]
390390
"""
391391

392392
jdt = None

0 commit comments

Comments
 (0)