diff options
| author | Mikhail Bautin <mbautin@gmail.com> | 2013-08-14 11:51:00 -0700 |
|---|---|---|
| committer | Mikhail Bautin <mbautin@gmail.com> | 2013-08-30 11:01:06 -0700 |
| commit | 5e30172f706090ccf49ecdac7983cb4b1c091417 (patch) | |
| tree | f5354aeac2572c21c3a4e28694a7970c1525186e /core | |
| parent | 9e17e456d2f39bb48200d634315525c7e2458d7e (diff) | |
| download | spark-5e30172f706090ccf49ecdac7983cb4b1c091417.tar.gz spark-5e30172f706090ccf49ecdac7983cb4b1c091417.tar.bz2 spark-5e30172f706090ccf49ecdac7983cb4b1c091417.zip | |
Make HadoopRDD's configuration accessible
Diffstat (limited to 'core')
| -rw-r--r-- | core/src/main/scala/spark/rdd/HadoopRDD.scala | 4 |
1 files changed, 3 insertions, 1 deletions
diff --git a/core/src/main/scala/spark/rdd/HadoopRDD.scala b/core/src/main/scala/spark/rdd/HadoopRDD.scala index 6c41b97780..e512423fd6 100644 --- a/core/src/main/scala/spark/rdd/HadoopRDD.scala +++ b/core/src/main/scala/spark/rdd/HadoopRDD.scala @@ -34,7 +34,7 @@ import org.apache.hadoop.util.ReflectionUtils import spark.{Dependency, Logging, Partition, RDD, SerializableWritable, SparkContext, SparkEnv, TaskContext} import spark.util.NextIterator -import org.apache.hadoop.conf.Configurable +import org.apache.hadoop.conf.{Configuration, Configurable} /** @@ -132,4 +132,6 @@ class HadoopRDD[K, V]( override def checkpoint() { // Do nothing. Hadoop RDD should not be checkpointed. } + + def getConf: Configuration = confBroadcast.value.value } |