Hbase API核心流程及程式碼
阿新 • • 發佈:2018-12-19
核心流程
- 獲取配置物件
- 為該物件指定hbase的叢集
- 通過配置物件建立連線
- 通過連接獲取管理員物件
- 通過管理員物件對錶進行操作
- 關閉連線
程式碼
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(); } }