aboutsummaryrefslogtreecommitdiff
path: root/core/src
diff options
context:
space:
mode:
authorStephen Haberman <stephen@exigencecorp.com>2013-03-14 14:57:12 -0500
committerStephen Haberman <stephen@exigencecorp.com>2013-03-14 14:57:12 -0500
commit7786881f47699d8e463d911468ed9d43079948a8 (patch)
treed203c84c9da622a62fc8d1d7d08ab2db74553489 /core/src
parent7d8bb4df3a5f8078cd4e86cef5e3b0b728afd2bc (diff)
downloadspark-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.scala16
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
+}