diff options
| author | Tathagata Das <tathagata.das1565@gmail.com> | 2013-12-31 02:01:45 -0800 |
|---|---|---|
| committer | Tathagata Das <tathagata.das1565@gmail.com> | 2013-12-31 02:01:45 -0800 |
| commit | fcd17a1e8ef1d0f106e845f4de99533d61cd8695 (patch) | |
| tree | 9826f029321e93f3286c4420dd290b053c1308ee /core | |
| parent | 271e3237f3e2efa62a94d6936fce551a40edd65f (diff) | |
| download | spark-fcd17a1e8ef1d0f106e845f4de99533d61cd8695.tar.gz spark-fcd17a1e8ef1d0f106e845f4de99533d61cd8695.tar.bz2 spark-fcd17a1e8ef1d0f106e845f4de99533d61cd8695.zip | |
Fixed comments and long lines based on comments on PR 289.
Diffstat (limited to 'core')
| -rw-r--r-- | core/src/main/scala/org/apache/spark/rdd/RDDCheckpointData.scala | 3 |
1 files changed, 2 insertions, 1 deletions
diff --git a/core/src/main/scala/org/apache/spark/rdd/RDDCheckpointData.scala b/core/src/main/scala/org/apache/spark/rdd/RDDCheckpointData.scala index 091a6fdb54..642dabaad5 100644 --- a/core/src/main/scala/org/apache/spark/rdd/RDDCheckpointData.scala +++ b/core/src/main/scala/org/apache/spark/rdd/RDDCheckpointData.scala @@ -91,7 +91,8 @@ private[spark] class RDDCheckpointData[T: ClassTag](rdd: RDD[T]) } // Save to file, and reload it as an RDD - val broadcastedConf = rdd.context.broadcast(new SerializableWritable(rdd.context.hadoopConfiguration)) + val broadcastedConf = rdd.context.broadcast( + new SerializableWritable(rdd.context.hadoopConfiguration)) rdd.context.runJob(rdd, CheckpointRDD.writeToFile(path.toString, broadcastedConf) _) val newRDD = new CheckpointRDD[T](rdd.context, path.toString) if (newRDD.partitions.size != rdd.partitions.size) { |