diff options
Diffstat (limited to 'bagel')
| -rw-r--r-- | bagel/src/main/scala/org/apache/spark/bagel/Bagel.scala | 3 |
1 files changed, 2 insertions, 1 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 281216612f..dd3eed8aff 100644 --- a/bagel/src/main/scala/org/apache/spark/bagel/Bagel.scala +++ b/bagel/src/main/scala/org/apache/spark/bagel/Bagel.scala @@ -33,7 +33,8 @@ object Bagel extends Logging { * @param messages initial set of messages represented as an RDD of (Key, Message) pairs. Often * this will be an empty array, i.e. sc.parallelize(Array[K, Message]()). * @param combiner [[org.apache.spark.bagel.Combiner]] combines multiple individual messages to a - * given vertex into one message before sending (which often involves network I/O). + * given vertex into one message before sending (which often involves network + * I/O). * @param aggregator [[org.apache.spark.bagel.Aggregator]] performs a reduce across all vertices * after each superstep and provides the result to each vertex in the next * superstep. |