@@ -0,0 +1,1514 @@
+%0Aimport org.apache.hadoop.conf.Configuration;%0Aimport org.apache.hadoop.fs.Path;%0Aimport org.apache.hadoop.io.Text;%0Aimport org.apache.hadoop.mapreduce.Job;%0Aimport org.apache.hadoop.mapreduce.lib.input.MultipleInputs;%0Aimport org.apache.hadoop.mapreduce.lib.input.TextInputFormat;%0Aimport org.apache.hadoop.mapreduce.lib.output.FileOutputFormat;%0A/* author @gatripat%0A * Adjustment Calculations%0A */%0A%0Apublic class InsDriver %7B%0A%0A%09public static void main(String%5B%5D args) throws Exception %7B%0A%09%09Configuration conf = new Configuration();%0A%09%09Job job = new Job(conf);%0A%09%09job.setJarByClass(InsDriver.class);%0A%09%09// job.setMapperClass(PFMapper.class);%0A%09%09job.setReducerClass(InsReducer.class);%0A%09%09// job.setNumReduceTasks(0);%0A%09%09job.setJobName(%22Participant Adjustment PoC%22);%0A%0A%09%09String busDate = args%5B3%5D.toString();%0A%09%09job.getConfiguration().set(%22BUS_DATE%22, busDate);%0A%0A%09%09// map-reduce job.%0A%09%09Path inputPath1 = new Path(args%5B0%5D);%0A%09%09Path inputPath2 = new Path(args%5B1%5D);%0A%09%09Path outputPath = new Path(args%5B2%5D);%0A%0A%09%09MultipleInputs.addInputPath(job, inputPath1, TextInputFormat.class, PFMapper.class);%0A%09%09MultipleInputs.addInputPath(job, inputPath2, TextInputFormat.class, BRMapper.class);%0A%09%09FileOutputFormat.setOutputPath(job, outputPath);%0A%09%09// TODO: Update the output path for the output directory of the%0A%09%09// map-reduce job.%0A%09%09// configuration should contain reference to your namenode%0A%0A%09%09job.setOutputKeyClass(Text.class);%0A%09%09job.setOutputValueClass(Text.class);%0A%0A%09%09// Submit the job and wait for it to finish.%0A%09%09job.waitForCompletion(true);%0A%09%7D%0A%0A%7D%0A

Create InsDriver.java