@@ -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