任何人都可以帮助我解决与此等效的 Java 问题吗?
wordCountRDD.saveAsNewAPIHadoopFile(outputFile,classOf[Text],classOf[IntWritable],classOf[TextOutputFormat[Text,IntWritable]])
我在下面尝试过:但它在 TextOutputFormat<>(Text,IntWritable) 给我错误..
wordCountRDD.saveAsNewAPIHadoopFile( output,. Text.class, IntWritable.class, TextOutputFormat<>(Text,IntWritable) context.hadoopConfiguration());
繁花如伊
相关分类