java - HBase:使用MapReduce更新行？

Question

我在HBase中有一个要对其进行更新的表。例如，如果pred(row) == true(pred是用Java编写的函数)，我想将列更新为一个值。

我可以为此使用MapReduce吗？最初我以为可以，但是现在我看到MapReduce用于读取一个表并写入另一个表(或磁盘)。然后，我考虑实现一个并行扫描，该扫描将使用多个线程在整个表上进行迭代，但是似乎在重新发明轮子。

Answer 1

对于此任务，不需要MapReduce。您可以连接到HBASE并从Java应用程序本身完成工作。以下代码有一点帮助

HTable table = new HTable(HBaseConfiguration.create(), "MYTABLE");
Scan scan = new Scan();

scan.addFamily(Bytes.toBytes("myfamily"));
ResultScanner scanner = table.getScanner(scan);

for (Result result = scanner.next(); (result != null); result = scanner.next()) {
    for(KeyValue keyValue : result.list()) {
    // Make use of keyValue.getKeyString() and keyValue.getValue() here
    }
}

更新特定行的代码段如下

  Put p = new Put(Bytes.toBytes("row1"));
  p.add(Bytes.toBytes("myfamily"),
  Bytes.toBytes("fieldname"),Bytes.toBytes("NEWVALUE"));
  table.put(p);