Skip to content

Commit 0c0aa94

Browse files
committed
update sql/core/src/test/resources/sql-tests/results/*
1 parent 9c29252 commit 0c0aa94

File tree

3 files changed

+11
-11
lines changed

3 files changed

+11
-11
lines changed

sql/core/src/test/resources/sql-tests/results/inline-table.sql.out

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -178,6 +178,6 @@ Join Cross
178178

179179
== Physical Plan ==
180180
BroadcastNestedLoopJoin BuildRight, Cross
181-
:- LocalTableScan [col1#x, col2#x]
181+
:- Scan LocalTable [col1,col2] [col1#x, col2#x]
182182
+- BroadcastExchange IdentityBroadcastMode
183-
+- LocalTableScan [col1#x, col2#x]
183+
+- Scan LocalTable [col1,col2] [col1#x, col2#x]

sql/core/src/test/resources/sql-tests/results/operators.sql.out

Lines changed: 6 additions & 6 deletions
Original file line numberDiff line numberDiff line change
@@ -233,7 +233,7 @@ struct<plan:string>
233233
-- !query 28 output
234234
== Physical Plan ==
235235
*Project [null AS (CAST(concat(a, CAST(1 AS STRING)) AS DOUBLE) + CAST(2 AS DOUBLE))#x]
236-
+- Scan OneRowRelation[]
236+
+- Scan Scan RDD OneRowRelation [][]
237237

238238

239239
-- !query 29
@@ -243,7 +243,7 @@ struct<plan:string>
243243
-- !query 29 output
244244
== Physical Plan ==
245245
*Project [-1b AS concat(CAST((1 - 2) AS STRING), b)#x]
246-
+- Scan OneRowRelation[]
246+
+- Scan Scan RDD OneRowRelation [][]
247247

248248

249249
-- !query 30
@@ -253,7 +253,7 @@ struct<plan:string>
253253
-- !query 30 output
254254
== Physical Plan ==
255255
*Project [11b AS concat(CAST(((2 * 4) + 3) AS STRING), b)#x]
256-
+- Scan OneRowRelation[]
256+
+- Scan Scan RDD OneRowRelation [][]
257257

258258

259259
-- !query 31
@@ -263,7 +263,7 @@ struct<plan:string>
263263
-- !query 31 output
264264
== Physical Plan ==
265265
*Project [4a2.0 AS concat(concat(CAST((3 + 1) AS STRING), a), CAST((CAST(4 AS DOUBLE) / CAST(2 AS DOUBLE)) AS STRING))#x]
266-
+- Scan OneRowRelation[]
266+
+- Scan Scan RDD OneRowRelation [][]
267267

268268

269269
-- !query 32
@@ -273,7 +273,7 @@ struct<plan:string>
273273
-- !query 32 output
274274
== Physical Plan ==
275275
*Project [true AS ((1 = 1) OR (concat(a, b) = ab))#x]
276-
+- Scan OneRowRelation[]
276+
+- Scan Scan RDD OneRowRelation [][]
277277

278278

279279
-- !query 33
@@ -283,7 +283,7 @@ struct<plan:string>
283283
-- !query 33 output
284284
== Physical Plan ==
285285
*Project [false AS ((concat(a, c) = ac) AND (2 = 3))#x]
286-
+- Scan OneRowRelation[]
286+
+- Scan Scan RDD OneRowRelation [][]
287287

288288

289289
-- !query 34

sql/core/src/test/scala/org/apache/spark/sql/streaming/StreamSuite.scala

Lines changed: 3 additions & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -476,7 +476,7 @@ class StreamSuite extends StreamTest {
476476
.mkString("\n")
477477
assert(explainString.contains("StateStoreRestore"))
478478
assert(explainString.contains("StreamingRelation"))
479-
assert(!explainString.contains("LocalTableScan"))
479+
assert(!explainString.contains("Scan LocalTable"))
480480

481481
// Test StreamingQuery.display
482482
val q = df.writeStream.queryName("memory_explain").outputMode("complete").format("memory")
@@ -493,15 +493,15 @@ class StreamSuite extends StreamTest {
493493
val explainWithoutExtended = q.explainInternal(false)
494494
// `extended = false` only displays the physical plan.
495495
assert("LocalRelation".r.findAllMatchIn(explainWithoutExtended).size === 0)
496-
assert("LocalTableScan".r.findAllMatchIn(explainWithoutExtended).size === 1)
496+
assert("Scan LocalTable".r.findAllMatchIn(explainWithoutExtended).size === 1)
497497
// Use "StateStoreRestore" to verify that it does output a streaming physical plan
498498
assert(explainWithoutExtended.contains("StateStoreRestore"))
499499

500500
val explainWithExtended = q.explainInternal(true)
501501
// `extended = true` displays 3 logical plans (Parsed/Optimized/Optimized) and 1 physical
502502
// plan.
503503
assert("LocalRelation".r.findAllMatchIn(explainWithExtended).size === 3)
504-
assert("LocalTableScan".r.findAllMatchIn(explainWithExtended).size === 1)
504+
assert("Scan LocalTable".r.findAllMatchIn(explainWithExtended).size === 1)
505505
// Use "StateStoreRestore" to verify that it does output a streaming physical plan
506506
assert(explainWithExtended.contains("StateStoreRestore"))
507507
} finally {

0 commit comments

Comments
 (0)