@@ -0,0 +1,534 @@
+package edu.isi.karma.mapreduce.driver;%0A%0Aimport java.io.IOException;%0A%0Aimport org.apache.hadoop.io.BytesWritable;%0Aimport org.apache.hadoop.io.Text;%0Aimport org.apache.hadoop.mapreduce.Mapper;%0Aimport org.json.JSONObject;%0A%0Apublic class IdentityJSONMapper extends Mapper%3CBytesWritable, Text, Text, Text%3E %7B%0A%09@Override%0A%09public void map(BytesWritable key, Text value, Context context) throws IOException, InterruptedException %7B%0A%09%09JSONObject obj = new JSONObject(value.toString());%0A%09%09context.write(new Text(obj.getString(%22@id%22)), value);%0A%09%7D%0A%7D%0A

Add Identity Mapper