暗能星系

    • 登录
    • 搜索

    Hbase shell常用命令

    大数据
    1
    1
    7
    正在加载更多帖子
    • 从旧到新
    • 从新到旧
    • 最多赞同
    回复
    • 在新帖中回复
    登录后回复
    此主题已被删除。只有拥有主题管理权限的用户可以查看。
    • A
      anneng 最后由 anneng 编辑

      1.只查询 key 注意:这个返回的不是 rowkey
      hbase(main):018:0> scan 'emp',{ FILTER => "KeyOnlyFilter()"}

      ROW COLUMN+CELL
      1 column=personal_data:city, timestamp=1501587154609, value=
      1 column=personal_data:name, timestamp=1501587131490, value=
      10 column=personal_data:city, timestamp=1501590338062, value=
      11 column=personal_data:city, timestamp=1501590380498, value=

      2.将shell的结果保存到本地
      echo "scan 'test_use',{FILTER =>"(PrefixFilter ('4'))"}"|hbase shell>hbase.txt

      3.只保存 rowkey
      echo "count 'nt', { INTERVAL => 1 }"|hbase shell>nt_rowkeys.txt
      4.查询rowkey中包括特殊字符的行
      import org.apache.hadoop.hbase.filter.CompareFilter
      import org.apache.hadoop.hbase.filter.SingleColumnValueFilter
      import org.apache.hadoop.hbase.filter.SubstringComparator

      scan 'TableName', {FILTER => org.apache.hadoop.hbase.filter.RowFilter.new(CompareFilter::CompareOp.valueOf('EQUAL'),SubstringComparator.new("se@@"))}

      5.查询含有某些值的列
      hbase> import org.apache.hadoop.hbase.filter.SingleColumnValueFilter

      hbase> import org.apache.hadoop.hbase.filter.CompareFilter

      hbase> import org.apache.hadoop.hbase.filter.BinaryComparator
      hbase> scan 'Table_Name', { FILTER => SingleColumnValueFilter.new(Bytes.toBytes('Column Family'), Bytes.toBytes('ColumnName'), CompareFilter::CompareOp.valueOf('EQUAL'),BinaryComparator.new(Bytes.toBytes('Column Value')))}

      1 条回复 最后回复 回复 引用 0
      • First post
        Last post
      Powered by 暗能星系