如何使用HBase API删除Google Cloud Bigtable中单行的列

Question

我正在使用HBase API访问Google Cloud Bigtable,但每当我尝试删除列时:

Delete delete = new Delete(r.getRow());
delete.addColumn(CF, Bytes.toBytes(d.seqid()));
delete.addColumn(CF, COL_LEASE);
tasksTable.delete(delete);

我得到了UnsupportedOperationException:

java.lang.UnsupportedOperationException: Cannot delete single latest cell.
at com.google.cloud.bigtable.hbase.adapters.DeleteAdapter.throwIfUnsupportedPointDelete(DeleteAdapter.java:85)
at com.google.cloud.bigtable.hbase.adapters.DeleteAdapter.adapt(DeleteAdapter.java:141)
at com.google.cloud.bigtable.hbase.adapters.HBaseRequestAdapter.adapt(HBaseRequestAdapter.java:71)
at com.google.cloud.bigtable.hbase.BigtableTable.delete(BigtableTable.java:307)
at queue.BigTableRowBackedQueue.poll(BigTableRowBackedQueue.java:54)

我在代码中看到它出现在这里.

我可以从HBase Java客户端中删除整行,并且可以使用HBase shell删除单个列.

如何在不删除Java客户端中的行的情况下删除列？

Answer 1

对不起您的麻烦.Bigtable和HBase在几个方面有所不同,这就是其中之一.

Delete delete = new Delete(rowKey);
delete.addColumns(COLUMN_FAMILY, qual); // the 's' matters
table.delete(delete);

HBase Delete.addColumn只删除列中的最新单元格.该Delete.addColumn_s_方法删除所有单元格(即所有不同的时间戳).另外,您也可以通过删除特定的细胞Delete.addColumn(byte[], byte[], long),其中long是一个时间戳.

hbase shell delete 使用 封面下的deleteColumns映射addColumns.它也使用s变体,这就是它工作的原因.

仅供参考这里是我们完成TestDelete套件,它识别您当前的使用情况下,@Category(KnownGap.class)我们用它来识别不同失踪HBase的特点,在Bigtable的客户端.