如何在Eclipse IDE中使用Java代码读取Hadoop中的CSV文件格式?
我有一个非常大的CSV格式文件,并且我想访问HDFS中的CSV文件以便执行地图缩小程序。希望有人能帮助我解决问题。
我希望Java代码访问该文件。
提前致谢。
您可以将文件作为输入传递给映射器。文件的行将成为映射器的值。
class FileMapper extends Mapper<LongWritable, Text> {
@Override
public void map(LongWritable key, Text value, Context context) {
// process your CSV records here.
}
}
本文收集自互联网,转载请注明来源。
如有侵权,请联系 [email protected] 删除。
我来说两句