hbase_table_read.java

public static void main(String[] args) throws Exception {
  Configuration hconf = HBaseConfiguration.create();
  hconf.set("hbase.rootdir", "hbase root 경로");
  hconf.set("hbase.zookeeper.quorum", "hbase zookeeper 주소");
  hconf.set("hbase.zookeeper.property.clientPort", "zookeeper port");
  
  HBaseAdmin ha = new HBaseAdmin(hconf);
  for (int i = 0; i < ha.listTableNames().length; i++){
    System.out.println(ha.listTableNames()[i]);
  }
  
  HTable hTable = new HTable(conf, "테이블명"); 
  Scan s = new Scan();
  ResultScanner rs = hTable.getScanner(s);
  
  for(Result r: rs){
    for (KeyValue kv : r.raw()){
      System.out.println("row : " + new String(kv.getRow()));
      System.out.println("family : " + new String(kv.getFamily()));
      System.out.println("qualifier : " + new String(kv.getQualifier()));
      System.out.println("value : " + new String(kv.getValue()));
    }
  }
}