diff options
| author | Ankur Dave <ankurdave@gmail.com> | 2014-01-09 13:26:17 -0800 |
|---|---|---|
| committer | Ankur Dave <ankurdave@gmail.com> | 2014-01-09 13:26:17 -0800 |
| commit | 4aa9be16333b61139fbe81a079f46ef32df0b1fd (patch) | |
| tree | 12a6856891575f58ccec8022c9647d213a0ae9a3 | |
| parent | b5b0de2de53563c43e1c5844a52b4eeeb2542ea5 (diff) | |
| download | spark-4aa9be16333b61139fbe81a079f46ef32df0b1fd.tar.gz spark-4aa9be16333b61139fbe81a079f46ef32df0b1fd.tar.bz2 spark-4aa9be16333b61139fbe81a079f46ef32df0b1fd.zip | |
Make GraphImpl serializable to work around capture
| -rw-r--r-- | graph/src/main/scala/org/apache/spark/graph/impl/GraphImpl.scala | 2 |
1 files changed, 1 insertions, 1 deletions
diff --git a/graph/src/main/scala/org/apache/spark/graph/impl/GraphImpl.scala b/graph/src/main/scala/org/apache/spark/graph/impl/GraphImpl.scala index 4d35755e7e..2ce5404e94 100644 --- a/graph/src/main/scala/org/apache/spark/graph/impl/GraphImpl.scala +++ b/graph/src/main/scala/org/apache/spark/graph/impl/GraphImpl.scala @@ -30,7 +30,7 @@ class GraphImpl[VD: ClassTag, ED: ClassTag] protected ( @transient val edges: EdgeRDD[ED], @transient val routingTable: RoutingTable, @transient val replicatedVertexView: ReplicatedVertexView[VD]) - extends Graph[VD, ED] { + extends Graph[VD, ED] with Serializable { def this( vertices: VertexRDD[VD], |