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

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

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

Store.add介绍

[英]Adds a value to the memstore
[中]为memstore添加一个值

代码示例

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

CellUtil.setSequenceId(cell, mvccNum);
size += store.add(cell);

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

/**
 * Used by tests
 * @param s Store to add edit too.
 * @param kv KeyValue to add.
 * @return True if we should flush.
 */
protected boolean restoreEdit(final Store s, final KeyValue kv) {
 long kvSize = s.add(kv);
 if (this.rsAccounting != null) {
  rsAccounting.addAndGetRegionReplayEditsSize(this.regionInfo.getRegionName(), kvSize);
 }
 return isFlushSize(this.addAndGetGlobalMemstoreSize(kvSize));
}

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

for (KeyValue kv: edits) {
 kv.setMemstoreTS(localizedWriteEntry.getWriteNumber());
 size += store.add(kv);

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

/**
 * Used by tests
 * @param s Store to add edit too.
 * @param cell Cell to add.
 * @return True if we should flush.
 */
protected boolean restoreEdit(final Store s, final Cell cell) {
 long kvSize = s.add(cell);
 if (this.rsAccounting != null) {
  rsAccounting.addAndGetRegionReplayEditsSize(getRegionInfo().getRegionName(), kvSize);
 }
 return isFlushSize(this.addAndGetGlobalMemstoreSize(kvSize));
}

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

size += store.add(cell);
doRollBackMemstore = true;

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

accumulatedResultSize += store.add(cell);
doRollBackMemstore = true;

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

addedSize += store.add(cell);

相关文章