做网站分流,乐山高端网站建设,外贸网站制作设计,中企动力淄博分公司相关环境#xff1a;
虚拟机#xff1a;Centos7 hadoop版本:3.1.3 hbase版本:2.4.11 zookeeper版本:3.5.7
Java IDE:IDEA JDK#xff1a;8 步骤
步骤一#xff1a;在idea创建一个maven项目
步骤二#xff1a;在虚拟机里找到core-site.x…
相关环境
虚拟机Centos7 hadoop版本:3.1.3 hbase版本:2.4.11 zookeeper版本:3.5.7
Java IDE:IDEA JDK8 步骤
步骤一在idea创建一个maven项目
步骤二在虚拟机里找到core-site.xml和hbase-site.xml这两个文件
我的core-site.xml文件是在hadoop安装目录下的etc/hadoop中 hbase-site.xml文件在hbase安装目录下的conf中 找到后下载下来然后放到idea的src/main/resources中 步骤三导入相关依赖
dependencies!-- https://mvnrepository.com/artifact/org.apache.hbase/hbase-server --dependencygroupIdorg.apache.hbase/groupIdartifactIdhbase-client/artifactIdversion2.4.17/version/dependency!-- https://mvnrepository.com/artifact/org.apache.hbase/hbase-client --dependencygroupIdorg.apache.hbase/groupIdartifactIdhbase-client/artifactIdversion2.4.17/version/dependency
/dependencies
步骤四写一个测试类测试一下
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 connect_test
{public static Connection connection null;public static Admin admin null;static{try{//1、获取配置信息Configuration configuration HBaseConfiguration.create();configuration.set(hbase.rootdir, hdfs://hadoop102:8020/hbase);configuration.set(hbase.zookeeper.quorum, hadoop102,hadoop103,hadoop104);//2、创建连接对象connection ConnectionFactory.createConnection(configuration);//3、创建Admin对象admin connection.getAdmin();}catch (IOException e){e.printStackTrace();}}//判断表是否存在public static boolean isTableExist(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{//测试hbase是否存在名为test的表System.out.println(isTableExist(test));//关闭资源close();}
}
比较关键的是下面这两个配置信息
configuration.set(hbase.rootdir, hdfs://hadoop102:8020/hbase);
configuration.set(hbase.zookeeper.quorum, hadoop102,hadoop103,hadoop104); 这两个信息可以在hbase-site.xml中可以找到 然后运行测试结果为true说明hbase中存在表为test的表。测试成功成功连接hbase
