
在较新的API中,您应该使用
mapreduce.input.keyvaluelinerecordreader.key.value.separator配置属性。
这是一个例子:
Configuration conf = new Configuration();conf.set("mapreduce.input.keyvaluelinerecordreader.key.value.separator", ",");Job job = new Job(conf);job.setInputFormatClass(KeyValueTextInputFormat.class);// next job set-up欢迎分享,转载请注明来源:内存溢出
微信扫一扫
支付宝扫一扫
评论列表(0条)