在本地⽤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、将虚拟机上的l⽂件放到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、代码举例，判断表是否存在
b.test;
import org.f.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 = ate();
configuration.set("dir", "hdfs://192.168.124.116:9000/HBase");
configuration.set("keeper.quorum","Master,Slave1,Slave2");
//2、创建连接对象
connection= ateConnection(configuration);
//3、创建Admin对象
admin = Admin();
} 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();
}
drop table if exists admin
}
到此这篇关于在本地⽤idea连接虚拟机上的hbase集的实现代码的⽂章就介绍到这了，更多相关idea连接虚拟机hbase集内容请搜索以前的⽂章或继续浏览下⾯的相关⽂章希望⼤家以后多多⽀持！

版权声明：本站内容均来自互联网，仅供演示用，请勿用于商业和其他非法用途。如果侵犯了您的权益请与我们联系QQ:729038198，我们将在24小时内删除。