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

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集群内容请搜索我们以前的文章或继续浏览下面的相关文章希望大家以后多多支持我们!

(0)

相关推荐

  • 详解VMware12使用三台虚拟机Ubuntu16.04系统搭建hadoop-2.7.1+hbase-1.2.4(完全分布式)

    初衷 首先说明一下既然网上有那么多教程为什么要还要写这样一个安装教程呢?网上教程虽然多,但是有些教程比较老,许多教程忽略许多安装过程中的细节,比如添加用户的权限,文件权限,小编在安装过程遇到许多这样的问题所以想写一篇完整的教程,希望对初学Hadoop的人有一个直观的了解,我们接触真集群的机会比较少,虚拟机是个不错的选择,可以基本完全模拟真实的情况,前提是你的电脑要配置相对较好不然跑起来都想死,废话不多说. 环境说明 本文使用VMware® Workstation 12 Pro虚拟机创建并安装三台

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

    1.用maven添加依赖(看清自己hbase版本) <dependency> <groupId>org.apache.hbase</groupId> <artifactId>hbase-server</artifactId> <version>1.3.1</version> </dependency> <dependency> <groupId>org.apache.hbase</

  • linux虚拟机上安装配置redis3.0.7

    我们给大家列出详细的图文步骤教给大家在linux虚拟机上安装redis以及相关的配置流程. 将redis-3.0.7.tar.gz上传到linux虚拟机上编译: a)  因为redis是C语言开发,所以需要先编译,在linux上编译需要依赖gcc环境,如果没有安装gcc环境,需要安装gcc: 执行命令:yum install gcc-c++ Redis数据类型 b) 在/usr/local创建redis目录(mkdir redis) 将redis-3.0.7.tar.gz复制到此目录下(cy /

  • Vmware12虚拟机安装教程 Vmware12虚拟机上安装Oracle

    Vmware12虚拟机及Oracle安装教程分享给大家,具体内容如下 1.安装XP系统 步骤一: 步骤二: 内存分配大一些,运行会流畅一些 (推荐使用仅主机模式网络(honest),原因是当主机上不了网的时候,也能保证与虚拟机相连) 选择使用现有的虚拟盘,然后加载系统文件即可 系统XP安装成功,检测一下主机和虚拟机的通信,ipconfig获取虚拟机IP,然后在主机 ping ip地址即可 接下来在虚拟机上安装Oralce 首先先启用xp系统的共享文件功能 右击虚拟机,找到设置,点击高级选项,启用

  • 如何在Hyper-V虚拟机上安装WSUS服务器技巧

    由于许多企业继续减少使用物理服务器,一个经常提及的问题随之而来:对Windows Server更新服务(WSUS)服务器进行虚拟化处理是个好想法吗?简单的回答:是的.本文介绍了如何在Hyper-V虚拟机中运行WSUS. WSUS可以在虚拟机中运行吗? 一言以蔽之,可以运行.如果你打算在Hyper-V上运行WSUS虚拟机,通常不强制要求你在Windows Server 2008 R2操作系统上运行WSUS.为了稳妥起见,你需要部署WSUS 3 SP2.按常规,SP2之前的WSUS不能与Window

  • Apache实现本地建立泛域名虚拟主机的方法

    本文讲述了Apache实现本地建立泛域名虚拟主机的方法.分享给大家供大家参考,具体如下: 在本地建立泛域名虚拟主机,可以修改Apache的安装目录下的conf/httpd.conf,如下: <VirtualHost *:80> ServerName auciou.com ServerAlias *.auciou.com DocumentRoot F:/site/auciou </VirtualHost> 重启Apache,就可以在本地同时使用auciou.com和xxx.aucio

  • 在VMWare虚拟机上安装Centos7系统的步骤详解

    安装前工作: 确保已经安装好vmware workstation,准备好centos安装包. 以下演示安装工具及版本: VMware Workstation Pro 15.5.0 CentOS-7-x86_64-DVD-1908 安装步骤: 1.    选择左上角文件,新建虚拟机: 2.    选择自定义,并点击下一步:[从左往右依次读] 3.       一直点击下一步,到完成为止: 4.       编辑虚拟机设置,设置镜像位置:[从左往右依次读]      5.       点击开启此虚拟

  • 浅谈千兆交换路由器的虚拟路由集群技术

    一.引言: 当前,IP已经成为大部分骨干网络产品的路由协议.在部分网络环境,用户对网络的要求是很高的,任何停工和储运损耗都会对用户造成严重影响.例如: 1.Internet服务提供商提供Web主机设备,为了使得用户的Web服务器对公众总是有效的,必须保证用户99.9999%的正常运行时间. 2.过程控制应用必须能够适时访问它的控制的系统,否则可能会发生结果损失严重的控制: 3.有时,运行在IP主机上的应用会超时,如果业务运行对网络应用要求较高,这种超时会带来很坏影响. 越来越多的IP主机使用DH

  • 教你在virtualBox搭建一个本地kubernets集群问题

    目录 1. 虚拟机准备工作 1.1 下载centos7的镜像 1.2 关闭sawp内存空间 1.3 关闭 SeLinux 1.4 配置桥接模式 1.5 安装增强功能 1.6 XSHELL连接SSH 2. 安装docker 2.1 卸载旧的docker版本 2.2 配置阿里的镜像仓库 2.3 安装最新版本的 Docker Engine 和 containerd 2.5 避免和kubelet的冲突 3. 安装kubernetes 3.2 配置kubernetes的yum源 3.3 启动 kubele

  • python3.6连接MySQL和表的创建与删除实例代码

    python3.6不支持importMySQLdb改用为importpymysql模块,需要自行安装模块pymysql. 1:python3.6安装模块pymysql 命令行安装pipinstallpymysql 2:python3.6连接mysql数据库 #!/bin/env Python # -*- coding:utf-8 -*- import pymysql conn = pymysql.connect( user="root", password="root@123

  • pycharm利用pyspark远程连接spark集群的实现

    0 背景 由于工作需要,利用spark完成机器学习.因此需要对spark集群进行操作.所以利用pycharm和pyspark远程连接spark集群.这里记录下遇到的问题及方法. 主要是参照下面的文献完成相应的内容,但是具体问题要具体分析. 1 方法 1.1 软件配置 spark2.3.3, hadoop2.6, python3 1.2 spark配置 Spark集群的每个节点的Python版本必须保持一致.在每个节点的$SPARK_HOME/conf/spark-env.sh中添加一行:具体看你

随机推荐