Declaring separator in the MapReduce Hadoop 0 20

Question

My input is like

One, Microsoft
Two, Google
Three, Facebook

And the output should be in the form of :

Key : One
Value : Microsoft
Key : Two
Value : Google

The am using KeyValueTextInputFormat:

    Job job1 = new Job(conf, "MyJob");
    job1.setInputFormatClass(KeyValueTextInputFormat.class);
    KeyValueTextInputFormat.addInputPath(job1, new Path("/user/abc.txt"));

If the delimiter is tab, this works fine. Can help me with the new API and tell me how to do I specify the separator as ‘,’.

Answer 1

In the new API you have to specify the value of  mapreduce.input.keyvaluelinerecordreader.key.value.separator  property as ‘,’.

conf.set("mapreduce.input.keyvaluelinerecordreader.key.value.separator", ",");