HBase命令

Posted 2020-10-29 chenyongxiang

HBase命令
---------------------------------------------
    1.启停
        $> start-hbase.sh
        $> stop-hbase.sh
        
    

HBase shell
---------------------------------------------
    $> hbase shell
    
    $hbase> help                            // 查看帮助
    $hbase> help "put"                        // 查看 put 命令 的帮助
    
    $hbase> put                                // insert + update 例如：put ‘t1‘,‘row1‘,‘f2‘,‘value_2‘ 或者 put ‘t1‘,‘row1‘,‘f3:column_3‘,‘value_3_col‘
    $hbase> delete                            //
    $hbase> get + scan                        // get ‘t1‘,‘row1‘ 或者 scan ‘t1‘
    
    $hbase> create                            // create ‘t1‘, {NAME => ‘f1‘} 或 create ‘t1‘, {NAME => ‘f1‘}, {NAME => ‘f2‘}, {NAME => ‘f3‘} 或 create ‘t1‘, ‘f1‘, ‘f2‘, ‘f3‘
    $hbase> disable                            // disable ‘t1‘
    $hbase> drop                            // drop ‘t1‘
    
    $hbase> list                            // 输出用户空间的所有表
    $hbase> list_namespace                    // 列出所有的命名空间
    $hbase> list_namespace_tables ‘hbase‘    // 列出对应命名空间的所有表
    $hbase> scan ‘hbase:meta‘                // 列出 hbase下的 命名空间 meta
    $hbase> scan ‘hbase:namespace‘            // 列出 hbase下的 命名空间 namespace
    


HBase 客户端API
---------------------------------------------
    1.创建类
        public static void main(String[] args) throws Exception {
            // 创建配置对象
            Configuration conf = HBaseConfiguration.create();
            
            // 通过连接工厂创建连接对象
            Connection conn = ConnectionFactory.createConnection(conf);
            
            // 通过连接获取table信息
            Table table = conn.getTable(TableName.valueOf("t1"));
            
            // 设定 row no
            Put put = new Put(Bytes.toBytes("r1"));
            
            // 设置字段值
            put.addColumn(Bytes.toBytes("f1"), Bytes.toBytes("c1"), Bytes.toBytes("r1_f1_c1_tom"));
            
            // put
            table.put(put);
            
            //关闭
            table.close();
            conn.close();
            
            System.out.println("-- OVER --");
        }
        
    2.添加配置文件
        <?xml version="1.0"?>
        <configuration>
            <!-- zk 配置 -->
            <property>
                <name>hbase.zookeeper.property.clientPort</name>
                <value>2181</value>
            </property>
            <property>
                <name>hbase.zookeeper.quorum</name>
                <value>h3,h4,h5</value>
            </property>
        </configuration>
        
    3.添加日志配置文件
        log4j.properties