//创建命名空间 public class HbaseDDL { public static Connection connection = DButil.getConnection(); //创建命名空间 /** * 创建命名空间 * @param namespace 命名空间名称 */ public static void Creatnamespace(String namespace){ //获取admin Admin admin = null; try { admin = connection.getAdmin(); } catch (IOException e) { e.printStackTrace(); } //2调用方法创建命名空间 //2.1创建命名空间描述的建造者 =>设计师 NamespaceDescriptor.Builder builder = NamespaceDescriptor.create(namespace); //2.2给建造者添加需求 builder.addConfiguration("user","baigeihan"); //2.3使用builder构造出特定的对象 try { admin.createNamespace(builder.build()); } catch (IOException e) { System.out.println("命名空间已经存在"); e.printStackTrace(); } //关闭admin try { admin.close(); } catch (IOException e) { e.printStackTrace(); } } /** * 判断表格是否存在 * @param namespace 命名空间名称 * @param tablename 表格名称 * @return 是否存在 */ public static boolean isTableExists(String namespace,String tablename) throws IOException { //1.创建admin Admin admin = connection.getAdmin(); //2.使用方法判断表格是否存在 boolean b = false; try { b = admin.tableExists(TableName.valueOf(namespace, tablename)); } catch (IOException e) { e.printStackTrace(); } //3.关闭连接 admin.close(); return b; } }
标签:表格,admin,创建,namespace,空间,IOException,命名,hbase From: https://www.cnblogs.com/-0112/p/16719960.html