Skip to content

Commit 9b01aed

Browse files
wangxinyu666666王心雨
andauthored
registerTempTable替换为createOrReplaceTempView (#1798)
Co-authored-by: 王心雨 <[email protected]>
1 parent 6ee5ee7 commit 9b01aed

File tree

3 files changed

+5
-5
lines changed

3 files changed

+5
-5
lines changed

java/openmldb-batch/src/test/scala/com/_4paradigm/openmldb/batch/end2end/unsafe/TestDateUdf.scala

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -79,7 +79,7 @@ class TestDateUdf extends SparkTestSuite {
7979
))
8080

8181
val t1 = spark.createDataFrame(spark.sparkContext.makeRDD(data), schema)
82-
t1.registerTempTable("t1")
82+
t1.createOrReplaceTempView("t1")
8383
sess.registerTable("t1", t1)
8484

8585
val sqlText = "SELECT col1, day(col1), dayofmonth(col1), dayofweek(col1) FROM t1"
@@ -103,7 +103,7 @@ class TestDateUdf extends SparkTestSuite {
103103
))
104104

105105
val t1 = spark.createDataFrame(spark.sparkContext.makeRDD(data), schema)
106-
t1.registerTempTable("t1")
106+
t1.createOrReplaceTempView("t1")
107107
sess.registerTable("t1", t1)
108108

109109
val sqlText ="""

java/openmldb-batch/src/test/scala/com/_4paradigm/openmldb/batch/end2end/unsafe/TestTimestampUdf.scala

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -45,7 +45,7 @@ class TestTimestampUdf extends SparkTestSuite {
4545
StructField("col1", TimestampType)))
4646

4747
val t1 = spark.createDataFrame(spark.sparkContext.makeRDD(data), schema)
48-
t1.registerTempTable("t1")
48+
t1.createOrReplaceTempView("t1")
4949
sess.registerTable("t1", t1)
5050

5151
val sqlText = "SELECT col1, year(col1), month(col1), day(col1) FROM t1"
@@ -69,7 +69,7 @@ class TestTimestampUdf extends SparkTestSuite {
6969
))
7070

7171
val t1 = spark.createDataFrame(spark.sparkContext.makeRDD(data), schema)
72-
t1.registerTempTable("t1")
72+
t1.createOrReplaceTempView("t1")
7373
sess.registerTable("t1", t1)
7474

7575
val sqlText ="""

java/openmldb-batch/src/test/scala/com/_4paradigm/openmldb/batch/end2end/unsafe/TestWindowWithoutSelect.scala

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -45,7 +45,7 @@ class TestWindowWithoutSelect extends SparkTestSuite {
4545
val t1 = spark.createDataFrame(spark.sparkContext.makeRDD(data), schema)
4646

4747
sess.registerTable("t1", t1)
48-
t1.registerTempTable("t1")
48+
t1.createOrReplaceTempView("t1")
4949

5050
val sqlText =
5151
""" select

0 commit comments

Comments
 (0)