Can any one help me with the Java equivalent of this?
wordCountRDD.saveAsNewAPIHadoopFile(outputFile,classOf[Text],classOf[IntWritable],classOf[TextOutputFormat[Text,IntWritable]])
I tried below : but it give me error at TextOutputFormat<>(Text,IntWritable) ..
wordCountRDD.saveAsNewAPIHadoopFile(
output,
Text.class,
IntWritable.class,
TextOutputFormat<>(Text,IntWritable)
context.hadoopConfiguration());