本文整理了Java中org.apache.hadoop.hbase.client.Get.isCheckExistenceOnly()
方法的一些代码示例,展示了Get.isCheckExistenceOnly()
的具体用法。这些代码示例主要来源于Github
/Stackoverflow
/Maven
等平台,是从一些精选项目中提取出来的代码,具有较强的参考意义,能在一定程度帮忙到你。Get.isCheckExistenceOnly()
方法的具体详情如下:
包路径:org.apache.hadoop.hbase.client.Get
类名称: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());
内容来源于网络,如有侵权,请联系作者删除!