File tree Expand file tree Collapse file tree 1 file changed +2
-2
lines changed
core/src/main/scala/org/apache/spark/rdd Expand file tree Collapse file tree 1 file changed +2
-2
lines changed Original file line number Diff line number Diff line change @@ -1173,7 +1173,7 @@ abstract class RDD[T: ClassTag](
11731173 val nullWritableClassTag = implicitly[ClassTag [NullWritable ]]
11741174 val textClassTag = implicitly[ClassTag [Text ]]
11751175 val r = this .map(x => (NullWritable .get(), new Text (x.toString)))
1176- RDD . rddToPairRDDFunctions(r)(nullWritableClassTag, textClassTag, null )
1176+ rddToPairRDDFunctions(r)(nullWritableClassTag, textClassTag, null )
11771177 .saveAsHadoopFile[TextOutputFormat [NullWritable , Text ]](path)
11781178 }
11791179
@@ -1185,7 +1185,7 @@ abstract class RDD[T: ClassTag](
11851185 val nullWritableClassTag = implicitly[ClassTag [NullWritable ]]
11861186 val textClassTag = implicitly[ClassTag [Text ]]
11871187 val r = this .map(x => (NullWritable .get(), new Text (x.toString)))
1188- RDD . rddToPairRDDFunctions(r)(nullWritableClassTag, textClassTag, null )
1188+ rddToPairRDDFunctions(r)(nullWritableClassTag, textClassTag, null )
11891189 .saveAsHadoopFile[TextOutputFormat [NullWritable , Text ]](path, codec)
11901190 }
11911191
You can’t perform that action at this time.
0 commit comments