当前位置: 萬仟网 > IT编程>开发语言>Java > 在本地用idea连接虚拟机上的hbase集群的实现代码

在本地用idea连接虚拟机上的hbase集群的实现代码

2020年10月17日  | 萬仟网IT编程  | 我要评论
1、用maven添加依赖(看清自己hbase版本)<dependency><groupid>org.apache.hbase</groupid><artifa

1、用maven添加依赖(看清自己hbase版本)

<dependency>
	<groupid>org.apache.hbase</groupid>
	<artifactid>hbase-server</artifactid>
	<version>1.3.1</version>
</dependency>
<dependency>
	<groupid>org.apache.hbase</groupid>
	<artifactid>hbase-client</artifactid>
	<version>1.3.1</version>
</dependency>

2、将虚拟机上的hbase-site.xml文件放到resourcs目录下

在这里插入图片描述

3、修改本机的hosts文件(在c:\windows\system32\drivers\etc下)
添加集群的ip 名称
192.168.124.116 master
192.168.124.115 slave1
192.168.124.130 slave2

4、代码举例,判断表是否存在

package com.zyb.test;

import org.apache.hadoop.conf.configuration;
import org.apache.hadoop.hbase.hbaseconfiguration;
import org.apache.hadoop.hbase.tablename;
import org.apache.hadoop.hbase.client.admin;
import org.apache.hadoop.hbase.client.connection;
import org.apache.hadoop.hbase.client.connectionfactory;

import java.io.ioexception;

public class testdemo {


  public static connection connection=null;
  public static admin admin=null;
  static {
    try {
      //1、获取配置信息
      configuration configuration = hbaseconfiguration.create();
      configuration.set("hbase.rootdir", "hdfs://192.168.124.116:9000/hbase");
      configuration.set("hbase.zookeeper.quorum","master,slave1,slave2");
      //2、创建连接对象
      connection= connectionfactory.createconnection(configuration);
      //3、创建admin对象
      admin = connection.getadmin();
    } catch (ioexception e) {
      e.printstacktrace();
    }
  }

  //判断表是否存在
  public static boolean istableexiat(string tablename) throws ioexception {
    boolean exists = admin.tableexists(tablename.valueof(tablename));
    return exists;
  }

  public static void close(){
    if (admin!=null){
      try {
        admin.close();
      } catch (ioexception e) {
        e.printstacktrace();
      }
    }
    if (connection!=null){
      try {
        connection.close();
      } catch (ioexception e) {
        e.printstacktrace();
      }
    }
  }
  public static void main(string[] args) throws ioexception {
    system.out.println(istableexiat("student"));
    //关闭资源
    close();
  }
}

到此这篇关于在本地用idea连接虚拟机上的hbase集群的实现代码的文章就介绍到这了,更多相关idea连接虚拟机hbase集群内容请搜索萬仟网以前的文章或继续浏览下面的相关文章希望大家以后多多支持萬仟网!

如您对本文有疑问或者有任何想说的,请点击进行留言回复,万千网友为您解惑!

相关文章:

验证码:
Copyright © 2017-2020  萬仟网 保留所有权利. 粤ICP备17035492号