通过Java操作HBase

Posted

tags:

篇首语:本文由小常识网(cha138.com)小编为大家整理,主要介绍了通过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‘

  技术分享

以上是关于通过Java操作HBase的主要内容,如果未能解决你的问题,请参考以下文章

HBase Java 操作 HBase 教程

HBase实战:使用JAVA操作分布式集群HBASE

Java 操作 HBase 教程

如何使用Java API操作Hbase

如何使用Java API操作Hbase

大数据系列之HBase命令行操作