分享

hbase corpocessor 按照例子,disable,alter table ,enable如何看到效果

ananan36 发表于 2015-9-1 14:10:04 [显示全部楼层] 回帖奖励 阅读模式 关闭右栏 3 8647
public class MyAggregationClient  {

    private static final byte[] TABLE_NAME = Bytes.toBytes("test11");
    private static final byte[] CF = Bytes.toBytes("a");
    public static void main(String[] args) throws Throwable {
    Configuration customConf = new Configuration();
    customConf.set("hbase.zookeeper.quorum",
    "testmaster1");
    //提高RPC通信时长
    customConf.setLong("hbase.rpc.timeout", 600000);
    //设置Scan缓存
    customConf.setLong("hbase.client.scanner.caching", 1000);
    Configuration configuration = HBaseConfiguration.create(customConf);
    AggregationClient aggregationClient = new AggregationClient(
    configuration);
    Scan scan = new Scan();
    //指定扫描列族,唯一值
    scan.addFamily(CF);
    //long rowCount = aggregationClient.rowCount(TABLE_NAME, null, scan);
    long rowCount = aggregationClient.rowCount(TableName.valueOf("test11"), new LongColumnInterpreter(), scan);
    System.out.println("row count is " + rowCount);
    log.o

    }

已有(3)人评论

跳转到指定楼层
arsenduan 发表于 2015-9-1 16:37:25
通过hbase shell直接看
参考下面内容


删除一个列族,alterdisableenable
我们之前建了3个列族,但是发现member_id这个列族是多余的,因为他就是主键,所以我们要将其删除。
hbase(main):003:0>alter 'member',{NAME=>'member_id',METHOD=>'delete'}

ERROR: Table memberis enabled. Disable it first before altering.

报错,删除列族的时候必须先将表给disable掉。
hbase(main):004:0>disable 'member'                                 
0 row(s) in 2.0390seconds
hbase(main):005:0>alter'member',NAME=>'member_id',METHOD=>'delete'
0 row(s) in 0.0560seconds
hbase(main):006:0>describe 'member'
DESCRIPTION                                                                                          ENABLED                                               
{NAME => 'member', FAMILIES => [{NAME=> 'address', BLOOMFILTER => 'NONE', REPLICATION_SCOPE => '0',false                                                
  VERSIONS => '3', COMPRESSION => 'NONE',TTL => '2147483647', BLOCKSIZE => '65536', IN_MEMORY => 'fa                                                      
lse', BLOCKCACHE => 'true'}, {NAME =>'info', BLOOMFILTER => 'NONE', REPLICATION_SCOPE => '0', VERSI                                                      
ONS => '3', COMPRESSION => 'NONE', TTL=> '2147483647', BLOCKSIZE => '65536', IN_MEMORY => 'false',                                                        
BLOCKCACHE => 'true'}]}                                                                                                                                    
1 row(s) in 0.0230seconds
该列族已经删除,我们继续将表enable
hbase(main):008:0> enable 'member'  
0 row(s) in 2.0420seconds

4.列出所有的表
hbase(main):028:0>list
TABLE                                                                                                                                                      
member                                                                                                                                                      
temp_table                                                                                                                                                  
2 row(s) in 0.0150seconds


5.drop一个表
hbase(main):029:0>disable 'temp_table'
0 row(s) in 2.0590seconds

hbase(main):030:0>drop 'temp_table'
0 row(s) in 1.1070seconds


6.查询表是否存在
hbase(main):021:0>exists 'member'
Table member doesexist                                                                                                                                    
0 row(s) in 0.1610seconds

7.判断表是否enable
hbase(main):034:0>is_enabled 'member'
true                                                                                                                                                        
0 row(s) in 0.0110seconds

8.判断表是否disable
hbase(main):032:0>is_disabled 'member'
false                                                                                                                                                      
0 row(s) in 0.0110seconds




来源:


HBase Shell常用命令
http://www.aboutyun.com/thread-6151-1-1.html


回复

使用道具 举报

ananan36 发表于 2015-9-6 16:55:29
arsenduan 发表于 2015-9-1 16:37
通过hbase shell直接看
参考下面内容

我写的System.out.println("row count is " + rowCount);怎么看有输出
回复

使用道具 举报

arsenduan 发表于 2015-9-6 17:11:16
ananan36 发表于 2015-9-6 16:55
我写的System.out.println("row count is " + rowCount);怎么看有输出

用context.write函数
例如
context.write(intkey, intvalue);

回复

使用道具 举报

您需要登录后才可以回帖 登录 | 立即注册

本版积分规则

关闭

推荐上一条 /2 下一条