Skip to content

Commit 8f54287

Browse files
author
Nathan Kronenfeld
committed
Changed string addition to string interpolation as per PR comments
1 parent 2a0cd4d commit 8f54287

File tree

1 file changed

+5
-5
lines changed
  • core/src/main/scala/org/apache/spark/rdd

1 file changed

+5
-5
lines changed

core/src/main/scala/org/apache/spark/rdd/RDD.scala

Lines changed: 5 additions & 5 deletions
Original file line numberDiff line numberDiff line change
@@ -1279,7 +1279,7 @@ abstract class RDD[T: ClassTag](
12791279
info.numCachedPartitions, bytesToString(info.memSize),
12801280
bytesToString(info.tachyonSize), bytesToString(info.diskSize)))
12811281

1282-
(rdd.toString+" ["+persistence+"]") +: storageInfo
1282+
s"$rdd [$persistence]" +: storageInfo
12831283
}
12841284

12851285
// Apply a different rule to the last child
@@ -1309,8 +1309,8 @@ abstract class RDD[T: ClassTag](
13091309
val nextPrefix = (" " * leftOffset) + "|" + (" " * (partitionStr.length - leftOffset))
13101310

13111311
debugSelf(rdd).zipWithIndex.map{
1312-
case (desc: String, 0) => partitionStr+" "+desc
1313-
case (desc: String, _) => nextPrefix+" "+desc
1312+
case (desc: String, 0) => s"$partitionStr $desc"
1313+
case (desc: String, _) => s"$nextPrefix $desc"
13141314
} ++ debugChildren(rdd, nextPrefix)
13151315
}
13161316
def shuffleDebugString(rdd: RDD[_], prefix: String = "", isLastChild: Boolean): Seq[String] = {
@@ -1323,8 +1323,8 @@ abstract class RDD[T: ClassTag](
13231323
+ (" " * leftOffset) + "|" + (" " * (partitionStr.length - leftOffset)))
13241324

13251325
debugSelf(rdd).zipWithIndex.map{
1326-
case (desc: String, 0) => thisPrefix+"+-"+partitionStr+" "+desc
1327-
case (desc: String, _) => nextPrefix+desc
1326+
case (desc: String, 0) => s"$thisPrefix+-$partitionStr $desc"
1327+
case (desc: String, _) => s"$nextPrefix$desc"
13281328
} ++ debugChildren(rdd, nextPrefix)
13291329
}
13301330
def debugString(rdd: RDD[_],

0 commit comments

Comments
 (0)