How to specify KeyValueTextInputFormat Separator in Hadoop- 20 api

Question

I'm using apache.hadoop.mapreduce.KeyValueTextInputFormat API, I want to specify separator (delimiter) other than tab(which is default) to separate key and Value. 

Sample Input :

one,first line
two,second line

Ouput Required :

Key : one
Value : first line
Key : two
Value : second line

I am specifying KeyValueTextInputFormat as :

    Job job = new Job(conf, "Sample");

    job.setInputFormatClass(KeyValueTextInputFormat.class);
    KeyValueTextInputFormat.addInputPath(job, new Path("/home/input.txt"));

Answer 1

In this API you should use mapreduce.input.keyvaluelinerecordreader.key.value.separatorconfiguration property.

For example:

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

Answer 2

Use this setting in the Driver Code.

conf.set("key.value.separator.in.input.line", ",");

Answer 3

conf.set("key.value.separator.in.input.line", ","); 
Job job = new Job(conf);