我正在尝试使用此代码使用hbase过滤器,
hbase(main):001:0>扫描'students',{FILTER => SingleColumnValueFilter.new(Bytes.toBytes('account'),Bytes.toBytes('name'),CompareFilter :: CompareOp.valueOf('EQUAL' ),BinaryComparator.new(Bytes.toBytes( 'EMP1')))}
并且此代码给出错误,如 NameError:uninitialized constant SingleColumnValueFilter
请让我知道我做错了什么或我需要做什么来获得过滤结果.
hbase(main):009:0> import org.apache.hadoop.hbase.util.Bytes;
hbase(main):009:0> import org.apache.hadoop.hbase.filter.SingleColumnValueFilter;
hbase(main):009:0> import org.apache.hadoop.hbase.filter.BinaryComparator;
hbase(main):009:0> import org.apache.hadoop.hbase.filter.CompareFilter;
hbase(main):009:0> import org.apache.hadoop.hbase.filter. Filter;
Run Code Online (Sandbox Code Playgroud)
| 归档时间: |
|
| 查看次数: |
3979 次 |
| 最近记录: |