diff options
| author | hushan <hushan@xiaomi.com> | 2015-11-19 14:56:00 -0800 |
|---|---|---|
| committer | Andrew Or <andrew@databricks.com> | 2015-11-19 14:56:00 -0800 |
| commit | 01403aa97b6aaab9b86ae806b5ea9e82690a741f (patch) | |
| tree | dbf23dc8e14c83048d9cffd986a1aba828d23138 | |
| parent | f7135ed7194d4f936f6f58e14f02b1ed93f68ad1 (diff) | |
| download | spark-01403aa97b6aaab9b86ae806b5ea9e82690a741f.tar.gz spark-01403aa97b6aaab9b86ae806b5ea9e82690a741f.tar.bz2 spark-01403aa97b6aaab9b86ae806b5ea9e82690a741f.zip | |
[SPARK-11746][CORE] Use cache-aware method dependencies
a small change
Author: hushan <hushan@xiaomi.com>
Closes #9691 from suyanNone/unify-getDependency.
| -rw-r--r-- | core/src/main/scala/org/apache/spark/rdd/PartitionPruningRDD.scala | 2 |
1 files changed, 1 insertions, 1 deletions
diff --git a/core/src/main/scala/org/apache/spark/rdd/PartitionPruningRDD.scala b/core/src/main/scala/org/apache/spark/rdd/PartitionPruningRDD.scala index d6a37e8cc5..0c6ddda52c 100644 --- a/core/src/main/scala/org/apache/spark/rdd/PartitionPruningRDD.scala +++ b/core/src/main/scala/org/apache/spark/rdd/PartitionPruningRDD.scala @@ -65,7 +65,7 @@ class PartitionPruningRDD[T: ClassTag]( } override protected def getPartitions: Array[Partition] = - getDependencies.head.asInstanceOf[PruneDependency[T]].partitions + dependencies.head.asInstanceOf[PruneDependency[T]].partitions } |