运行java类连接hbase的步骤是什么?

dxxyhpgq  于 2021-06-09  发布在  Hbase
关注(0)|答案(2)|浏览(331)
Configuration config = HBaseConfiguration.create();
HTable table = new HTable(config, "myLittleHBaseTable");

然后我在创建管理员后得到这个错误
打开到服务器的套接字连接将不会尝试使用sasl进行身份验证(未知错误)

3j86kqsm

3j86kqsm1#

这是我的项目中jar列表的屏幕截图,这些jar成功地向hbase写入数据并从hbase读取数据:

在另一篇文章中,我问如何获得一个时间戳单元格的多个版本。代码如下。它完全适用于创建表、插入值和检索值。
关于您的问题,我认为您需要在代码的配置部分添加更多信息,例如。。。

//config
    Configuration config = HBaseConfiguration.create();
    config.clear();
    config.set("hbase.zookeeper.quorum", HBASE_ZOOKEEPER_QUORUM_IP);
    config.set("hbase.zookeeper.property.clientPort", HBASE_ZOOKEEPER_PROPERTY_CLIENTPORT);
    config.set("hbase.master", HBASE_MASTER);

... 这些大写变量的值可以在下面的完整代码中看到:

public static void main(String[] args)
    throws ZooKeeperConnectionException, MasterNotRunningException, IOException, InterruptedException {

    final String HBASE_ZOOKEEPER_QUORUM_IP = "localhost.localdomain"; //set ip in hosts file
    final String HBASE_ZOOKEEPER_PROPERTY_CLIENTPORT = "2181";
    final String HBASE_MASTER = HBASE_ZOOKEEPER_QUORUM_IP + ":60010";

    //identify a data cell with these properties
    String tablename = "characters";
    String row = "johnsmith";
    String family = "capital";
    String qualifier = "A"; 

    //config
    Configuration config = HBaseConfiguration.create();
    config.clear();
    config.set("hbase.zookeeper.quorum", HBASE_ZOOKEEPER_QUORUM_IP);
    config.set("hbase.zookeeper.property.clientPort", HBASE_ZOOKEEPER_PROPERTY_CLIENTPORT);
    config.set("hbase.master", HBASE_MASTER);

    //admin
    HBaseAdmin hba = new HBaseAdmin(config);

    //create a table
    HTableDescriptor descriptor = new HTableDescriptor(tablename);
    descriptor.addFamily(new HColumnDescriptor(family));
    hba.createTable(descriptor);
    hba.close();

    //get the table
    HTable htable = new HTable(config, tablename);

    //insert 10 different timestamps into 1 record
    for(int i = 0; i < 10; i++) {
        String value = Integer.toString(i);
        Put put = new Put(Bytes.toBytes(row));
        put.add(Bytes.toBytes(family), Bytes.toBytes(qualifier), System.currentTimeMillis(), Bytes.toBytes(value));
        htable.put(put);
        Thread.sleep(200); //make sure each timestamp is different
    }

    //get 10 timestamp versions of 1 record
    final int MAX_VERSIONS = 10;
    Get get = new Get(Bytes.toBytes(row));
    get.setMaxVersions(MAX_VERSIONS);
    Result result = htable.get(get);
    byte[] value = result.getValue(Bytes.toBytes(family), Bytes.toBytes(qualifier));  // returns MAX_VERSIONS quantity of values
    String output = Bytes.toString(value);

    //show me what you got
    System.out.println(output); //prints 9 instead of 0 through 9
}
zwghvu4y

zwghvu4y2#

java类路径中是否有hbase-site.xml?hbase从hbas-site.xml获取zookeeper信息,连接到zookeeper,然后连接hbase。

相关问题