/* package whatever; // don't place package name! */
 
import java.util.*;
import java.lang.*;
import java.io.*;
 
/* Name of the class has to be "Main" only if the class is public. */
class Ideone
{
	public static void main (String[] args) throws java.lang.Exception
	{
		// your code goes here
	}
}

LyogcGFja2FnZSB3aGF0ZXZlcjsgLy8gZG9uJ3QgcGxhY2UgcGFja2FnZSBuYW1lISAqLwoKaW1wb3J0IGphdmEudXRpbC4qOwppbXBvcnQgamF2YS5sYW5nLio7CmltcG9ydCBqYXZhLmlvLio7CgovKiBOYW1lIG9mIHRoZSBjbGFzcyBoYXMgdG8gYmUgIk1haW4iIG9ubHkgaWYgdGhlIGNsYXNzIGlzIHB1YmxpYy4gKi8KY2xhc3MgSWRlb25lCnsKCXB1YmxpYyBzdGF0aWMgdm9pZCBtYWluIChTdHJpbmdbXSBhcmdzKSB0aHJvd3MgamF2YS5sYW5nLkV4Y2VwdGlvbgoJewoJCS8vIHlvdXIgY29kZSBnb2VzIGhlcmUKCX0KfQ==

aW1wb3J0IGphdmEuaW8uSU9FeGNlcHRpb247CmltcG9ydCBqYXZhLnV0aWwuU3RyaW5nVG9rZW5pemVyOwppbXBvcnQgb3JnLmFwcGFjaGUuaGFkb29wLmlvLkludFdyaXRhYmxlOwppbXBvcnQgb3JnLmFwcGFjaGUuaGFkb29wLmlvLkxvbmdXcml0YWJsZTsKaW1wb3J0IG9yZy5hcHBhY2hlLmhhZG9vcC5pby5UZXh0OwppbXBvcnQgb3JnLmFwcGFjaGUuaGFkb29wLm1hcHJlZHVjZS5NYXBwZXI7CmltcG9ydCBvcmcuYXBwYWNoZS5oYWRvb3AubWFwcmVkdWNlLlJlZHVjZXI7CmltcG9ydCBvcmcuYXBwYWNoZS5oYWRvb3AuY29uZi5jb25maWd1cmF0aW9uOwppbXBvcnQgb3JnLmFwcGFjaGUuaGFkb29wLm1hcHJlZHVjZS5Kb2I7CmltcG9ydCBvcmcuYXBwYWNoZS5oYWRvb3AubWFwcmVkdWNlLmxpYi5pbnB1dC5UZXh0SW5wdXRGb3JtYXQ7CmltcG9ydCBvcmcuYXBwYWNoZS5oYWRvb3AubWFwcmVkdWNlLmxpYi5vdXRwdXQuVGV4dE91dHB1dEZvcm1hdDsKaW1wb3J0IG9yZy5hcHBhY2hlLmhhZG9vcC5tYXByZWR1Y2UubGliLmlucHV0LkZpbGVJbnB1dEZvcm1hdDsKaW1wb3J0IG9yZy5hcHBhY2hlLmhhZG9vcC5tYXByZWR1Y2UubGliLm91dHB1dC5GaWxlT3V0cHV0Rm9ybWF0OwppbXBvcnQgb3JnLmFwcGFjaGUuaGFkb29wLmZzLlBhdGg7CnB1YmxpYyBjbGFzcyBXb3JkQ291bnQKewoJcHVibGljIHN0YXRpYyBjbGFzcyBNYXAgZXh0ZW5kcyBNYXBwZXImbHQ7TG9uZyBXcml0YWJsZSxUZXh0LEludFdyaXRhYmxlJmd0Owp7IHB1YmxpYyB2b2lkIG1hcChMb25nV3JpdGFibGUgS2V5LFRleHQgdmFsdWUsQ29udGV4dCBjb250ZXh0KSB0aHJvd3MKSU9FeGNlcHRpb24sSW50ZXJydXB0ZWRFeGNlcHRpb257CnN0cmluZyBsaW5lPXZhbHVlLnRvU3RyaW5nKCk7CnN0cmluZ1Rva2VuaXplciB0b2tlbml6ZXI9bmV3IFN0cmluZ1Rva2VuaXplcihsaW5lKTsKd2hpbGUodG9rZW5pemVyLmhhc01vcmVUb2tlbnMoKSkKe3ZhbHVlLnNldCh0b2tlbml6ZXIubmV4VG9rZW4oKSk7CmNvbnRleC53cml0ZSh2YWx1ZSxuZXcgSW50V3JpdGFibGUoMSkpOwp9Cn0KfQpwdWJsaWMgc3RhdGljIGNsYXNzIFJlZHVjZSBleHRlbmRzIHJlZHVjZXJlciZsdDtUZXh0LEludFdyaXRhYmxlLFRleHQsSW50V3JpdGFibGUmZ3Q7CnsgcHVibGljIHZvaWQgcmVkdWNlKFRleHRLZXksSXRlcmFibGUmbHQ7SW50V3JpdGFibGUmZ3Q7dmFsdWVzLENvbnRleHQgY29udGV4dCkgCnRocm93cyBJT0V4Y2VwdGlvbixJbnRlcnJ1cHRlZEV4Y2VwdGlvbnsKaW50IHN1bT0wOwoKCmZvcihJbnRXcml0YWJsZSB4OnZhbHVlcykKewoJc3VtKz14LmdldCgpOwp9CmNvbnRleHQuV3JpdGUoa2V5LG5ldyBJbnRXcml0YWJsZShzdW0pKTsKfQp9CnB1YmxpYyBzdGF0aWMgdm9pZCBtYWluKFN0cmluZ1tdYXJncyl0aHJvd3MgRXhjZXB0aW9uCntDb25maWd1cmF0aW9uIGNvbmY9bmV3IENvbmZpZ3VyYXRpb24oKTsKSm9iIGpvYj1uZXcgSm9iKGNvbmYsJnF1b3Q7TXkgV29yZCBjb3VudCBwcm9ncmFtJnF1b3Q7KTsKam9iLnNldEphckJ5Q2xhc3MoV29yZENvdW50LmNsYXNzKTsKam9iLnNldE1hcHBlckNsYXNzKE1hcC5jbGFzcyk7CmpvYi5zZXRSZWR1Y2VyQ2xhc3MoUmVkdWNlLmNsYXNzKTsKam9iLnNldE91dHB1dEtleUNsYXNzKFRleHQuY2xhc3MpOwpqb2Iuc2V0T3V0cHV0dmFsdWVDbGFzcyhJbnRXcml0YWJsZS5jbGFzcyk7CmpvYi5zZXRJbnB1dEZvcm1hdENsYXNzKFRleHRJbnB1dEZvcm1hdC5jbGFzcyk7CmpvYi5zZXRPdXRwdXRGb3JtYXRDbGFzcyhUZXh0SW5wdXRGb3JtYXQuY2xhc3MpOwpQYXRoIG91dHB1dFBhdGggPW5ldyBQYXRoKGFyZ3NbMV0pOwovL0NvbmZpZ3VyaW5nIHRoZSBpbnB1dC9vdXRwdXQgcGF0aCBmcm9tIHRoZSBmaWxlc3lzdGVtIGludG8gdGhlIGpvYgpGaWxlSW5wdXRGb3JtYXQuYWRkSW5wdXRQYXRoKGpvYixuZXcgUGF0aChhcmdzWzBdKSk7CkZpbGVPdXRwdXRGb3JtYXQuc2V0b3V0cHV0UGF0aChqb2IsbmV3IFBhdGgoYXJnc1sxXSkpOwovL2RlbGV0aW5nIHRoZSBvdXRwdXQgcGF0aCBhdXRvbWF0aWNhbGx5IGZyb20gaGRmcyBzbyB0aGF0IHdlIGRvbid0IGhhdmUgdG8gZGVsZXRlIGl0IGV4cGxpY2l0eQpvdXRwdXRQYXRoLmdldEZpbGVTeXN0ZW0oQ29uZikuZGVsZXRlKE91dHB1dFBhdGgpOwovL2V4aXRpbmcgdGhlIGpvYiBvbmx5IGlmIHRoZSBmbGFnIHZhbHVlIGJlY29tZXMgZmFsc2UKU3lzdGVtLmV4aXQoam9iLndhaXRGb3JDb21wbGV0aW9uKHRydWUpPzAgOiAxKTsKfQp9CgoKCg==

