diff options
| author | Joseph E. Gonzalez <joseph.e.gonzalez@gmail.com> | 2014-01-13 17:15:21 -0800 |
|---|---|---|
| committer | Joseph E. Gonzalez <joseph.e.gonzalez@gmail.com> | 2014-01-13 17:18:31 -0800 |
| commit | cfe4a29dcb516ceae5f243ac3b5d0c3a505d7f5a (patch) | |
| tree | 2ec2c1b4a67548048775c6b98df43e55dda92f32 /graphx | |
| parent | ae4b75d94a4a0f2545e6d90d6f9b8f162bf70ded (diff) | |
| download | spark-cfe4a29dcb516ceae5f243ac3b5d0c3a505d7f5a.tar.gz spark-cfe4a29dcb516ceae5f243ac3b5d0c3a505d7f5a.tar.bz2 spark-cfe4a29dcb516ceae5f243ac3b5d0c3a505d7f5a.zip | |
Improvements in example code for the programming guide as well as adding serialization support for GraphImpl to address issues with failed closure capture.
Diffstat (limited to 'graphx')
| -rw-r--r-- | graphx/src/main/scala/org/apache/spark/graphx/impl/GraphImpl.scala | 3 |
1 files changed, 3 insertions, 0 deletions
diff --git a/graphx/src/main/scala/org/apache/spark/graphx/impl/GraphImpl.scala b/graphx/src/main/scala/org/apache/spark/graphx/impl/GraphImpl.scala index c21f8935d9..916eb9763c 100644 --- a/graphx/src/main/scala/org/apache/spark/graphx/impl/GraphImpl.scala +++ b/graphx/src/main/scala/org/apache/spark/graphx/impl/GraphImpl.scala @@ -32,6 +32,9 @@ class GraphImpl[VD: ClassTag, ED: ClassTag] protected ( @transient val replicatedVertexView: ReplicatedVertexView[VD]) extends Graph[VD, ED] with Serializable { + /** Default construct is provided to support serialization */ + protected def this() = this(null, null, null, null) + /** Return a RDD that brings edges together with their source and destination vertices. */ @transient override val triplets: RDD[EdgeTriplet[VD, ED]] = { val vdTag = classTag[VD] |