From 969644df8eec13f4b89597a0682c8037949d855b Mon Sep 17 00:00:00 2001 From: Matei Zaharia Date: Thu, 14 Jul 2011 12:40:56 -0400 Subject: Cleaned up a few issues to do with default parallelism levels. Also renamed HadoopFileWriter to HadoopWriter (since it's not only for files) and fixed a bug for lookup(). --- bagel/src/main/scala/spark/bagel/Bagel.scala | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) (limited to 'bagel/src') diff --git a/bagel/src/main/scala/spark/bagel/Bagel.scala b/bagel/src/main/scala/spark/bagel/Bagel.scala index 08ff1d8a01..92d4132e68 100644 --- a/bagel/src/main/scala/spark/bagel/Bagel.scala +++ b/bagel/src/main/scala/spark/bagel/Bagel.scala @@ -14,7 +14,7 @@ object Bagel extends Logging { combiner: Combiner[M, C] = new DefaultCombiner[M], aggregator: Aggregator[V, A] = new NullAggregator[V], superstep: Int = 0, - numSplits: Int = sc.numCores + numSplits: Int = sc.defaultParallelism )( compute: (V, Option[C], A, Int) => (V, Iterable[M]) ): RDD[V] = { -- cgit v1.2.3