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](
1173
1173
val nullWritableClassTag = implicitly[ClassTag [NullWritable ]]
1174
1174
val textClassTag = implicitly[ClassTag [Text ]]
1175
1175
val r = this .map(x => (NullWritable .get(), new Text (x.toString)))
1176
- RDD . rddToPairRDDFunctions(r)(nullWritableClassTag, textClassTag, null )
1176
+ rddToPairRDDFunctions(r)(nullWritableClassTag, textClassTag, null )
1177
1177
.saveAsHadoopFile[TextOutputFormat [NullWritable , Text ]](path)
1178
1178
}
1179
1179
@@ -1185,7 +1185,7 @@ abstract class RDD[T: ClassTag](
1185
1185
val nullWritableClassTag = implicitly[ClassTag [NullWritable ]]
1186
1186
val textClassTag = implicitly[ClassTag [Text ]]
1187
1187
val r = this .map(x => (NullWritable .get(), new Text (x.toString)))
1188
- RDD . rddToPairRDDFunctions(r)(nullWritableClassTag, textClassTag, null )
1188
+ rddToPairRDDFunctions(r)(nullWritableClassTag, textClassTag, null )
1189
1189
.saveAsHadoopFile[TextOutputFormat [NullWritable , Text ]](path, codec)
1190
1190
}
1191
1191
You can’t perform that action at this time.
0 commit comments