aboutsummaryrefslogtreecommitdiff
diff options
context:
space:
mode:
authorAnkur Dave <ankurdave@gmail.com>2014-01-10 12:17:17 -0800
committerAnkur Dave <ankurdave@gmail.com>2014-01-10 12:17:17 -0800
commitc39ec3017f0c8dcf5546ab8b9153bfe237b2aa68 (patch)
tree24b5ec3aa834a9d11ab1c3640dc2c2668b563215
parent5fcd2a61b4f10d039336e2ca3716e99c0d96ded2 (diff)
downloadspark-c39ec3017f0c8dcf5546ab8b9153bfe237b2aa68.tar.gz
spark-c39ec3017f0c8dcf5546ab8b9153bfe237b2aa68.tar.bz2
spark-c39ec3017f0c8dcf5546ab8b9153bfe237b2aa68.zip
Remove some commented code
-rw-r--r--graphx/src/main/scala/org/apache/spark/graphx/EdgeRDD.scala1
-rw-r--r--graphx/src/main/scala/org/apache/spark/graphx/EdgeTriplet.scala4
2 files changed, 0 insertions, 5 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 d1d9703159..61228e9628 100644
--- a/graphx/src/main/scala/org/apache/spark/graphx/EdgeRDD.scala
+++ b/graphx/src/main/scala/org/apache/spark/graphx/EdgeRDD.scala
@@ -54,7 +54,6 @@ class EdgeRDD[@specialized ED: ClassTag](
def mapEdgePartitions[ED2: ClassTag](f: (PartitionID, EdgePartition[ED]) => EdgePartition[ED2])
: EdgeRDD[ED2] = {
-// iter => iter.map { case (pid, ep) => (pid, f(ep)) }
new EdgeRDD[ED2](partitionsRDD.mapPartitions({ iter =>
val (pid, ep) = iter.next()
Iterator(Tuple2(pid, f(pid, ep)))
diff --git a/graphx/src/main/scala/org/apache/spark/graphx/EdgeTriplet.scala b/graphx/src/main/scala/org/apache/spark/graphx/EdgeTriplet.scala
index 7b209ed6c7..5e2528925f 100644
--- a/graphx/src/main/scala/org/apache/spark/graphx/EdgeTriplet.scala
+++ b/graphx/src/main/scala/org/apache/spark/graphx/EdgeTriplet.scala
@@ -14,10 +14,6 @@ import org.apache.spark.graphx.impl.VertexPartition
* that is not a trait.
*/
class EdgeTriplet[VD, ED] extends Edge[ED] {
-// class EdgeTriplet[@specialized(Char, Int, Boolean, Byte, Long, Float, Double) VD: ClassTag,
-// @specialized(Char, Int, Boolean, Byte, Long, Float, Double) ED: ClassTag] extends Edge[ED] {
-
-
/**
* The source vertex attribute
*/