diff options
| author | Prashant Sharma <prashant.s@imaginea.com> | 2014-02-09 22:17:52 -0800 |
|---|---|---|
| committer | Reynold Xin <rxin@apache.org> | 2014-02-09 22:17:52 -0800 |
| commit | 919bd7f669c61500eee7231298d9880b320eb6f3 (patch) | |
| tree | 5cdcf197aef425b6be47b676f8d7fe3d1e2e8c34 /graphx | |
| parent | 2182aa3c55737a90e0ff200eede7146b440801a3 (diff) | |
| download | spark-919bd7f669c61500eee7231298d9880b320eb6f3.tar.gz spark-919bd7f669c61500eee7231298d9880b320eb6f3.tar.bz2 spark-919bd7f669c61500eee7231298d9880b320eb6f3.zip | |
Merge pull request #567 from ScrapCodes/style2.
SPARK-1058, Fix Style Errors and Add Scala Style to Spark Build. Pt 2
Continuation of PR #557
With this all scala style errors are fixed across the code base !!
The reason for creating a separate PR was to not interrupt an already reviewed and ready to merge PR. Hope this gets reviewed soon and merged too.
Author: Prashant Sharma <prashant.s@imaginea.com>
Closes #567 and squashes the following commits:
3b1ec30 [Prashant Sharma] scala style fixes
Diffstat (limited to 'graphx')
| -rw-r--r-- | graphx/src/main/scala/org/apache/spark/graphx/EdgeRDD.scala | 3 |
1 files changed, 1 insertions, 2 deletions
diff --git a/graphx/src/main/scala/org/apache/spark/graphx/EdgeRDD.scala b/graphx/src/main/scala/org/apache/spark/graphx/EdgeRDD.scala index 799a9dd1ee..f2296a865e 100644 --- a/graphx/src/main/scala/org/apache/spark/graphx/EdgeRDD.scala +++ b/graphx/src/main/scala/org/apache/spark/graphx/EdgeRDD.scala @@ -67,8 +67,7 @@ class EdgeRDD[@specialized ED: ClassTag]( } private[graphx] def mapEdgePartitions[ED2: ClassTag]( - f: (PartitionID, EdgePartition[ED]) => EdgePartition[ED2]) - : EdgeRDD[ED2] = { + f: (PartitionID, EdgePartition[ED]) => EdgePartition[ED2]): EdgeRDD[ED2] = { new EdgeRDD[ED2](partitionsRDD.mapPartitions({ iter => val (pid, ep) = iter.next() Iterator(Tuple2(pid, f(pid, ep))) |