在我的理解中,当我用现有的rowkey和方法(比如put)更新行时,我们插入一个新版本的行,但是如果rowkey不存在,它仍然插入一个新行。我的要求是,如果rowkey不存在,则不要插入新行。如何使用hbase java客户机api?
7rtdyuoh1#
你可以用 checkAndPut(rowkey,family,qualifier,CompareFilter.CompareOp.NOT_EQUAL,null,put) 但它检查rowkey中是否存在列,然后执行put。要检查rowkey是否存在,请先执行get操作并检查是否存在,然后相应地继续put。
checkAndPut(rowkey,family,qualifier,CompareFilter.CompareOp.NOT_EQUAL,null,put)
1条答案
按热度按时间7rtdyuoh1#
你可以用
checkAndPut(rowkey,family,qualifier,CompareFilter.CompareOp.NOT_EQUAL,null,put)
但它检查rowkey中是否存在列,然后执行put。要检查rowkey是否存在,请先执行get操作并检查是否存在,然后相应地继续put。