import com.google.common.base.Strings;

import org.apache.hadoop.conf.Configuration;

import org.apache.hadoop.hbase.HBaseConfiguration;

import org.apache.hadoop.hbase.TableName;

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

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

import java.io.IOException;

import java.util.ArrayList;

import java.util.List;

/**

 * 尝试获取数据使用错误的列族

 */

public class GetDataWithErrorColFamily {

    public static void main(String args[]) throws IOException {

        Configuration configuration = HBaseConfiguration.create();

        Connection connection = ConnectionFactory.createConnection(configuration);

        //建立表的连接

        Table table = connection.getTable(TableName.valueOf("testtable"));

        List<Get> gets = new ArrayList<Get>();

        //列族

        byte[] cf1 = Bytes.toBytes("colfam1");

        //列限定符

        byte[] qf1 = Bytes.toBytes("qual1");

        //列限定符

        byte[] qf2 = Bytes.toBytes("qual2");

        //行键

        byte[] row1 = Bytes.toBytes("10010");

        //行键

        byte[] row2 = Bytes.toBytes("10086");

        Get get1 = new Get(row1);

        get1.addColumn(cf1,qf1);

        gets.add(get1);

        Get get2 = new Get(row2);

        get2.addColumn(cf1,qf1);

        gets.add(get2);

        Get get3 = new Get(row2);

        get3.addColumn(cf1,qf2);

        gets.add(get3);

        Get get4 = new Get(row2);

        //这个列族根本不存在

        get4.addColumn(Bytes.toBytes("BOGUS"), qf2);

        gets.add(get4);

        //抛出异常 进程中断

        //Exception in thread "main" org.apache.hadoop.hbase.client.RetriesExhaustedWithDetailsException: Failed 1 action: org.apache.hadoop.hbase.regionserver.NoSuchColumnFamilyException: Column family BOGUS does not exist in region testtable,,1470907049676.32bcdb9d8df5829ae7eda1ae06cc9dc0. in table 'testtable', {NAME => 'colfam1', DATA_BLOCK_ENCODING => 'NONE', BLOOMFILTER => 'ROW', REPLICATION_SCOPE => '0', COMPRESSION => 'NONE', VERSIONS => '1', TTL => 'FOREVER', MIN_VERSIONS => '0', KEEP_DELETED_CELLS => 'FALSE', BLOCKSIZE => '65536', IN_MEMORY => 'false', BLOCKCACHE => 'true'}

        Result[] results = table.get(gets);

        //下面的打印到达并了

        System.out.println("Result count: " + results.length);

    }

}