在本地用idea連線虛擬機器上的hbase叢集的實現程式碼
阿新 • • 發佈:2020-10-19
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叢集內容請搜尋我們以前的文章或繼續瀏覽下面的相關文章希望大家以後多多支援我們!