在本地用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集群内容请搜索脚本之家以前的文章或继续浏览下面的相关文章希望大家以后多多支持脚本之家!
相关文章
解决"XML Parser Error on line 1: 前言中不允许有内容"错误
解决用windows自带的记事编辑xml文件后出现 "XML Parser Error on line 1: 前言中不允许有内容。"的错误2018-02-02利用Spring MVC+Mybatis实现Mysql分页数据查询的过程详解
这篇文章主要给大家介绍了关于利用Spring MVC+Mybatis实现Mysql分页数据查询的相关资料,文中通过示例代码介绍的非常详细,对大家的学习或者工作具有一定的参考学习价值,需要的朋友们下面跟着小编来一起学习学习吧。2017-08-08SpringCloud OpenFeign自定义结果解码器方式
这篇文章主要介绍了SpringCloud OpenFeign自定义结果解码器方式,具有很好的参考价值,希望对大家有所帮助,如有错误或未考虑完全的地方,望不吝赐教2023-09-09springboot配置文件属性变量引用方式${}和@@用法及区别说明
这篇文章主要介绍了springboot配置文件属性变量引用方式${}和@@用法及区别说明,具有很好的参考价值,希望对大家有所帮助。如有错误或未考虑完全的地方,望不吝赐教2022-03-03基于Pinpoint对SpringCloud微服务项目实现全链路监控的问题
这篇文章主要介绍了基于Pinpoint对SpringCloud微服务项目实现全链路监控的问题,本文通过图文并茂的形式给大家介绍的非常详细,对大家的学习或工作具有一定的参考借鉴价值,需要的朋友可以参考下2022-02-02
最新评论