标签：admin toBytes Bytes 插入 new Hb table Hbase configuration

Hbase 创建表 插入数据

创建表

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

   // Instantiating configuration class 初始化配置文件
   Configuration con = HBaseConfiguration.create();

   // Instantiating HbaseAdmin class  初始化HbaseAdmin 
   HBaseAdmin admin = new HBaseAdmin(con);

   // Instantiating table descriptor class  设置表名
   HTableDescriptor tableDescriptor = new
   TableDescriptor(TableName.valueOf("member"));

   // Adding column families to table descriptor  设置列族名（可设置多个）
   tableDescriptor.addFamily(new HColumnDescriptor("personal"));
   tableDescriptor.addFamily(new HColumnDescriptor("professional"));


   // Execute the table through admin
   admin.createTable(tableDescriptor);
   System.out.println(" Table created ");

   }

插入数据

 public static void main(String[] args) throws IOException {
        //第一步，设置HBsae配置信息
        Configuration configuration = HBaseConfiguration.create();
        //注意。这里这行目前没有注释掉的，这行和问题3有关系  是要根据自己zookeeper.znode.parent的配置信息进行修改。
        configuration.set("hbase.zookeeper.quorum", "192.168.222.128");  //hbase 服务地址
        configuration.set("hbase.zookeeper.property.clientPort", "2181"); //端口号
        //这里使用的是接口Admin   该接口有一个实现类HBaseAdmin   也可以直接使用这个实现类
        Admin admin = ConnectionFactory.createConnection(configuration).getAdmin();

        conn = ConnectionFactory.createConnection(configuration);


        if (admin != null) {
            try {
                //获取到数据库所有表信息
                HTableDescriptor[] allTable = admin.listTables();
                for (HTableDescriptor hTableDescriptor : allTable) {
                    System.out.println(hTableDescriptor.getNameAsString());
                }
            } catch (IOException e) {
                e.printStackTrace();
            }
        }

        String id = "001828";
        String name = "Paul_Smith";

        //2、创建数据对象
        String rowKey = "101" + "_" + id + "_" + name ;
        Put put = new Put(Bytes.toBytes(rowKey));
        byte[] family = Bytes.toBytes("personal");

        put.addColumn(family, Bytes.toBytes("key"), Bytes.toBytes(id));
        put.addColumn(family, Bytes.toBytes("value"), Bytes.toBytes(name));

        List<Put> puts = new ArrayList<Put>();
        puts.add(put);

        Table table = conn.getTable(TableName.valueOf("member"));
        table.put(puts);
        table.close();

        System.out.println("sucsssss");
    }

标签：admin,toBytes,Bytes,插入,new,Hb,table,Hbase,configuration
来源： https://www.cnblogs.com/Jomini/p/12247765.html

本站声明： 1. iCode9 技术分享网（下文简称本站）提供的所有内容，仅供技术学习、探讨和分享；
2. 关于本站的所有留言、评论、转载及引用，纯属内容发起人的个人观点，与本站观点和立场无关；
3. 关于本站的所有言论和文字，纯属内容发起人的个人观点，与本站观点和立场无关；
4. 本站文章均是网友提供，不完全保证技术分享内容的完整性、准确性、时效性、风险性和版权归属；如您发现该文章侵犯了您的权益，可联系我们第一时间进行删除；
5. 本站为非盈利性的个人网站，所有内容不会用来进行牟利，也不会利用任何形式的广告来间接获益，纯粹是为了广大技术爱好者提供技术内容和技术思想的分享性交流网站。