anchor.diff:  [source,java]
   ----
   public class SomeMapper extends Mapper {
  -    @Override
  -    protected void map(Object key, Object value, Context context) throws IOException, InterruptedException {
  -		// create the MapWritable object
  -		MapWritable doc = new MapWritable()
  -		...
  -	    context.write(NullWritable.get(), doc);
  -	}}
  + @Override
  + protected void map(Object key, Object value, Context context) 
  +        throws IOException, InterruptedException {
  +   // create the MapWritable object
  +   MapWritable doc = new MapWritable();
  +   ...
  +   context.write(NullWritable.get(), doc);
  + }}
   ----
   
   [float]
  
positive.code: [source,java]
  ----
  public class MyMapper extends MapReduceBase implements Mapper {
  	@Override
  	public void map(Object key, Object value, OutputCollector output, Reporter reporter) throws IOException {
  	   // assuming the document is a String called 'source'
  	   String source =  ...
  	   Text jsonDoc = new Text(source)
  	   // send the doc directly
  	   output.collect(NullWritable.get(), jsonDoc);
  	}}
  ----
  
  [float]
  
negative.code: [source,java]
  ----
  public class MyMapper extends MapReduceBase implements Mapper {
   @Override
   public void map(Object key, Object value, OutputCollector output, Reporter reporter)
          throws IOException {
     // create the MapWritable object
     MapWritable doc = new MapWritable();
     ...
     // write the result to the output collector
     // one can pass whatever value to the key; EsOutputFormat ignores it
     output.collect(NullWritable.get(), map);
   }}
  ----
  
  [float]
  