@@ -0,0 +1,1586 @@
+%0Aimport java.io.BufferedReader;%0Aimport java.io.FileReader;%0Aimport java.io.IOException;%0Aimport java.net.URI;%0Aimport java.text.DateFormat;%0Aimport java.text.ParseException;%0Aimport java.text.SimpleDateFormat;%0Aimport java.util.ArrayList;%0Aimport java.util.Date;%0Aimport java.util.HashMap;%0A%0Aimport org.apache.hadoop.filecache.DistributedCache;%0Aimport org.apache.hadoop.fs.Path;%0Aimport org.apache.hadoop.io.LongWritable;%0Aimport org.apache.hadoop.io.Text;%0Aimport org.apache.hadoop.mapreduce.Mapper;%0Aimport org.apache.log4j.Logger;%0A%0A/* author @gatripat%0A * Adjustment Calculations%0A */%0Apublic class PFMapper extends Mapper%3CLongWritable, Text, Text, Text%3E %7B%0A%09Logger log = Logger.getLogger(BRMapper.class);%0A%09private Text word = new Text();%0A%09String%5B%5D token;%0A%09String PF_PERSON_NUM = %22%22;%0A%09String PF_PLAN_NUM = %22%22;%0A%09String PF_SUB_PLAN = %22%22;%0A%09String PF_SHR_BAL_CUR = %22%22;%0A%09String PF_LAST_POST_DATE = %22%22;%0A%09String PF_BAEXT_EXT_DATE = %22%22;%0A%09String PF_CYC_ID = %22%22;%0A%0A%09// PERSON PLAN_NUM SUB_PLAN SHR_BAL_CUR LAST_POST_DATE BAEXT_EXT_DATE CYC_ID%0A%0A%09@Override%0A%09protected void map(LongWritable key, Text value, Context context) throws IOException, InterruptedException %7B%0A%09%09token = value.toString().split(%22,%22, -1);%0A%0A%09%09PF_PERSON_NUM = token%5B0%5D;%0A%09%09PF_PLAN_NUM = token%5B1%5D;%0A%09%09PF_SUB_PLAN = token%5B2%5D;%0A%09%09PF_SHR_BAL_CUR = token%5B3%5D;%0A%09%09PF_LAST_POST_DATE = token%5B4%5D;%0A%09%09PF_BAEXT_EXT_DATE = token%5B5%5D;%0A%09%09PF_CYC_ID = token%5B6%5D;%0A%0A%09%09context.write(new Text(PF_PERSON_NUM + %22~%22 + PF_PLAN_NUM + %22~%22 + PF_SUB_PLAN),%0A%09%09%09%09new Text(PF_SHR_BAL_CUR + %22~%22 + PF_LAST_POST_DATE + %22~%22 + PF_BAEXT_EXT_DATE + %22~%22 + PF_CYC_ID+%22~%22+%22PF_SERIES%22));%0A%09%7D%0A%0A%7D%0A

Create PFMapper.java