zoukankan      html  css  js  c++  java
  • HBase之表状态

    import org.apache.hadoop.conf.Configuration;
    import org.apache.hadoop.hbase.HBaseConfiguration;
    import org.apache.hadoop.hbase.HColumnDescriptor;
    import org.apache.hadoop.hbase.HTableDescriptor;
    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 org.apache.hadoop.hbase.util.Bytes;
    
    import java.io.IOException;
    
    /**
     * Hbase表状态描述
     */
    public class VarCallsStatuInHBase {
        public static void main(String args[]) throws IOException{
            Configuration conf = HBaseConfiguration.create();
            Connection connection = ConnectionFactory.createConnection(conf);
            Admin admin = connection.getAdmin();
            //表的名称
            TableName tableName = TableName.valueOf("T_admin");
            //获取表描述
            HTableDescriptor desc = new HTableDescriptor(tableName);
            //获取列族描述
            HColumnDescriptor coldef = new HColumnDescriptor(Bytes.toBytes("info"));
            //加入列族
            desc.addFamily(coldef);
            //创建表
            admin.createTable(desc);
    
            try{
                //删除表 删除表前应该先disabled表
                admin.deleteTable(tableName);
            }catch (IOException e){
                System.err.println("Error deleting table: " + e.getMessage());
            }
            //disable表后可用删除
            admin.disableTable(tableName);
            //是否disable状态
            boolean isDisabled=admin.isTableDisabled(tableName);
            // Table is disabled: true
            System.out.println("Table is disabled: " + isDisabled);
            //表是否可用
            boolean avail1 = admin.isTableAvailable(tableName);
            // Table available: true
            System.out.println("Table available: " + avail1);
            //删除表
            admin.deleteTable(tableName);
            //表是否可用
            boolean avail2 = admin.isTableAvailable(tableName);
            //Table available: false
            System.out.println("Table available: " + avail2);
            //再次创建
            admin.createTable(desc);
    
            boolean isEnabled = admin.isTableEnabled(tableName);
            //Table is enabled: true*
            System.out.println("Table is enabled: " + isEnabled);
        }
    }
    /**
     Error deleting table: T_admin
     Table is disabled: true
     Table available: true
     Table available: false
     Table is enabled: true*
     */
    
  • 相关阅读:
    思岚 激光雷达 A3 使用官方sdk读取数据
    思岚激光雷达 开箱使用
    ubuntu 更新软件失败
    ubuntu 安装tftp
    Ubuntu 安装Telnet服务
    【博客搬至CSDN】
    【RabbitMQ】一文带你搞定springboot整合RabbitMQ涉及消息的发送确认,消息的消费确认机制,延时队列的实现
    基于JVisualVM的可视化监控
    LCN解决分布式事务原理解析+项目实战(原创精华版)
    springboot 用监听器统计在线人数案例分析
  • 原文地址:https://www.cnblogs.com/similarface/p/5822328.html
Copyright © 2011-2022 走看看