import java.io.IOException;
import java.util.HashMap;
import java.util.Map;
import java.util.Set;
import org.apache.hadoop.conf.Configuration;
import org.apache.hadoop.hbase.HBaseConfiguration;
import org.apache.hadoop.hbase.client.Put;
import org.apache.hadoop.hbase.client.Result;
import org.apache.hadoop.hbase.client.Scan;
import org.apache.hadoop.hbase.io.ImmutableBytesWritable;
import org.apache.hadoop.hbase.mapreduce.MultiTableOutputFormat;
import org.apache.hadoop.hbase.mapreduce.TableInputFormat;
import org.apache.hadoop.hbase.mapreduce.TableMapReduceUtil;
import org.apache.hadoop.hbase.mapreduce.TableMapper;
import org.apache.hadoop.hbase.util.Bytes;
import org.apache.hadoop.mapreduce.Job;
import org.apache.hadoop.util.GenericOptionsParser;
public class IndexBuilder {
,,,private class MyMapper extends TableMapper, {
,,,,,,,private Map, indexes =, new HashMap ();
,,,,,,,private String columnFamily;
,,,,,,@Override
,,,,,,,protected void 地图(ImmutableBytesWritable 关键,Result 价值,
,,,,,,,,,,,,,,,Context 上下文),throws IOException, InterruptedException {
,,,,,,,,,,,SetMapreduce构建hbase二级索引
