Skip to content

Commit 1facc05

Browse files
committed
de-dupe scan
1 parent bf90ac7 commit 1facc05

File tree

3 files changed

+9
-9
lines changed

3 files changed

+9
-9
lines changed

sql/core/src/main/scala/org/apache/spark/sql/execution/ExistingRDD.scala

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -193,6 +193,6 @@ case class RDDScanExec(
193193
}
194194

195195
override def simpleString: String = {
196-
s"Scan $nodeName${Utils.truncatedString(output, "[", ",", "]")}"
196+
s"$nodeName${Utils.truncatedString(output, "[", ",", "]")}"
197197
}
198198
}

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-
:- Scan LocalTable [col1,col2] [col1#x, col2#x]
181+
:- Scan LocalTable [col1#x, col2#x]
182182
+- BroadcastExchange IdentityBroadcastMode
183-
+- Scan LocalTable [col1,col2] [col1#x, col2#x]
183+
+- Scan LocalTable [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 Scan RDD OneRowRelation [][]
236+
+- 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 Scan RDD OneRowRelation [][]
246+
+- 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 Scan RDD OneRowRelation [][]
256+
+- 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 Scan RDD OneRowRelation [][]
266+
+- 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 Scan RDD OneRowRelation [][]
276+
+- 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 Scan RDD OneRowRelation [][]
286+
+- Scan RDD OneRowRelation [][]
287287

288288

289289
-- !query 34

0 commit comments

Comments
 (0)