zoukankan      html  css  js  c++  java
  • 13 hbase连接

     Configuration conf=new Configuration();
            String zookeeper="";
            String clientport="2181";
            String tableName="pbtest";
            String rowkey="22977609";
            conf.set(HBASE_ZOOKEEPER_QUORUM, zookeeper);
            conf.set(HBASE_ZOOKEEPER_CLINETPORT, clientport);
            conf= HBaseConfiguration.create(conf);
    
            Table table=null;
            try {
                Connection connection = ConnectionFactory.createConnection(conf);
                table=connection.getTable(TableName.valueOf(tableName));
            } catch (IOException e) {
                e.printStackTrace();
            }
            Get get=new Get(Bytes.toBytes(rowkey));
            Result result= null;
            try {
                result = table.get(get);
            } catch (IOException e) {
                e.printStackTrace();
            }
            Cell cell = result.getColumnLatestCell(Bytes.toBytes("cf"), Bytes.toBytes("data"));
            byte[] value = CellUtil.cloneValue(cell);
  • 相关阅读:
    ASP.NET 篇
    .NET Core 篇
    JS-CSS篇
    IIS使用篇
    WebService篇
    电脑使用篇
    数据库使用篇
    正则表达式篇
    Linux学习篇
    Leetcode 198. 打家劫舍 dp
  • 原文地址:https://www.cnblogs.com/yangh2016/p/6121769.html
Copyright © 2011-2022 走看看