Skip to content

Commit 1c70366

Browse files
committed
scalastyle check: wrap line, parameter list indent 4 spaces
1 parent e4ca697 commit 1c70366

File tree

1 file changed

+4
-2
lines changed

1 file changed

+4
-2
lines changed

graphx/src/main/scala/org/apache/spark/graphx/impl/ShippableVertexPartition.scala

Lines changed: 4 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -43,7 +43,7 @@ object ShippableVertexPartition {
4343
* table, filling in missing vertices mentioned in the routing table using `defaultVal`.
4444
*/
4545
def apply[VD: ClassTag](
46-
iter: Iterator[(VertexId, VD)], routingTable: RoutingTablePartition, defaultVal: VD)
46+
iter: Iterator[(VertexId, VD)], routingTable: RoutingTablePartition, defaultVal: VD)
4747
: ShippableVertexPartition[VD] =
4848
apply(iter, routingTable, defaultVal, (a, b) => a)
4949

@@ -53,7 +53,9 @@ object ShippableVertexPartition {
5353
* and merging duplicate vertex atrribute with mergeFunc.
5454
*/
5555
def apply[VD: ClassTag](
56-
iter: Iterator[(VertexId, VD)], routingTable: RoutingTablePartition, defaultVal: VD, mergeFunc: (VD, VD) => VD)
56+
iter: Iterator[(VertexId, VD)], routingTable: RoutingTablePartition, defaultVal: VD,
57+
mergeFunc: (VD, VD) => VD
58+
)
5759
: ShippableVertexPartition[VD] = {
5860
val fullIter = iter ++ routingTable.iterator.map(vid => (vid, defaultVal))
5961
val (index, values, mask) = VertexPartitionBase.initFrom(fullIter, mergeFunc)

0 commit comments

Comments
 (0)