org.apache.hadoop.hbase.KeyValue.isDelete()方法的使用及代码示例

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

KeyValue.isDelete介绍

暂无

代码示例

代码示例来源：origin: apache/kylin

if (kv.isDelete()) {
data.get(row).get(kv.getFamily()).clear();
} else {

代码示例来源：origin: forcedotcom/phoenix

private PTable buildDeletedTable(byte[] key, ImmutableBytesPtr cacheKey, HRegion region, long clientTimeStamp) throws IOException {
if (clientTimeStamp == HConstants.LATEST_TIMESTAMP) {
return null;
}

Scan scan = newTableRowsScan(key, clientTimeStamp, HConstants.LATEST_TIMESTAMP);
scan.setFilter(new FirstKeyOnlyFilter());
scan.setRaw(true);
RegionScanner scanner = region.getScanner(scan);
List results = Lists.newArrayList();
scanner.next(results);
// HBase ignores the time range on a raw scan (HBASE-7362)
if (!results.isEmpty() && results.get(0).getTimestamp() > clientTimeStamp) {
KeyValue kv = results.get(0);
if (kv.isDelete()) {
Map metaDataCache = GlobalCache.getInstance(this.getEnvironment()).getMetaDataCache();
PTable table = newDeletedTableMarker(kv.getTimestamp());
metaDataCache.put(cacheKey, table);
return table;
}
}
return null;
}

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

/**
* @return True if a delete type, a {@link KeyValue.Type#Delete} or
* a {KeyValue.Type#DeleteFamily} or a {@link KeyValue.Type#DeleteColumn}
* KeyValue type.
*/
@Deprecated // use CellUtil#isDelete
public boolean isDelete() {
return KeyValue.isDelete(getType());
}

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

/**
* @return True if a delete type, a {@link KeyValue.Type#Delete} or
* a {KeyValue.Type#DeleteFamily} or a {@link KeyValue.Type#DeleteColumn}
* KeyValue type.
*/
public boolean isDelete() {
return KeyValue.isDelete(getType());
}

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

/**
* Do right thing with passed key, add to deletes or add to candidates.
* @param kv
* @return True if we added a candidate
*/
boolean handle(final KeyValue kv) {
if (kv.isDelete()) {
handleDeletes(kv);
return false;
}
return addCandidate(kv);
}

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

/**
* Do right thing with passed key, add to deletes or add to candidates.
* @param kv
* @return True if we added a candidate
*/
boolean handle(final Cell kv) {
if (KeyValueUtil.ensureKeyValue(kv).isDelete()) {
handleDeletes(kv);
return false;
}
return addCandidate(kv);
}

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

/**
* Check whether this version should be retained.
* There are 4 variables considered:
* If this version is past max versions -> skip it
* If this kv has expired or was deleted, check min versions
* to decide whther to skip it or not.
*
* Increase the version counter unless this is a delete
*/
private MatchCode checkVersion(byte type, long timestamp) {
if (!KeyValue.isDelete(type)) {
currentCount++;
}
if (currentCount > maxVersions) {
return ScanQueryMatcher.MatchCode.SEEK_NEXT_COL; // skip to next col
}
// keep the KV if required by minversions or it is not expired, yet
if (currentCount <= minVersions || !isExpired(timestamp)) {
setTSAndType(timestamp, type);
return ScanQueryMatcher.MatchCode.INCLUDE;
} else {
return MatchCode.SEEK_NEXT_COL;
}
}

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

if (kv.isDelete()) {
if (delete == null) {
delete = new Delete(key.get());

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

if (del != null) context.write(tableOut, del);
if (kv.isDelete()) {
del = new Delete(kv.getRow());
} else {
if (kv.isDelete()) {
del.addDeleteMarker(kv);
} else {

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

/**
* Advanced use only.
* Add an existing delete marker to this Delete object.
* @param kv An existing KeyValue of type "delete".
* @return this for invocation chaining
* @throws IOException
*/
public Delete addDeleteMarker(KeyValue kv) throws IOException {
if (!kv.isDelete()) {
throw new IOException("The recently added KeyValue is not of type "
+ "delete. Rowkey: " + Bytes.toStringBinary(this.row));
}
if (Bytes.compareTo(this.row, 0, row.length, kv.getBuffer(),
kv.getRowOffset(), kv.getRowLength()) != 0) {
throw new IOException("The row in the recently added KeyValue "
+ Bytes.toStringBinary(kv.getBuffer(), kv.getRowOffset(),
kv.getRowLength()) + " doesn't match the original one "
+ Bytes.toStringBinary(this.row));
}
byte [] family = kv.getFamily();
List list = familyMap.get(family);
if (list == null) {
list = new ArrayList();
}
list.add(kv);
familyMap.put(family, list);
return this;
}

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

assert !KeyValue.isDelete(type);
do {

代码示例来源：origin: domino-succ/domino

VERSION_KV_COMPARATOR);
for (KeyValue kv : status) {
if (kv.isDelete() || kv.isEmptyColumn()) {
continue;

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

for (KeyValue kv : kvs) {
if (lastKV == null || lastKV.getType() != kv.getType() || !lastKV.matchingRow(kv)) {
if (kv.isDelete()) {
del = new Delete(kv.getRow());
del.setClusterId(entry.getKey().getClusterId());
if (kv.isDelete()) {
del.addDeleteMarker(kv);
} else {

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

if (kv.isDelete()) {
if (!keepDeletedCells) {