diff options
| author | harshars <harshars@bigcuttall-lm.corp.yahoo.com> | 2013-07-26 15:16:41 -0700 |
|---|---|---|
| committer | harshars <harshars@bigcuttall-lm.corp.yahoo.com> | 2013-07-26 15:16:41 -0700 |
| commit | 72cf7ec0e5736d8cc5a691b36c78a79c9a4bf118 (patch) | |
| tree | 121b55a4c8dd53fc9a20c9cd8276c21f0734d72c | |
| parent | 822aac8f5afd1342bb1cbadd7a2c2821bda81988 (diff) | |
| download | spark-72cf7ec0e5736d8cc5a691b36c78a79c9a4bf118.tar.gz spark-72cf7ec0e5736d8cc5a691b36c78a79c9a4bf118.tar.bz2 spark-72cf7ec0e5736d8cc5a691b36c78a79c9a4bf118.zip | |
Indentation
| -rw-r--r-- | core/src/main/scala/spark/rdd/PartitionPruningRDD.scala | 6 |
1 files changed, 3 insertions, 3 deletions
diff --git a/core/src/main/scala/spark/rdd/PartitionPruningRDD.scala b/core/src/main/scala/spark/rdd/PartitionPruningRDD.scala index 04e22574af..eaac134ef4 100644 --- a/core/src/main/scala/spark/rdd/PartitionPruningRDD.scala +++ b/core/src/main/scala/spark/rdd/PartitionPruningRDD.scala @@ -16,9 +16,9 @@ class PruneDependency[T](rdd: RDD[T], @transient partitionFilterFunc: Int => Boo extends NarrowDependency[T](rdd) { @transient - val partitions: Array[Partition] = rdd.partitions. - zipWithIndex.filter(s => partitionFilterFunc(s._2)). - map { case(split, idx) => new PartitionPruningRDDPartition(idx, split) : Partition } + val partitions: Array[Partition] = rdd.partitions.zipWithIndex + .filter(s => partitionFilterFunc(s._2)) + .map { case(split, idx) => new PartitionPruningRDDPartition(idx, split) : Partition } override def getParents(partitionId: Int) = List(partitions(partitionId).index) } |