1. 程式人生 > >Hbase API核心流程及程式碼

Hbase API核心流程及程式碼

核心流程

  1. 獲取配置物件
  2. 為該物件指定hbase的叢集
  3. 通過配置物件建立連線
  4. 通過連接獲取管理員物件
  5. 通過管理員物件對錶進行操作
  6. 關閉連線

程式碼

public class HBase_API {

	public static void main(String[] args) throws Exception {
		
		/**
		 * 獲取一個配置物件
		 * 要點:獲取到了配置資訊之後,就一定要告訴這個配置物件,說接下來要建立的連線是哪個hbase叢集的連線
		 */
		Configuration config = HBaseConfiguration.create();
		config.set("hbase.zookeeper.quorum", "moc01:2181,moc02:2181,moc03:2181");
		
		
		/**
		 * 通過配置物件建立連線
		 */
		Connection connection = ConnectionFactory.createConnection(config);
		
		
		/**
		 * 通過連接獲取管理員物件
		 */
		Admin admin = connection.getAdmin();
		
		
		/**
		 * 通過管理員物件就可以對錶進行各種操作
		 */
		HTableDescriptor[] tables = admin.listTables();
		
		
		/**
		 * 針對結果進行處理
		 */
		for(HTableDescriptor table : tables){
			System.out.println(table.getNameAsString());
		}
		
		
		/**
		 * 關閉連線
		 */
		connection.close();
		
	}
}