时间戳

首页 > 解决方案 > scala classOf[] 的 java 等价物

java - scala classOf[] 的 java 等价物

问题描述

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

标签： javascalaapache-spark

解决方案

这里：

TextOutputFormat<>(Text,IntWritable)

您必须改为通过课程：

TextOutputFormat.class

但请注意：java 类型系统不允许您表达类似的东西。TextOutputFormat<Text,IntWritable>.class！请参阅此处了解为什么会这样。

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

推荐阅读