zoukankan      html  css  js  c++  java
  • hbase连接操作

    hbase连接操作

    package com.test;
    import java.io.IOException;
    
    import org.apache.hadoop.conf.Configuration;
    import org.apache.hadoop.hbase.HBaseConfiguration;
    import org.apache.hadoop.hbase.TableName;
    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.HBaseAdmin;
    import org.apache.hadoop.hbase.client.HTable;
    import org.apache.hadoop.hbase.client.Result;
    import org.apache.hadoop.hbase.util.Bytes;
    
    public class Test {
    
    
        
        public static void main(String[] args) {
            
            // 连接
            Connection conn = null;
            HTable messages = null;
            String TABLE_NAME = "mytest";
            
            Configuration configuration = HBaseConfiguration.create();
            configuration.set("hbase.zookeeper.property.clientPort", "2181");
            configuration.set("hbase.zookeeper.quorum","192.168.1.21:2181,192.168.1.22:2181,192.168.1.23:2181");
            configuration.set("hbase.master", "192.168.1.21:60000");
            
    
            
            try {
                conn = ConnectionFactory.createConnection(configuration);
                messages = (HTable) conn.getTable(TableName.valueOf(TABLE_NAME));
                System.out.println("连接到表"+messages);
                
                            Get g = new Get("287998723".getBytes());
                            Result r = messages.get(g);
                            /*byte [] value = r.getValue(Bytes.toBytes("msg"),
                               Bytes.toBytes("content"));
                String valueStr = Bytes.toString(value);*/
                
                System.out.println("Get r1 content: " );
                
            } catch (IllegalArgumentException e) {
                // TODO Auto-generated catch block
                e.printStackTrace();
            } catch (IOException e) {
                // TODO Auto-generated catch block
                e.printStackTrace();
            }
            
        }
    
    }
  • 相关阅读:
    Java中替换字符串中特定字符,replaceAll,replace,replaceFirst的区别
    牛客剑指offer 67题(持续更新~)
    从尾到头打印链表
    字符串变形
    缩写
    删除公共字符
    替换空格
    二维数组的查找
    acm博弈论基础总结
    acm模板总结
  • 原文地址:https://www.cnblogs.com/huanhuanang/p/6043068.html
Copyright © 2011-2022 走看看