java等效于scala classOf [] [关闭]

Question

任何人都可以帮助我处理 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());

Answer 1

这里：

TextOutputFormat<>(Text,IntWritable)

您必须改为传递 class：

TextOutputFormat.class

但请注意：java 类型系统不允许您表达类似的东西。 TextOutputFormat<Text,IntWritable>.class！请参阅here 了解原因。

从这个角度来看，TextOutputFormat.class 似乎是您唯一的选择。