diff options
| author | zsxwing <zsxwing@gmail.com> | 2014-12-22 11:13:40 -0800 |
|---|---|---|
| committer | Reynold Xin <rxin@databricks.com> | 2014-12-22 11:13:40 -0800 |
| commit | b896963728154ec51689fd3e975fc5033eb24d8c (patch) | |
| tree | 05966e4252fd5108e90ac09a4d2bb037d15c19ba /core | |
| parent | 665653d240c0563f23ad6922b217ff6f0d548874 (diff) | |
| download | spark-b896963728154ec51689fd3e975fc5033eb24d8c.tar.gz spark-b896963728154ec51689fd3e975fc5033eb24d8c.tar.bz2 spark-b896963728154ec51689fd3e975fc5033eb24d8c.zip | |
[SPARK-2075][Core] backport for branch-1.2
backport #3740 for branch-1.2
Author: zsxwing <zsxwing@gmail.com>
Closes #3758 from zsxwing/SPARK-2075-branch-1.2 and squashes the following commits:
b57d440 [zsxwing] SPARK-2075 backport for branch-1.2
Diffstat (limited to 'core')
| -rw-r--r-- | core/src/main/scala/org/apache/spark/rdd/RDD.scala | 4 |
1 files changed, 2 insertions, 2 deletions
diff --git a/core/src/main/scala/org/apache/spark/rdd/RDD.scala b/core/src/main/scala/org/apache/spark/rdd/RDD.scala index 8f4db148ea..ff6d9465b4 100644 --- a/core/src/main/scala/org/apache/spark/rdd/RDD.scala +++ b/core/src/main/scala/org/apache/spark/rdd/RDD.scala @@ -1173,7 +1173,7 @@ abstract class RDD[T: ClassTag]( val nullWritableClassTag = implicitly[ClassTag[NullWritable]] val textClassTag = implicitly[ClassTag[Text]] val r = this.map(x => (NullWritable.get(), new Text(x.toString))) - RDD.rddToPairRDDFunctions(r)(nullWritableClassTag, textClassTag, null) + rddToPairRDDFunctions(r)(nullWritableClassTag, textClassTag, null) .saveAsHadoopFile[TextOutputFormat[NullWritable, Text]](path) } @@ -1185,7 +1185,7 @@ abstract class RDD[T: ClassTag]( val nullWritableClassTag = implicitly[ClassTag[NullWritable]] val textClassTag = implicitly[ClassTag[Text]] val r = this.map(x => (NullWritable.get(), new Text(x.toString))) - RDD.rddToPairRDDFunctions(r)(nullWritableClassTag, textClassTag, null) + rddToPairRDDFunctions(r)(nullWritableClassTag, textClassTag, null) .saveAsHadoopFile[TextOutputFormat[NullWritable, Text]](path, codec) } |