package org.apache.blur.mapreduce.lib.update;

import java.io.IOException;

import org.apache.blur.mapreduce.lib.BlurRecord;
import org.apache.hadoop.io.NullWritable;
import org.apache.hadoop.io.Text;
import org.apache.hadoop.mapreduce.Mapper;

public class LookupBuilderMapper extends Mapper<Text, BlurRecord, Text, NullWritable> {

  @Override
  protected void map(Text key, BlurRecord value, Mapper<Text, BlurRecord, Text, NullWritable>.Context context)
      throws IOException, InterruptedException {
    context.write(new Text(value.getRowId()), NullWritable.get());
  }

}