任何人都可以帮助我解决与此等效的 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());
1 回答
繁花如伊
TA贡献2012条经验 获得超12个赞
这里:
TextOutputFormat<>(Text,IntWritable)
您必须改为通过该课程:
TextOutputFormat.class
但请注意:Java 类型系统不允许您表达类似的东西。TextOutputFormat<Text,IntWritable>.class
!看到这里为什么会这样。
从这个角度来看,TextOutputFormat.class 似乎是您唯一的选择。
添加回答
举报
0/150
提交
取消