0
我使用KeyValueTextInputFormat用于读取/处理逗号分隔的文件:KeyValueTextInputFormat逗号分隔符
100,56
123,68
但是我得到了所有关键的价值,即使在将分隔符设置为逗号(,)后,值字段也会为空。它不挑选分隔符,不知道是什么问题,这里是我的驱动程序代码:
Configuration conf = new Configuration();
conf.set("key.value.separator.in.input.line", ",");
Job job = new Job(conf, "citation data");
job.setJarByClass(Citation.class);
job.setJobName("citation data");
job.setMapperClass(MapClass.class);
job.setReducerClass(ReduceClass.class);
job.setInputFormatClass(KeyValueTextInputFormat.class);
job.setOutputKeyClass(Text.class);
job.setOutputValueClass(Text.class);
KeyValueTextInputFormat.addInputPath(job, new Path("input/sample.txt"));
FileOutputFormat.setOutputPath(job, new Path("output2"));
System.exit(job.waitForCompletion(true)?0:1);
的可能重复[如何指定KeyValueTextInputFormat分离器在Hadoop的0.20 API?](http://stackoverflow.com/questions/9211151/how-to-specified-keyvaluetextinputformat-separator-in-hadoop-20-api) – 2013-02-21 01:07:03
@ChrisGerken - 不重复,这里的问题是值字段将作为null – CassandraCurious 2013-02-21 01:11:12