Skip to content

Commit 10add8b

Browse files
gatorsmileRobert Kruszewski
authored andcommitted
[SPARK-23122][PYSPARK][FOLLOWUP] Replace registerTempTable by createOrReplaceTempView
## What changes were proposed in this pull request? Replace `registerTempTable` by `createOrReplaceTempView`. ## How was this patch tested? N/A Author: gatorsmile <[email protected]> Closes apache#20523 from gatorsmile/updateExamples.
1 parent 5e8ac29 commit 10add8b

File tree

2 files changed

+2
-2
lines changed

2 files changed

+2
-2
lines changed

python/pyspark/sql/udf.py

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -357,7 +357,7 @@ def registerJavaUDAF(self, name, javaClassName):
357357
358358
>>> spark.udf.registerJavaUDAF("javaUDAF", "test.org.apache.spark.sql.MyDoubleAvg")
359359
>>> df = spark.createDataFrame([(1, "a"),(2, "b"), (3, "a")],["id", "name"])
360-
>>> df.registerTempTable("df")
360+
>>> df.createOrReplaceTempView("df")
361361
>>> spark.sql("SELECT name, javaUDAF(id) as avg from df group by name").collect()
362362
[Row(name=u'b', avg=102.0), Row(name=u'a', avg=102.0)]
363363
"""

sql/core/src/test/java/test/org/apache/spark/sql/JavaUDAFSuite.java

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -46,7 +46,7 @@ public void tearDown() {
4646
@SuppressWarnings("unchecked")
4747
@Test
4848
public void udf1Test() {
49-
spark.range(1, 10).toDF("value").registerTempTable("df");
49+
spark.range(1, 10).toDF("value").createOrReplaceTempView("df");
5050
spark.udf().registerJavaUDAF("myDoubleAvg", MyDoubleAvg.class.getName());
5151
Row result = spark.sql("SELECT myDoubleAvg(value) as my_avg from df").head();
5252
Assert.assertEquals(105.0, result.getDouble(0), 1.0e-6);

0 commit comments

Comments
 (0)