diff options
| author | Mikhail Bautin <mbautin@gmail.com> | 2013-08-30 11:03:57 -0700 |
|---|---|---|
| committer | Mikhail Bautin <mbautin@gmail.com> | 2013-08-30 11:03:57 -0700 |
| commit | 35090958b3df8ba06360be6a48489b33b22216e7 (patch) | |
| tree | fbccd9d62f84b1bbfcb7ea3b137734b005280ad8 /core | |
| parent | 5e30172f706090ccf49ecdac7983cb4b1c091417 (diff) | |
| download | spark-35090958b3df8ba06360be6a48489b33b22216e7.tar.gz spark-35090958b3df8ba06360be6a48489b33b22216e7.tar.bz2 spark-35090958b3df8ba06360be6a48489b33b22216e7.zip | |
Also add getConf to NewHadoopRDD
Diffstat (limited to 'core')
| -rw-r--r-- | core/src/main/scala/spark/rdd/NewHadoopRDD.scala | 3 |
1 files changed, 3 insertions, 0 deletions
diff --git a/core/src/main/scala/spark/rdd/NewHadoopRDD.scala b/core/src/main/scala/spark/rdd/NewHadoopRDD.scala index 184685528e..b1877dc06e 100644 --- a/core/src/main/scala/spark/rdd/NewHadoopRDD.scala +++ b/core/src/main/scala/spark/rdd/NewHadoopRDD.scala @@ -120,4 +120,7 @@ class NewHadoopRDD[K, V]( val theSplit = split.asInstanceOf[NewHadoopPartition] theSplit.serializableHadoopSplit.value.getLocations.filter(_ != "localhost") } + + def getConf: Configuration = confBroadcast.value.value } + |