package com.lyq.hbase.util;
import java.io.IOException;
import java.util.ArrayList;
import java.util.HashMap;
import java.util.List;
import java.util.Map;
import org.apache.hadoop.conf.Configuration;
import org.apache.hadoop.hbase.HBaseConfiguration;
import org.apache.hadoop.hbase.KeyValue;
import org.apache.hadoop.hbase.client.HTable;
import org.apache.hadoop.hbase.client.Result;
import org.apache.hadoop.hbase.client.ResultScanner;
import org.apache.hadoop.hbase.client.Scan;
import org.apache.hadoop.hbase.util.Bytes;
public class HBaseConfigUtils {
public static Configuration getHBaseConfig(){
Configuration conf = HBaseConfiguration.create();
conf.set("hbase.zookeeper.quorum", "master129,slave130,slave131,slave132");
return conf;
}
@SuppressWarnings("deprecation")
public static void main(String[] args) {
List<Map<String,String>> list = new ArrayList<Map<String,String>>();
Map<String,String> map = new HashMap<String,String>();
try {
HTable table = new HTable(getHBaseConfig(),"test");
Scan scan = new Scan();
ResultScanner rs = table.getScanner(scan);
for(Result r:rs){
System.out.println("rowkey:"+Bytes.toString(r.getRow()));
map.put("rowkey", Bytes.toString(r.getRow()));
for(KeyValue kv:r.raw()){
System.out.println(Bytes.toString(kv.getQualifier())+":"+Bytes.toString(kv.getValue()));
map.put(Bytes.toString(kv.getQualifier()), Bytes.toString(kv.getValue()));
}
list.add(map);
System.out.println("==========");
}
} catch (IOException e) {
e.printStackTrace();
}
}
}