org.apache.hadoop.hbase.regionserver.Store.upsert()方法的使用及代码示例

x33g5p2x  于2022-01-30 转载在 其他  
字(1.1k)|赞(0)|评价(0)|浏览(179)

本文整理了Java中org.apache.hadoop.hbase.regionserver.Store.upsert()方法的一些代码示例,展示了Store.upsert()的具体用法。这些代码示例主要来源于Github/Stackoverflow/Maven等平台,是从一些精选项目中提取出来的代码,具有较强的参考意义,能在一定程度帮忙到你。Store.upsert()方法的具体详情如下:
包路径:org.apache.hadoop.hbase.regionserver.Store
类名称:Store
方法名:upsert

Store.upsert介绍

[英]Adds or replaces the specified KeyValues.

For each KeyValue specified, if a cell with the same row, family, and qualifier exists in MemStore, it will be replaced. Otherwise, it will just be inserted to MemStore.

This operation is atomic on each KeyValue (row/family/qualifier) but not necessarily atomic across all of them.
[中]添加或替换指定的键值。
对于指定的每个KeyValue,如果MemStore中存在具有相同行、族和限定符的单元格,则将替换该单元格。否则,它只会被插入MemStore。
此操作在每个键值(行/族/限定符)上都是原子的,但不一定在所有键值上都是原子的。

代码示例

代码示例来源:origin: co.cask.hbase/hbase

size += store.upsert(entry.getValue());
allKVs.addAll(entry.getValue());

代码示例来源:origin: co.cask.hbase/hbase

size += store.upsert(entry.getValue());
allKVs.addAll(entry.getValue());

代码示例来源:origin: harbby/presto-connectors

if (store.getFamily().getMaxVersions() == 1) {
 accumulatedResultSize += store.upsert(results, getSmallestReadPoint());

代码示例来源:origin: harbby/presto-connectors

size += store.upsert(entry.getValue(), getSmallestReadPoint());
} else {

相关文章