diff options
| author | Ankur Dave <ankurdave@gmail.com> | 2014-01-09 00:13:23 -0800 |
|---|---|---|
| committer | Ankur Dave <ankurdave@gmail.com> | 2014-01-09 00:13:23 -0800 |
| commit | 7309a29c755ae833f35523546e851be4c2f328be (patch) | |
| tree | 5eabba253c42b252026ac583fc60382e34c71e7b /graph/src | |
| parent | 22374559a23adbcb5c286e0aadc7cd40c228726f (diff) | |
| download | spark-7309a29c755ae833f35523546e851be4c2f328be.tar.gz spark-7309a29c755ae833f35523546e851be4c2f328be.tar.bz2 spark-7309a29c755ae833f35523546e851be4c2f328be.zip | |
Removed Kryo dependency and graphx-shell
Diffstat (limited to 'graph/src')
4 files changed, 6 insertions, 5 deletions
diff --git a/graph/src/main/scala/org/apache/spark/graph/Edge.scala b/graph/src/main/scala/org/apache/spark/graph/Edge.scala index 7e8ae7c790..5ac77839eb 100644 --- a/graph/src/main/scala/org/apache/spark/graph/Edge.scala +++ b/graph/src/main/scala/org/apache/spark/graph/Edge.scala @@ -19,7 +19,7 @@ case class Edge[@specialized(Char, Int, Boolean, Byte, Long, Float, Double) ED] /** * The attribute associated with the edge. */ - var attr: ED = nullValue[ED]) { + var attr: ED = nullValue[ED]) extends Serializable { /** * Given one vertex in the edge return the other vertex. diff --git a/graph/src/main/scala/org/apache/spark/graph/impl/EdgePartition.scala b/graph/src/main/scala/org/apache/spark/graph/impl/EdgePartition.scala index 7367269f67..7ae4d7df43 100644 --- a/graph/src/main/scala/org/apache/spark/graph/impl/EdgePartition.scala +++ b/graph/src/main/scala/org/apache/spark/graph/impl/EdgePartition.scala @@ -19,7 +19,7 @@ class EdgePartition[@specialized(Char, Int, Boolean, Byte, Long, Float, Double) val srcIds: Array[Vid], val dstIds: Array[Vid], val data: Array[ED], - val index: PrimitiveKeyOpenHashMap[Vid, Int]) { + val index: PrimitiveKeyOpenHashMap[Vid, Int]) extends Serializable { /** * Reverse all the edges in this partition. diff --git a/graph/src/main/scala/org/apache/spark/graph/impl/MessageToPartition.scala b/graph/src/main/scala/org/apache/spark/graph/impl/MessageToPartition.scala index 66fe796d2e..bf033945de 100644 --- a/graph/src/main/scala/org/apache/spark/graph/impl/MessageToPartition.scala +++ b/graph/src/main/scala/org/apache/spark/graph/impl/MessageToPartition.scala @@ -11,7 +11,7 @@ class VertexBroadcastMsg[@specialized(Int, Long, Double, Boolean) T]( @transient var partition: Pid, var vid: Vid, var data: T) - extends Product2[Pid, (Vid, T)] { + extends Product2[Pid, (Vid, T)] with Serializable { override def _1 = partition @@ -29,7 +29,7 @@ class VertexBroadcastMsg[@specialized(Int, Long, Double, Boolean) T]( class MessageToPartition[@specialized(Int, Long, Double, Char, Boolean/*, AnyRef*/) T]( @transient var partition: Pid, var data: T) - extends Product2[Pid, T] { + extends Product2[Pid, T] with Serializable { override def _1 = partition diff --git a/graph/src/main/scala/org/apache/spark/graph/impl/ReplicatedVertexView.scala b/graph/src/main/scala/org/apache/spark/graph/impl/ReplicatedVertexView.scala index 033971c1af..970acfed27 100644 --- a/graph/src/main/scala/org/apache/spark/graph/impl/ReplicatedVertexView.scala +++ b/graph/src/main/scala/org/apache/spark/graph/impl/ReplicatedVertexView.scala @@ -175,6 +175,7 @@ object ReplicatedVertexView { } } -class VertexAttributeBlock[VD: ClassTag](val vids: Array[Vid], val attrs: Array[VD]) { +class VertexAttributeBlock[VD: ClassTag](val vids: Array[Vid], val attrs: Array[VD]) + extends Serializable { def iterator: Iterator[(Vid, VD)] = (0 until vids.size).iterator.map { i => (vids(i), attrs(i)) } } |