org.apache.hadoop.hbase.client.Get.isCheckExistenceOnly()方法的使用及代码示例

x33g5p2x  于2022-01-19 转载在 其他  
字(4.6k)|赞(0)|评价(0)|浏览(214)

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

Get.isCheckExistenceOnly介绍

暂无

代码示例

代码示例来源:origin: apache/hbase

@Override
public Result get(final Get get) throws IOException {
 return get(get, get.isCheckExistenceOnly());
}

代码示例来源:origin: apache/hbase

static Get toCheckExistenceOnly(Get get) {
 if (get.isCheckExistenceOnly()) {
  return get;
 }
 return ReflectionUtils.newInstance(get.getClass(), get).setCheckExistenceOnly(true);
}

代码示例来源:origin: apache/hbase

@Override
public boolean exists(Get get) throws IOException {
 if (!get.isCheckExistenceOnly()) throw new IllegalArgumentException();
 return get(get) != null;
}

代码示例来源:origin: apache/hbase

@Override
public Result get(final Get get) throws IOException {
 prepareGet(get);
 List<Cell> results = get(get, true);
 boolean stale = this.getRegionInfo().getReplicaId() != 0;
 return Result.create(results, get.isCheckExistenceOnly() ? !results.isEmpty() : null, stale);
}

代码示例来源:origin: apache/hbase

this.storeOffset = get.getRowOffsetPerColumnFamily();
this.tr = get.getTimeRange();
this.checkExistenceOnly = get.isCheckExistenceOnly();
this.loadColumnFamiliesOnDemand = get.getLoadColumnFamiliesOnDemandValue();
Map<byte[], NavigableSet<byte[]>> fams = get.getFamilyMap();

代码示例来源:origin: apache/hbase

region.metricsUpdateForGet(results, before);
  return Result
    .create(results, get.isCheckExistenceOnly() ? !results.isEmpty() : null, stale);
return Result.create(results, get.isCheckExistenceOnly() ? !results.isEmpty() : null, stale);

代码示例来源:origin: apache/hbase

out.setStoreLimit(in.getMaxResultsPerColumnFamily());
out.setStoreOffset(in.getRowOffsetPerColumnFamily());
out.setExistence_only(in.isCheckExistenceOnly());
for (Map.Entry<byte[], NavigableSet<byte[]>> family : in.getFamilyMap().entrySet()) {

代码示例来源:origin: apache/hbase

private Result get(Get get, final boolean checkExistenceOnly) throws IOException {
 if (get.isCheckExistenceOnly() != checkExistenceOnly || get.getConsistency() == null) {
  get = ReflectionUtils.newInstance(get.getClass(), get);
  get.setCheckExistenceOnly(checkExistenceOnly);

代码示例来源:origin: apache/hbase

builder.setStoreOffset(get.getRowOffsetPerColumnFamily());
if (get.isCheckExistenceOnly()){
 builder.setExistenceOnly(true);

代码示例来源:origin: apache/hbase

builder.setStoreOffset(get.getRowOffsetPerColumnFamily());
if (get.isCheckExistenceOnly()){
 builder.setExistenceOnly(true);

代码示例来源:origin: org.apache.hbase/hbase-client

@Override
public Result get(final Get get) throws IOException {
 return get(get, get.isCheckExistenceOnly());
}

代码示例来源:origin: org.apache.hbase/hbase-client

static Get toCheckExistenceOnly(Get get) {
 if (get.isCheckExistenceOnly()) {
  return get;
 }
 return ReflectionUtils.newInstance(get.getClass(), get).setCheckExistenceOnly(true);
}

代码示例来源:origin: apache/hbase

assertEquals(get.isCheckExistenceOnly(), copyGet.isCheckExistenceOnly());
assertTrue(get.getTimeRange().equals(copyGet.getTimeRange()));
assertEquals(get.getMaxVersions(), copyGet.getMaxVersions());

代码示例来源:origin: org.apache.hbase/hbase-client

this.storeOffset = get.getRowOffsetPerColumnFamily();
this.tr = get.getTimeRange();
this.checkExistenceOnly = get.isCheckExistenceOnly();
this.loadColumnFamiliesOnDemand = get.getLoadColumnFamiliesOnDemandValue();
Map<byte[], NavigableSet<byte[]>> fams = get.getFamilyMap();

代码示例来源:origin: org.apache.hbase/hbase-client

private Result get(Get get, final boolean checkExistenceOnly) throws IOException {
 if (get.isCheckExistenceOnly() != checkExistenceOnly || get.getConsistency() == null) {
  get = ReflectionUtils.newInstance(get.getClass(), get);
  get.setCheckExistenceOnly(checkExistenceOnly);

代码示例来源:origin: com.google.cloud.bigtable/bigtable-hbase

public static Get setCheckExistenceOnly(Get get) {
 if (get.isCheckExistenceOnly()){
  return get;
 } else {
  Get existsGet = new Get(get);
  existsGet.setCheckExistenceOnly(true);
  return existsGet;
 }
}

代码示例来源:origin: org.apache.hbase/hbase-client

builder.setStoreOffset(get.getRowOffsetPerColumnFamily());
if (get.isCheckExistenceOnly()){
 builder.setExistenceOnly(true);

代码示例来源:origin: org.apache.hbase/hbase-client

builder.setStoreOffset(get.getRowOffsetPerColumnFamily());
if (get.isCheckExistenceOnly()){
 builder.setExistenceOnly(true);

代码示例来源:origin: org.apache.hbase/hbase-server

@Override
public boolean exists(Get get) throws IOException {
 if (!get.isCheckExistenceOnly()) throw new IllegalArgumentException();
 return get(get) != null;
}

代码示例来源:origin: org.apache.hbase/hbase-client

assertEquals(get.isCheckExistenceOnly(), copyGet.isCheckExistenceOnly());
assertTrue(get.getTimeRange().equals(copyGet.getTimeRange()));
assertEquals(get.getMaxVersions(), copyGet.getMaxVersions());

相关文章