Hbase Shell 调用java代码:通过比较器,强过滤查询

在hbase shell里面查询:过滤字段 && 过滤值

####0, 声明要导入的java类
hbase(main):026:0> 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
 
####1, 比较数值字段: >某个数 的数据打印
hbase(main):026:0> scan 't'
ROW                                          COLUMN+CELL                                                                                                                     
 1                                           column=f:age, timestamp=1587466381584, value=25                                                                                 
 1                                           column=f:name, timestamp=1587466381584, value=a                                                                                 
 1                                           column=f:pm, timestamp=1587466381584, value=123                                                                                 
 2                                           column=f:name, timestamp=1587466381584, value=                                                                                  
 2                                           column=f:pm, timestamp=1587466381584, value=456                                                                                 
 3                                           column=f:name, timestamp=1587466381584, value=c                                                                                 
3 row(s) in 0.0300 seconds

hbase(main):060:0> scan 't', { COLUMNS => ['f:pm'], FILTER =>SingleColumnValueFilter.new(Bytes.toBytes('f'),Bytes.toBytes('pm'),CompareFilter::CompareOp.valueOf('GREATER'),Bytes.toBytes("123"))  }
ROW                                          COLUMN+CELL                                                                                                                     
 2                                           column=f:pm, timestamp=1587466381584, value=456                                                                                 
1 row(s) in 0.0210 seconds


####2, 比较时间字段: >某个时间 的数据打印
hbase(main):059:0> scan 'BASIC_INFORMATION',{COLUMNS=>['f:Visit_Date'], LIMIT=> 3}
ROW                                          COLUMN+CELL                                                                                                                     
 row1                   column=f:Visit_Date, timestamp=1567637460098, value=2010-12-04 00:00:00.0                                                       
 row2                   column=f:Visit_Date, timestamp=1567593570811, value=2005-07-04 00:00:00.0                                                       
 row3                   column=f:Visit_Date, timestamp=1567607471125, value=2009-09-21 00:00:00.0                                                       
3 row(s) in 0.0100 seconds

hbase(main):039:0> scan 'BASIC_INFORMATION', \
{ COLUMNS=>['f:Visit_Date'], LIMIT=> 3, \
FILTER =>SingleColumnValueFilter.new(Bytes.toBytes('f'),Bytes.toBytes('Visit_Date'), CompareFilter::CompareOp.valueOf('GREATER'),Bytes.toBytes("2005-07-04 00:00:00.0"))  }
ROW                                          COLUMN+CELL                                                                                                                     
 r1                   column=f:Visit_Date, timestamp=1567637460098, value=2010-12-04 00:00:00.0                                                       
 r3                   column=f:Visit_Date, timestamp=1567607471125, value=2009-09-21 00:00:00.0                                                       
 r4                   column=f:Visit_Date, timestamp=1567599833678, value=2007-12-20 00:00:00.0                                                       
3 row(s) in 0.0130 seconds
发布了282 篇原创文章 · 获赞 45 · 访问量 15万+

猜你喜欢

转载自blog.csdn.net/eyeofeagle/article/details/105688787