@@ -0,0 +1,1915 @@
+%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%0A/* author @gatripat%0A * Adjustment Calculations%0A */%0Apublic class BRMapper 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 BR_RUN_DATE = %22%22;%0A%09String BR_TRADE_DATE = %22%22;%0A%09String BR_PERSON_NUM = %22%22;%0A%09String BR_PLAN_NUM = %22%22;%0A%09String BR_SUB_PLAN = %22%22;%0A%09String BR_ACTIVITY = %22%22;%0A%09String BR_FUND_IV = %22%22;%0A%09String BR_FUND_SRC = %22%22;%0A%09String BR_SHARES = %22%22;%0A%09String BR_SHRCOST = %22%22;%0A%09String BR_SHR_PRICE = %22%22;%0A%09String BR_POST_NUM = %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%09BR_RUN_DATE = token%5B0%5D;%0A%09%09BR_TRADE_DATE = token%5B1%5D;%0A%09%09BR_PERSON_NUM = token%5B2%5D;%0A%09%09BR_PLAN_NUM = token%5B3%5D;%0A%09%09BR_SUB_PLAN = token%5B4%5D;%0A%09%09BR_ACTIVITY = token%5B5%5D;%0A%09%09BR_FUND_IV = token%5B6%5D;%0A%09%09BR_FUND_SRC = token%5B7%5D;%0A%09%09BR_SHARES = token%5B8%5D;%0A%09%09BR_SHRCOST = token%5B9%5D;%0A%09%09BR_SHR_PRICE = token%5B10%5D;%0A%09%09BR_POST_NUM = token%5B11%5D;%0A%0A%09%09context.write(new Text(BR_PERSON_NUM + %22~%22 + BR_PLAN_NUM + %22~%22 + BR_SUB_PLAN),%0A%09%09%09%09new Text(BR_RUN_DATE + %22~%22 + BR_TRADE_DATE + %22~%22 + BR_ACTIVITY + %22~%22 + BR_FUND_IV + %22~%22 + BR_FUND_SRC%0A%09%09%09%09%09%09+ %22~%22 + BR_SHARES + %22~%22 + BR_SHRCOST + %22~%22 + BR_SHR_PRICE + %22~%22 + BR_POST_NUM + %22~%22+%22BR_SERIES%22));%0A%09%7D%0A%0A%7D%0A

Create BRMapper.java