Scribd
Upload
6 views3 pages

Java Word Count MapReduce Example

The document contains a Java program for a Hadoop MapReduce application that counts the occurrences of words in a given input. It includes a Mapper class that tokenizes input text and a Reducer class that sums the counts of each word. The main method sets up the job configuration and specifies input and output paths.

Uploaded by

uldesoleha
Copyright
© All Rights Reserved
We take content rights seriously. If you suspect this is your content, claim it here.
Available Formats
Download as PDF, TXT or read online on Scribd
6 views3 pages

Java Word Count MapReduce Example

The document contains a Java program for a Hadoop MapReduce application that counts the occurrences of words in a given input. It includes a Mapper class that tokenizes input text and a Reducer class that sums the counts of each word. The main method sets up the job configuration and specifies input and output paths.

Uploaded by

uldesoleha
Copyright
© All Rights Reserved
We take content rights seriously. If you suspect this is your content, claim it here.
Available Formats
Download as PDF, TXT or read online on Scribd

Name: Rupesh Sunil Bhadane

Roll No: COTB49

Practical No.11
Name: Aditya Dinesh Nimse Roll No:COTB22
Code:
import [Link]; import [Link]; import

[Link]; import

[Link]; import

[Link]; import

[Link]; import

[Link]; import

[Link]; import

[Link]; import

[Link]; import

[Link]; public

class WordCount {

public static class TokenizerMapper extends

Mapper<Object, Text, Text, IntWritable>{

private final static IntWritable one = new IntWritable(1);

private Text word = new Text();

public void map(Object key, Text value, Context context

) throws IOException, InterruptedException {

StringTokenizer itr = new StringTokenizer([Link]());

while ([Link]()) { [Link]([Link]());

[Link](word, one);

} }}
public static class IntSumReducer extends

Reducer<Text,IntWritable,Text,IntWritable> { private

IntWritable result = new IntWritable();

public void reduce(Text key, Iterable<IntWritable> values,

Context context

) throws IOException, InterruptedException {

int sum = 0; for (IntWritable val : values) { sum +=

[Link]();

[Link](sum);

[Link](key, result);

public static void main(String[] args) throws Exception {

Configuration conf = new Configuration(); Job job =

[Link](conf, "word count");

[Link]([Link]);

[Link]([Link]);

[Link]([Link]);

[Link]([Link]);

[Link]([Link]);

[Link]([Link]);

[Link](job, new Path(args[0]));

[Link](job, new Path(args[1]));

[Link]([Link](true) ? 0 : 1);

}
Input:
Aditya

Onkar

Nangare

Nimse

Onkar

Shubham

Ganesh

Aditya

Output:

You might also like