import java.io.IOException;
import java.util.StringTokenizer;
import org.appache.hadoop.io.IntWritable;
import org.appache.hadoop.io.LongWritable;
import org.appache.hadoop.io.Text;
import org.appache.hadoop.mapreduce.Mapper;
import org.appache.hadoop.mapreduce.Reducer;
import org.appache.hadoop.conf.configuration;
import org.appache.hadoop.mapreduce.Job;
import org.appache.hadoop.mapreduce.lib.input.TextInputFormat;
import org.appache.hadoop.mapreduce.lib.output.TextOutputFormat;
import org.appache.hadoop.mapreduce.lib.input.FileInputFormat;
import org.appache.hadoop.mapreduce.lib.output.FileOutputFormat;
import org.appache.hadoop.fs.Path;
public class WordCount
{
	public static class Map extends Mapper<Long Writable,Text,IntWritable>
{ public void map(LongWritable Key,Text value,Context context) throws
IOException,InterruptedException{
string line=value.toString();
stringTokenizer tokenizer=new StringTokenizer(line);
while(tokenizer.hasMoreTokens())
{value.set(tokenizer.nexToken());
contex.write(value,new IntWritable(1));
}
}
}
public static class Reduce extends reducerer<Text,IntWritable,Text,IntWritable>
{ public void reduce(TextKey,Iterable<IntWritable>values,Context context) 
throws IOException,InterruptedException{
int sum=0;


for(IntWritable x:values)
{
	sum+=x.get();
}
context.Write(key,new IntWritable(sum));
}
}
public static void main(String[]args)throws Exception
{Configuration conf=new Configuration();
Job job=new Job(conf,"My Word count program");
job.setJarByClass(WordCount.class);
job.setMapperClass(Map.class);
job.setReducerClass(Reduce.class);
job.setOutputKeyClass(Text.class);
job.setOutputvalueClass(IntWritable.class);
job.setInputFormatClass(TextInputFormat.class);
job.setOutputFormatClass(TextInputFormat.class);
Path outputPath =new Path(args[1]);
//Configuring the input/output path from the filesystem into the job
FileInputFormat.addInputPath(job,new Path(args[0]));
FileOutputFormat.setoutputPath(job,new Path(args[1]));
//deleting the output path automatically from hdfs so that we don't have to delete it explicity
outputPath.getFileSystem(Conf).delete(OutputPath);
//exiting the job only if the flag value becomes false
System.exit(job.waitForCompletion(true)?0 : 1);
}
}