From 35090958b3df8ba06360be6a48489b33b22216e7 Mon Sep 17 00:00:00 2001 From: Mikhail Bautin Date: Fri, 30 Aug 2013 11:03:57 -0700 Subject: Also add getConf to NewHadoopRDD --- core/src/main/scala/spark/rdd/NewHadoopRDD.scala | 3 +++ 1 file changed, 3 insertions(+) (limited to 'core') 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 } + -- cgit v1.2.3