您的位置:首页 > 运维架构 > Shell

HBase shell中使用fliter

2016-01-04 17:41 501 查看
在hbase的命令行中,可以直接使用filter进行scan,命令如下所示:

[code]import org.apache.hadoop.hbase.filter.CompareFilter
import org.apache.hadoop.hbase.filter.SingleColumnValueFilter
import org.apache.hadoop.hbase.filter.SubstringComparator
import org.apache.hadoop.hbase.util.Bytes
scan 'obd_multtrace', { COLUMNS => 'info:accessTime', FILTER => 
    SingleColumnValueFilter.new 
        (Bytes.toBytes('info'),
         Bytes.toBytes('accessTime'), 
         CompareFilter::CompareOp.valueOf('EQUAL'), 
         SubstringComparator.new('2015-12-09'))}


如果是filter是自定义的,则首先将filter的jar包复制到hbase集群的所有结点上,再重启hbase,

在命令行中使用该自定义filter时,需要给import命令后的filter类名加入引号,比如import “test.testfilter”;否则,如果使用NameError: undefined local variable or method `test’
内容来自用户分享和网络整理,不保证内容的准确性,如有侵权内容,可联系管理员处理 点击这里给我发消息
标签: