Skip to content

Commit ccaf06f

Browse files
committed
Shadow members in withXYZ() methods rather than using underscores
1 parent c34abc0 commit ccaf06f

File tree

2 files changed

+8
-8
lines changed

2 files changed

+8
-8
lines changed

graphx/src/main/scala/org/apache/spark/graphx/EdgeRDD.scala

Lines changed: 4 additions & 4 deletions
Original file line numberDiff line numberDiff line change
@@ -140,8 +140,8 @@ class EdgeRDD[@specialized ED: ClassTag, VD: ClassTag](
140140

141141
/** Replaces the vertex partitions while preserving all other properties of the VertexRDD. */
142142
private[graphx] def withPartitionsRDD[ED2: ClassTag, VD2: ClassTag](
143-
partitionsRDD_ : RDD[(PartitionID, EdgePartition[ED2, VD2])]): EdgeRDD[ED2, VD2] = {
144-
new EdgeRDD(partitionsRDD_, targetStorageLevel)
143+
partitionsRDD: RDD[(PartitionID, EdgePartition[ED2, VD2])]): EdgeRDD[ED2, VD2] = {
144+
new EdgeRDD(partitionsRDD, this.targetStorageLevel)
145145
}
146146

147147
/**
@@ -152,8 +152,8 @@ class EdgeRDD[@specialized ED: ClassTag, VD: ClassTag](
152152
* [[org.apache.spark.graphx.EdgeRDD#cache]] on the returned EdgeRDD.
153153
*/
154154
private[graphx] def withTargetStorageLevel(
155-
targetStorageLevel_ : StorageLevel): EdgeRDD[ED, VD] = {
156-
new EdgeRDD(partitionsRDD, targetStorageLevel_)
155+
targetStorageLevel: StorageLevel): EdgeRDD[ED, VD] = {
156+
new EdgeRDD(this.partitionsRDD, targetStorageLevel)
157157
}
158158

159159
}

graphx/src/main/scala/org/apache/spark/graphx/VertexRDD.scala

Lines changed: 4 additions & 4 deletions
Original file line numberDiff line numberDiff line change
@@ -325,8 +325,8 @@ class VertexRDD[@specialized VD: ClassTag](
325325

326326
/** Replaces the vertex partitions while preserving all other properties of the VertexRDD. */
327327
private[graphx] def withPartitionsRDD[VD2: ClassTag](
328-
partitionsRDD_ : RDD[ShippableVertexPartition[VD2]]): VertexRDD[VD2] = {
329-
new VertexRDD(partitionsRDD_, targetStorageLevel)
328+
partitionsRDD: RDD[ShippableVertexPartition[VD2]]): VertexRDD[VD2] = {
329+
new VertexRDD(partitionsRDD, this.targetStorageLevel)
330330
}
331331

332332
/**
@@ -337,8 +337,8 @@ class VertexRDD[@specialized VD: ClassTag](
337337
* [[org.apache.spark.graphx.VertexRDD#cache]] on the returned VertexRDD.
338338
*/
339339
private[graphx] def withTargetStorageLevel(
340-
targetStorageLevel_ : StorageLevel): VertexRDD[VD] = {
341-
new VertexRDD(partitionsRDD, targetStorageLevel_)
340+
targetStorageLevel: StorageLevel): VertexRDD[VD] = {
341+
new VertexRDD(this.partitionsRDD, targetStorageLevel)
342342
}
343343

344344
/** Generates an RDD of vertex attributes suitable for shipping to the edge partitions. */

0 commit comments

Comments
 (0)