HBase 协处理器行更新检测

Question

如何检测 HBase 协处理器中的行更新？

我试图在 RegionObserver 的 postPut() 函数中找出它，但即使值没有更改，它也会在每个 put 请求中调用。

假设这是一系列操作：

1. 把'testTable','row2','cf:f1','val1'

2. 把'testTable','row2','cf:f1','val1'

3. 输入'testTable','row2','cf:f1','val2'

所以，我想检测操作 1 和 3 何时发生，即第一次添加行以及更改值的时间。再次推送相同的值时不会。

有什么方法可以让我在 postPut() 函数中获取 cell 的旧值？并将其与新值进行比较。

Answer 1

我会在协处理器区域中预先放置并查找记录。如果记录是新的，它不应该执行物理 I/O，因为布隆过滤器 99% 的时间都是正确的。

我们在 Splice Machine（开源）进行了一些优化，我们直接访问布隆过滤器以绕过扫描中的同步。您可以查看我们的 github 站点 https://github.com/splicemachine/spliceengine 并搜索此类和方法 HRegionUtil.keyExists()。

祝你好运。