diff options
| author | Nick Pentreath <nick.pentreath@gmail.com> | 2013-03-11 09:14:00 +0200 |
|---|---|---|
| committer | Nick Pentreath <nick.pentreath@gmail.com> | 2013-03-11 09:14:00 +0200 |
| commit | 8dd943fc3e8adfc638a3ed4ffbd19076e19adfe5 (patch) | |
| tree | f5296c1c22b11ec9acef9ee8789441cfc95e8a03 /bagel | |
| parent | d35c5a5176601b4c8e12d022cc72e42d6986c0a4 (diff) | |
| download | spark-8dd943fc3e8adfc638a3ed4ffbd19076e19adfe5.tar.gz spark-8dd943fc3e8adfc638a3ed4ffbd19076e19adfe5.tar.bz2 spark-8dd943fc3e8adfc638a3ed4ffbd19076e19adfe5.zip | |
Fix doc style
Diffstat (limited to 'bagel')
| -rw-r--r-- | bagel/src/main/scala/spark/bagel/Bagel.scala | 20 |
1 files changed, 13 insertions, 7 deletions
diff --git a/bagel/src/main/scala/spark/bagel/Bagel.scala b/bagel/src/main/scala/spark/bagel/Bagel.scala index 013388cbdf..e10c03f6ba 100644 --- a/bagel/src/main/scala/spark/bagel/Bagel.scala +++ b/bagel/src/main/scala/spark/bagel/Bagel.scala @@ -34,7 +34,7 @@ object Bagel extends Logging { * @tparam M message type * @tparam C combiner * @tparam A aggregator - * @return a set of (K, V) pairs representing the graph after completion of the program + * @return an RDD of (K, V) pairs representing the graph after completion of the program */ def run[K: Manifest, V <: Vertex : Manifest, M <: Message[K] : Manifest, C: Manifest, A: Manifest]( @@ -110,8 +110,10 @@ object Bagel extends Logging { addAggregatorArg[K, V, M, C](compute)) } - /** Runs a Bagel program with no [[spark.bagel.Aggregator]], default [[spark.HashPartitioner]] - * and default storage level*/ + /** + * Runs a Bagel program with no [[spark.bagel.Aggregator]], default [[spark.HashPartitioner]] + * and default storage level + */ def run[K: Manifest, V <: Vertex : Manifest, M <: Message[K] : Manifest, C: Manifest]( sc: SparkContext, vertices: RDD[(K, V)], @@ -139,8 +141,10 @@ object Bagel extends Logging { addAggregatorArg[K, V, M, C](compute)) } - /** Runs a Bagel program with no [[spark.bagel.Aggregator]], default [[spark.HashPartitioner]], - * [[spark.bagel.DefaultCombiner]] and the default storage level */ + /** + * Runs a Bagel program with no [[spark.bagel.Aggregator]], default [[spark.HashPartitioner]], + * [[spark.bagel.DefaultCombiner]] and the default storage level + */ def run[K: Manifest, V <: Vertex : Manifest, M <: Message[K] : Manifest]( sc: SparkContext, vertices: RDD[(K, V)], @@ -150,8 +154,10 @@ object Bagel extends Logging { compute: (V, Option[Array[M]], Int) => (V, Array[M]) ): RDD[(K, V)] = run(sc, vertices, messages, numPartitions, DEFAULT_STORAGE_LEVEL)(compute) - /** Runs a Bagel program with no [[spark.bagel.Aggregator]], the default [[spark.HashPartitioner]] - * and [[spark.bagel.DefaultCombiner]]*/ + /** + * Runs a Bagel program with no [[spark.bagel.Aggregator]], the default [[spark.HashPartitioner]] + * and [[spark.bagel.DefaultCombiner]] + */ def run[K: Manifest, V <: Vertex : Manifest, M <: Message[K] : Manifest]( sc: SparkContext, vertices: RDD[(K, V)], |