The HBase Architecture - HBase Essentials - page 68

import org.apache.hadoop.hbase.client.Scan;
import org.apache.hadoop.hbase.io.ImmutableBytesWritable;
import org.apache.hadoop.hbase.mapreduce.TableMapReduceUtil;
import org.apache.hadoop.hbase.mapreduce.TableMapper;
import org.apache.hadoop.hbase.mapreduce.TableReducer;
import org.apache.hadoop.hbase.util.Bytes;
import org.apache.hadoop.io.IntWritable;
import org.apache.hadoop.io.Text;
import org.apache.hadoop.mapreduce.Job;
public class HBaseMRTest {
// Mapper Class
static class HBaseTestMapper extends TableMapper<Text, IntWritable>
{
private final IntWritable ONE = new IntWritable(1);
private Text text = new Text();
@SuppressWarnings("deprecation")
@Override
public void map(ImmutableBytesWritable rowKey, Result columns,
Context context) throws IOException, InterruptedException {
try {
HashMap<String, String> customerMap = new HashMap<String,
String>();
for (KeyValue kv : columns.raw()) {
String qualifier = "";
HashMap<?, ?> kvMap = (HashMap<?, ?>) kv.toStringMap();
String colFamily = (String) kvMap.get("family");
if (colFamily.equalsIgnoreCase("cf1")) {
if (kvMap.get("qualifier") != null
&& !kvMap.get("qualifier").equals("")) {
qualifier = (String) kvMap.get("qualifier");
}
String qualifierVal = Bytes
.toString(kv.getValueArray());
customerMap.put(qualifier, qualifierVal);
}
}
System.out.println(customerMap.toString());