diff options
author | Patrick Wendell <pwendell@gmail.com> | 2014-01-13 20:45:22 -0800 |
---|---|---|
committer | Patrick Wendell <pwendell@gmail.com> | 2014-01-13 20:45:22 -0800 |
commit | b07bc02a00881822d2cb350f20dca31ddbeed54b (patch) | |
tree | 5a521fadc61b9de2bb8aa64a0440f32c7d2992f5 | |
parent | a2fee38ee054c7dd6ff5f5d72f036fef54194d53 (diff) | |
parent | 9e84e705090daad500838d5b00073cd06a5c621b (diff) | |
download | spark-b07bc02a00881822d2cb350f20dca31ddbeed54b.tar.gz spark-b07bc02a00881822d2cb350f20dca31ddbeed54b.tar.bz2 spark-b07bc02a00881822d2cb350f20dca31ddbeed54b.zip |
Merge pull request #412 from harveyfeng/master
Add default value for HadoopRDD's `cloneRecords` constructor arg
Small mend to https://github.com/apache/incubator-spark/pull/359/files#diff-1 for backwards compatibility
-rw-r--r-- | core/src/main/scala/org/apache/spark/rdd/HadoopRDD.scala | 2 |
1 files changed, 1 insertions, 1 deletions
diff --git a/core/src/main/scala/org/apache/spark/rdd/HadoopRDD.scala b/core/src/main/scala/org/apache/spark/rdd/HadoopRDD.scala index 5cdb80be1d..dbe76f3431 100644 --- a/core/src/main/scala/org/apache/spark/rdd/HadoopRDD.scala +++ b/core/src/main/scala/org/apache/spark/rdd/HadoopRDD.scala @@ -78,7 +78,7 @@ class HadoopRDD[K: ClassTag, V: ClassTag]( keyClass: Class[K], valueClass: Class[V], minSplits: Int, - cloneRecords: Boolean) + cloneRecords: Boolean = true) extends RDD[(K, V)](sc, Nil) with Logging { def this( |