Skip to content

Commit b2d6590

Browse files
committed
Fix long lines
1 parent 0d2f4c7 commit b2d6590

File tree

1 file changed

+15
-11
lines changed

1 file changed

+15
-11
lines changed

graphx/src/main/scala/org/apache/spark/graphx/api/java/JavaVertexRDD.scala

Lines changed: 15 additions & 11 deletions
Original file line numberDiff line numberDiff line change
@@ -90,24 +90,26 @@ class JavaVertexRDD[VD](val vertexRDD: VertexRDD[VD])(implicit val vdTag: ClassT
9090
f: JFunction3[JLong, VD, Optional[VD2], VD3]): JavaVertexRDD[VD3] = {
9191
implicit val vd2Tag: ClassTag[VD2] = fakeClassTag
9292
implicit val vd3Tag: ClassTag[VD3] = fakeClassTag
93-
vertexRDD.leftZipJoin(other) { (vid, a, bOpt) => f.call(vid, a, JavaUtils.optionToOptional(bOpt)) }
93+
vertexRDD.leftZipJoin(other) {
94+
(vid, a, bOpt) => f.call(vid, a, JavaUtils.optionToOptional(bOpt))
95+
}
9496
}
9597

9698
/**
97-
* Left joins this JavaVertexRDD with an RDD containing vertex attribute pairs. If the other RDD is
98-
* backed by a JavaVertexRDD with the same index then the efficient [[leftZipJoin]] implementation is
99-
* used. The resulting JavaVertexRDD contains an entry for each vertex in `this`. If `other` is
100-
* missing any vertex in this JavaVertexRDD, `f` is passed `None`. If there are duplicates,
101-
* the vertex is picked arbitrarily.
99+
* Left joins this JavaVertexRDD with an RDD containing vertex attribute pairs. If the other RDD
100+
* is backed by a JavaVertexRDD with the same index then the efficient [[leftZipJoin]]
101+
* implementation is used. The resulting JavaVertexRDD contains an entry for each vertex in
102+
* `this`. If `other` is missing any vertex in this JavaVertexRDD, `f` is passed `None`. If there
103+
* are duplicates, the vertex is picked arbitrarily.
102104
*
103105
* @tparam VD2 the attribute type of the other JavaVertexRDD
104106
* @tparam VD3 the attribute type of the resulting JavaVertexRDD
105107
*
106108
* @param other the other JavaVertexRDD with which to join
107109
* @param f the function mapping a vertex id and its attributes in this and the other vertex set
108110
* to a new vertex attribute.
109-
* @return a JavaVertexRDD containing all the vertices in this JavaVertexRDD with the attributes emitted
110-
* by `f`.
111+
* @return a JavaVertexRDD containing all the vertices in this JavaVertexRDD with the attributes
112+
* emitted by `f`.
111113
*/
112114
def leftJoin[VD2, VD3](
113115
other: JavaPairRDD[JLong, VD2],
@@ -116,12 +118,14 @@ class JavaVertexRDD[VD](val vertexRDD: VertexRDD[VD])(implicit val vdTag: ClassT
116118
implicit val vd2Tag: ClassTag[VD2] = fakeClassTag
117119
implicit val vd3Tag: ClassTag[VD3] = fakeClassTag
118120
val scalaOther: RDD[(VertexId, VD2)] = other.rdd.map(kv => (kv._1, kv._2))
119-
vertexRDD.leftJoin(scalaOther) { (vid, a, bOpt) => f.call(vid, a, JavaUtils.optionToOptional(bOpt)) }
121+
vertexRDD.leftJoin(scalaOther) {
122+
(vid, a, bOpt) => f.call(vid, a, JavaUtils.optionToOptional(bOpt))
123+
}
120124
}
121125

122126
/**
123-
* Efficiently inner joins this JavaVertexRDD with another JavaVertexRDD sharing the same index. See
124-
* [[innerJoin]] for the behavior of the join.
127+
* Efficiently inner joins this JavaVertexRDD with another JavaVertexRDD sharing the same index.
128+
* See [[innerJoin]] for the behavior of the join.
125129
*/
126130
def innerZipJoin[U, VD2](
127131
other: JavaVertexRDD[U],

0 commit comments

Comments
 (0)