diff options
author | Stephen Haberman <stephen@exigencecorp.com> | 2013-03-14 14:57:12 -0500 |
---|---|---|
committer | Stephen Haberman <stephen@exigencecorp.com> | 2013-03-14 14:57:12 -0500 |
commit | 7786881f47699d8e463d911468ed9d43079948a8 (patch) | |
tree | d203c84c9da622a62fc8d1d7d08ab2db74553489 /core/src | |
parent | 7d8bb4df3a5f8078cd4e86cef5e3b0b728afd2bc (diff) | |
download | spark-7786881f47699d8e463d911468ed9d43079948a8.tar.gz spark-7786881f47699d8e463d911468ed9d43079948a8.tar.bz2 spark-7786881f47699d8e463d911468ed9d43079948a8.zip |
Fix tabs that snuck in.
Diffstat (limited to 'core/src')
-rw-r--r-- | core/src/main/scala/spark/rdd/SubtractedRDD.scala | 16 |
1 files changed, 8 insertions, 8 deletions
diff --git a/core/src/main/scala/spark/rdd/SubtractedRDD.scala b/core/src/main/scala/spark/rdd/SubtractedRDD.scala index 2f8ff9bb34..0a02561062 100644 --- a/core/src/main/scala/spark/rdd/SubtractedRDD.scala +++ b/core/src/main/scala/spark/rdd/SubtractedRDD.scala @@ -35,13 +35,13 @@ private[spark] class SubtractedRDD[K: ClassManifest, V: ClassManifest, W: ClassM override def getDependencies: Seq[Dependency[_]] = { Seq(rdd1, rdd2).map { rdd => - if (rdd.partitioner == Some(part)) { - logInfo("Adding one-to-one dependency with " + rdd) - new OneToOneDependency(rdd) - } else { - logInfo("Adding shuffle dependency with " + rdd) - new ShuffleDependency(rdd.asInstanceOf[RDD[(K, Any)]], part) - } + if (rdd.partitioner == Some(part)) { + logInfo("Adding one-to-one dependency with " + rdd) + new OneToOneDependency(rdd) + } else { + logInfo("Adding shuffle dependency with " + rdd) + new ShuffleDependency(rdd.asInstanceOf[RDD[(K, Any)]], part) + } } } @@ -97,4 +97,4 @@ private[spark] class SubtractedRDD[K: ClassManifest, V: ClassManifest, W: ClassM rdd2 = null } -}
\ No newline at end of file +} |