使用Java操作HBase-第3关：获取数据

package step3;

import java.io.IOException;
import org.apache.hadoop.conf.Configuration;
import org.apache.hadoop.hbase.HBaseConfiguration;
import org.apache.hadoop.hbase.HColumnDescriptor;
import org.apache.hadoop.hbase.HTableDescriptor;
import org.apache.hadoop.hbase.TableName;
import org.apache.hadoop.hbase.client.Admin;
import org.apache.hadoop.hbase.client.ColumnFamilyDescriptor;
import org.apache.hadoop.hbase.client.ColumnFamilyDescriptorBuilder;
import org.apache.hadoop.hbase.client.Connection;
import org.apache.hadoop.hbase.client.ConnectionFactory;
import org.apache.hadoop.hbase.client.Get;
import org.apache.hadoop.hbase.client.Put;
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.client.Table;
import org.apache.hadoop.hbase.client.TableDescriptor;
import org.apache.hadoop.hbase.client.TableDescriptorBuilder;
import org.apache.hadoop.hbase.util.Bytes;

/**
 * @author FancyKing
 */
public class Task {

    public void queryTableInfo()throws Exception{
        /********* Begin *********/

        Configuration config = HBaseConfiguration.create();
        Connection connection = ConnectionFactory.createConnection(config);
        TableName tableName = TableName.valueOf("t_step3");
        Table table = connection.getTable(tableName);
        Get get = new Get(Bytes.toBytes("row1"));
        Result result = table.get(get);
        // System.out.println("Result: " + result);
        byte[] valueBytes = result.getValue(Bytes.toBytes("data"), Bytes.toBytes("1"));
        String valueStr = new String(valueBytes,"utf-8");
        System.out.println("value:" + valueStr);

        TableName tb = TableName.valueOf("table_step3");
        Table t = connection.getTable(tb);
        Scan scan = new Scan();
        ResultScanner scanner = t.getScanner(scan);
        try {
            for (Result scannerResult: scanner) {
                // System.out.println("Scan: " + scannerResult);
                byte[] row = scannerResult.getRow();
                System.out.println("rowName:" + new String(row,"utf-8"));
            }
        } finally {
            scanner.close();
        }




        /********* End *********/
    }

}