通過Java操作HBase


  本文主要是利用IDEA 2017做一個小的Demo,能訪問CentOS的HBase。

一,hosts設置

1,Win10的C:\Windows\System32\drivers\etc目錄下,在hosts的最后加一行代碼。(其中,LZW是CentOS的主機名)

192.168.30.128     LZW

2,通過如下命令編輯CentOS的hosts文件,同樣是加上上面的IP

vi /etc/hosts

二,代碼編寫  

1,IDEA 2017新建Maven項目,填入信息,直到完成

  

  

2,pom.xml文件新增如下配置,並應用更改

  <dependencies>
        <dependency>
            <groupId>org.apache.hbase</groupId>
            <artifactId>hbase-client</artifactId>
            <version>1.2.6</version>
        </dependency>
  </dependencies>

3,新建com.demo.hbase包,並新增HBaseDemo代碼文件

package com.demo.hbase;

import org.apache.hadoop.conf.Configuration;
import org.apache.hadoop.hbase.HBaseConfiguration;
import org.apache.hadoop.hbase.client.HTable;
import org.apache.hadoop.hbase.client.Put;
import org.apache.hadoop.hbase.util.Bytes;

import java.io.IOException;

public class HBaseDemo {
    public static void main(String[] args) throws IOException {
        Configuration conf= HBaseConfiguration.create();
        conf.set("hbase.zookeeper.quorum","192.168.30.129");

        HTable table=new HTable(conf,"testtable");

        Put put=new Put(Bytes.toBytes("row1"));
        put.add(Bytes.toBytes("colfam1"),Bytes.toBytes("qual1"),Bytes.toBytes("val1"));
        put.add(Bytes.toBytes("colfam1"),Bytes.toBytes("qual2"),Bytes.toBytes("val2"));

        table.put(put);
    }
}

4,運行代碼,然后在HBase shell查看結果。成功添加

scan 'testtable'

  


免責聲明!

本站轉載的文章為個人學習借鑒使用,本站對版權不負任何法律責任。如果侵犯了您的隱私權益,請聯系本站郵箱yoyou2525@163.com刪除。



 
粵ICP備18138465號   © 2018-2025 CODEPRJ.COM