博客

MapReduce连接Hbase时报错及处理

我的Map class如下：


package com.hbasepackage;



import java.io.IOException;



import org.apache.hadoop.hbase.client.Result;



import org.apache.hadoop.hbase.io.ImmutableBytesWritable;



import org.apache.hadoop.hbase.mapreduce.TableMapper;



import org.apache.hadoop.hbase.util.Bytes;



import org.apache.hadoop.io.IntWritable;



import org.apache.hadoop.io.Text;



import com.google.common.primitives.*;



@SuppressWarnings("unused")



public class TestMapper extends TableMapper<Text, IntWritable>{




@Override



protected void map(ImmutableBytesWritable rowKey, Result columns, Context context)



throws IOException, InterruptedException {




try {




// get rowKey and convert it to string



String inKey = new String(rowKey.get());



// set new key having only date



String oKey = inKey.split("#")[0];



// get sales column in byte format first and then convert it to string



// (as it is stored as string from hbase shell)



byte[] bSales = columns.getValue(Bytes.toBytes("cf1"), Bytes.toBytes("sales"));



String sSales = new String(bSales);