From 1c70366d2fdb8354cbb58eb465b137be1ccb562f Mon Sep 17 00:00:00 2001 From: Larry Xiao Date: Wed, 3 Sep 2014 10:03:21 +0800 Subject: [PATCH] scalastyle check: wrap line, parameter list indent 4 spaces --- .../apache/spark/graphx/impl/ShippableVertexPartition.scala | 6 ++++-- 1 file changed, 4 insertions(+), 2 deletions(-) diff --git a/graphx/src/main/scala/org/apache/spark/graphx/impl/ShippableVertexPartition.scala b/graphx/src/main/scala/org/apache/spark/graphx/impl/ShippableVertexPartition.scala index 16e82b64c45bc..f0834c317fcdb 100644 --- a/graphx/src/main/scala/org/apache/spark/graphx/impl/ShippableVertexPartition.scala +++ b/graphx/src/main/scala/org/apache/spark/graphx/impl/ShippableVertexPartition.scala @@ -43,7 +43,7 @@ object ShippableVertexPartition { * table, filling in missing vertices mentioned in the routing table using `defaultVal`. */ def apply[VD: ClassTag]( - iter: Iterator[(VertexId, VD)], routingTable: RoutingTablePartition, defaultVal: VD) + iter: Iterator[(VertexId, VD)], routingTable: RoutingTablePartition, defaultVal: VD) : ShippableVertexPartition[VD] = apply(iter, routingTable, defaultVal, (a, b) => a) @@ -53,7 +53,9 @@ object ShippableVertexPartition { * and merging duplicate vertex atrribute with mergeFunc. */ def apply[VD: ClassTag]( - iter: Iterator[(VertexId, VD)], routingTable: RoutingTablePartition, defaultVal: VD, mergeFunc: (VD, VD) => VD) + iter: Iterator[(VertexId, VD)], routingTable: RoutingTablePartition, defaultVal: VD, + mergeFunc: (VD, VD) => VD + ) : ShippableVertexPartition[VD] = { val fullIter = iter ++ routingTable.iterator.map(vid => (vid, defaultVal)) val (index, values, mask) = VertexPartitionBase.initFrom(fullIter, mergeFunc)