// Path: big-data/MapReduceHelloWorld/src/main/java/com/sample/one/mappers/WordCountMapper.java
// public class WordCountMapper extends Mapper<LongWritable, Text, Text, LongWritable> {
// 
//     private Text word = new Text();
//     private LongWritable count = new LongWritable();
// 
//     protected void map(LongWritable key, Text value, Context context) throws IOException, InterruptedException {
// 
//         String[] split = value.toString().split("\t+");
//         word.set(split[0]);
//         if (split.length > 2) {
//             count.set(Long.parseLong(split[2]));
//             context.write(word, count);
//         }
//     }
// }
// 
// Path: big-data/MapReduceHelloWorld/src/main/java/com/sample/one/reducers/WordCountReducer.java
// public class WordCountReducer<KEY> extends Reducer<KEY, LongWritable, KEY, LongWritable> {
// 
//     private LongWritable result = new LongWritable();
// 
//     public void reduce(KEY key, Iterable<LongWritable> values, Context context) throws IOException, InterruptedException {
//         long sum = 0;
//         for (LongWritable val : values) {
//             sum += val.get();
//         }
//         result.set(sum);
//         context.write(key, result);
//     }
// 
// }


import com.sample.one.mappers.WordCountMapper;
import com.sample.one.reducers.WordCountReducer;
import org.apache.hadoop.conf.Configured;
import org.apache.hadoop.fs.Path;
import org.apache.hadoop.io.LongWritable;
import org.apache.hadoop.io.Text;
import org.apache.hadoop.mapreduce.Job;
import org.apache.hadoop.mapreduce.lib.input.FileInputFormat;
import org.apache.hadoop.mapreduce.lib.output.FileOutputFormat;
import org.apache.hadoop.util.Tool;
import org.apache.hadoop.util.ToolRunner;
package com.sample.client;


public class ClientRunner extends Configured implements Tool {

    public static void main(String[] args) throws Exception {
        int rc = ToolRunner.run(new ClientRunner(), args);
        System.exit(rc);
    }

    @Override
// Path: big-data/MapReduceHelloWorld/src/main/java/com/sample/one/mappers/WordCountMapper.java
// public class WordCountMapper extends Mapper<LongWritable, Text, Text, LongWritable> {
// 
//     private Text word = new Text();
//     private LongWritable count = new LongWritable();
// 
//     protected void map(LongWritable key, Text value, Context context) throws IOException, InterruptedException {
// 
//         String[] split = value.toString().split("\t+");
//         word.set(split[0]);
//         if (split.length > 2) {
//             count.set(Long.parseLong(split[2]));
//             context.write(word, count);
//         }
//     }
// }
// 
// Path: big-data/MapReduceHelloWorld/src/main/java/com/sample/one/reducers/WordCountReducer.java
// public class WordCountReducer<KEY> extends Reducer<KEY, LongWritable, KEY, LongWritable> {
// 
//     private LongWritable result = new LongWritable();
// 
//     public void reduce(KEY key, Iterable<LongWritable> values, Context context) throws IOException, InterruptedException {
//         long sum = 0;
//         for (LongWritable val : values) {
//             sum += val.get();
//         }
//         result.set(sum);
//         context.write(key, result);
//     }
// 
// }


// Path: big-data/MapReduceHelloWorld/src/main/java/com/sample/client/ClientRunner.java
import com.sample.one.mappers.WordCountMapper;
import com.sample.one.reducers.WordCountReducer;
import org.apache.hadoop.conf.Configured;
import org.apache.hadoop.fs.Path;
import org.apache.hadoop.io.LongWritable;
import org.apache.hadoop.io.Text;
import org.apache.hadoop.mapreduce.Job;
import org.apache.hadoop.mapreduce.lib.input.FileInputFormat;
import org.apache.hadoop.mapreduce.lib.output.FileOutputFormat;
import org.apache.hadoop.util.Tool;
import org.apache.hadoop.util.ToolRunner;

package com.sample.client;


public class ClientRunner extends Configured implements Tool {

    public static void main(String[] args) throws Exception {
        int rc = ToolRunner.run(new ClientRunner(), args);
        System.exit(rc);
    }

    @Override
    public int run(String[] args) throws Exception {