Skip to content

Commit 9775df6

Browse files
gatorsmileHyukjinKwon
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 #20523 from gatorsmile/updateExamples.
1 parent c36fecc commit 9775df6

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
@@ -356,7 +356,7 @@ def registerJavaUDAF(self, name, javaClassName):
356356
357357
>>> spark.udf.registerJavaUDAF("javaUDAF", "test.org.apache.spark.sql.MyDoubleAvg")
358358
>>> df = spark.createDataFrame([(1, "a"),(2, "b"), (3, "a")],["id", "name"])
359-
>>> df.registerTempTable("df")
359+
>>> df.createOrReplaceTempView("df")
360360
>>> spark.sql("SELECT name, javaUDAF(id) as avg from df group by name").collect()
361361
[Row(name=u'b', avg=102.0), Row(name=u'a', avg=102.0)]
362362
"""

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)