diff options
author | Sean Owen <sowen@cloudera.com> | 2015-09-13 08:36:46 +0100 |
---|---|---|
committer | Sean Owen <sowen@cloudera.com> | 2015-09-13 08:36:46 +0100 |
commit | 1dc614b874badde0eee60def46fb47f608bc4759 (patch) | |
tree | 0b3b0e1206af1f84fe19666b53ab6a4ab4272de9 /bagel/src | |
parent | b3a7480ab0821ab38f710de96e3ac4a13f62dbca (diff) | |
download | spark-1dc614b874badde0eee60def46fb47f608bc4759.tar.gz spark-1dc614b874badde0eee60def46fb47f608bc4759.tar.bz2 spark-1dc614b874badde0eee60def46fb47f608bc4759.zip |
[SPARK-10222] [GRAPHX] [DOCS] More thoroughly deprecate Bagel in favor of GraphX
Finish deprecating Bagel; remove reference to nonexistent example
Author: Sean Owen <sowen@cloudera.com>
Closes #8731 from srowen/SPARK-10222.
Diffstat (limited to 'bagel/src')
-rw-r--r-- | bagel/src/main/scala/org/apache/spark/bagel/Bagel.scala | 6 |
1 files changed, 6 insertions, 0 deletions
diff --git a/bagel/src/main/scala/org/apache/spark/bagel/Bagel.scala b/bagel/src/main/scala/org/apache/spark/bagel/Bagel.scala index 4e6b7686f7..8399033ac6 100644 --- a/bagel/src/main/scala/org/apache/spark/bagel/Bagel.scala +++ b/bagel/src/main/scala/org/apache/spark/bagel/Bagel.scala @@ -22,6 +22,7 @@ import org.apache.spark.SparkContext._ import org.apache.spark.rdd.RDD import org.apache.spark.storage.StorageLevel +@deprecated("Uses of Bagel should migrate to GraphX", "1.6.0") object Bagel extends Logging { val DEFAULT_STORAGE_LEVEL = StorageLevel.MEMORY_AND_DISK @@ -270,18 +271,21 @@ object Bagel extends Logging { } } +@deprecated("Uses of Bagel should migrate to GraphX", "1.6.0") trait Combiner[M, C] { def createCombiner(msg: M): C def mergeMsg(combiner: C, msg: M): C def mergeCombiners(a: C, b: C): C } +@deprecated("Uses of Bagel should migrate to GraphX", "1.6.0") trait Aggregator[V, A] { def createAggregator(vert: V): A def mergeAggregators(a: A, b: A): A } /** Default combiner that simply appends messages together (i.e. performs no aggregation) */ +@deprecated("Uses of Bagel should migrate to GraphX", "1.6.0") class DefaultCombiner[M: Manifest] extends Combiner[M, Array[M]] with Serializable { def createCombiner(msg: M): Array[M] = Array(msg) @@ -297,6 +301,7 @@ class DefaultCombiner[M: Manifest] extends Combiner[M, Array[M]] with Serializab * Subclasses may store state along with each vertex and must * inherit from java.io.Serializable or scala.Serializable. */ +@deprecated("Uses of Bagel should migrate to GraphX", "1.6.0") trait Vertex { def active: Boolean } @@ -307,6 +312,7 @@ trait Vertex { * Subclasses may contain a payload to deliver to the target vertex * and must inherit from java.io.Serializable or scala.Serializable. */ +@deprecated("Uses of Bagel should migrate to GraphX", "1.6.0") trait Message[K] { def targetId: K } |