Also add getConf to NewHadoopRDD

2013-08-30 11:03:57 -07:00 · 2013-08-30 11:03:57 -07:00 · 35090958b3
parent 5e30172f70
commit 35090958b3
1 changed files with 3 additions and 0 deletions
--- 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
 }
+