File tree Expand file tree Collapse file tree 1 file changed +2
-2
lines changed
core/src/main/scala/org/apache/spark/api/python Expand file tree Collapse file tree 1 file changed +2
-2
lines changed Original file line number Diff line number Diff line change @@ -663,13 +663,13 @@ private[spark] object PythonRDD extends Logging {
663
663
*/
664
664
def saveAsHadoopDataset [K , V ](
665
665
pyRDD : JavaRDD [Array [Byte ]],
666
- batchSerialzied : Boolean ,
666
+ batchSerialized : Boolean ,
667
667
confAsMap : java.util.HashMap [String , String ],
668
668
useNewAPI : Boolean ,
669
669
keyConverterClass : String ,
670
670
valueConverterClass : String ) = {
671
671
val conf = PythonHadoopUtil .mapToConf(confAsMap)
672
- val converted = convertRDD(SerDeUtil .pythonToPairRDD(pyRDD, batchSerialzied ),
672
+ val converted = convertRDD(SerDeUtil .pythonToPairRDD(pyRDD, batchSerialized ),
673
673
keyConverterClass, valueConverterClass, new JavaToWritableConverter )
674
674
if (useNewAPI) {
675
675
converted.saveAsNewAPIHadoopDataset(conf)
You can’t perform that action at this time.
0 commit comments