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

x33g5p2x  于2022-01-21 转载在 其他  
字(3.8k)|赞(0)|评价(0)|浏览(143)

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

Increment.setAttribute介绍

暂无

代码示例

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

if (!authResult.isAllowed()) {
 if (cellFeaturesEnabled && !compatibleEarlyTermination) {
  increment.setAttribute(CHECK_COVERING_PERM, TRUE);
 } else if (authorizationEnabled) {
  throw new AccessDeniedException("Insufficient permissions " +

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

increment.setAttribute("visibility", Bytes.toBytes("tag2"));
table.increment(increment);
TestCoprocessorForTags.checkTagPresence = true;
increment = new Increment(row2);
increment.add(new KeyValue(row2, f, q, 1234L, v));
increment.setAttribute("visibility", Bytes.toBytes("tag2"));
table.increment(increment);
TestCoprocessorForTags.checkTagPresence = true;

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

inc.setAttribute(SequenceRegionObserver.NUM_TO_ALLOCATE, Bytes.toBytes(numToAllocate));
} catch (IOException e) {
  throw new RuntimeException(e); // Impossible

代码示例来源:origin: cdapio/cdap

@Override
 public IncrementBuilder setAttribute(String name, byte[] value) {
  increment.setAttribute(name, value);
  return this;
 }
}

代码示例来源:origin: caskdata/cdap

@Override
 public IncrementBuilder setAttribute(String name, byte[] value) {
  increment.setAttribute(name, value);
  return this;
 }
}

代码示例来源:origin: cdapio/cdap

@Override
 public IncrementBuilder setAttribute(String name, byte[] value) {
  increment.setAttribute(name, value);
  return this;
 }
}

代码示例来源:origin: cdapio/cdap

@Override
public IncrementBuilder setAttribute(String name, byte[] value) {
 increment.setAttribute(name, value);
 return this;
}

代码示例来源:origin: co.cask.cdap/cdap-hbase-compat-base

@Override
public IncrementBuilder setAttribute(String name, byte[] value) {
 increment.setAttribute(name, value);
 return this;
}

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

return null;
inc.setAttribute(ATOMIC_OP_ATTRIB, null);
Put put = null;
Delete delete = null;

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

/**
 * Copy constructor
 * @param i
 */
public Increment(Increment i) {
 this.row = i.getRow();
 this.ts = i.getTimeStamp();
 this.tr = i.getTimeRange();
 this.familyMap.putAll(i.getFamilyCellMap());
 for (Map.Entry<String, byte[]> entry : i.getAttributesMap().entrySet()) {
  this.setAttribute(entry.getKey(), entry.getValue());
 }
}

代码示例来源:origin: org.apache.phoenix/phoenix-core

inc.setAttribute(SequenceRegionObserver.NUM_TO_ALLOCATE, Bytes.toBytes(numToAllocate));
} catch (IOException e) {
  throw new RuntimeException(e); // Impossible

代码示例来源:origin: com.aliyun.phoenix/ali-phoenix-core

inc.setAttribute(SequenceRegionObserver.NUM_TO_ALLOCATE, Bytes.toBytes(numToAllocate));
} catch (IOException e) {
  throw new RuntimeException(e); // Impossible

代码示例来源:origin: org.apache.phoenix/phoenix-core

return null;
inc.setAttribute(ATOMIC_OP_ATTRIB, null);
Put put = null;
Delete delete = null;

代码示例来源:origin: com.aliyun.phoenix/ali-phoenix-core

return null;
inc.setAttribute(ATOMIC_OP_ATTRIB, null);
Put put = null;
Delete delete = null;

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

if (!authResult.isAllowed()) {
 if (cellFeaturesEnabled && !compatibleEarlyTermination) {
  increment.setAttribute(CHECK_COVERING_PERM, TRUE);
 } else if (authorizationEnabled) {
  throw new AccessDeniedException("Insufficient permissions " +

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

increment.setAttribute("visibility", Bytes.toBytes("tag2"));
table.increment(increment);
TestCoprocessorForTags.checkTagPresence = true;
increment = new Increment(row2);
increment.add(new KeyValue(row2, f, q, 1234L, v));
increment.setAttribute("visibility", Bytes.toBytes("tag2"));
table.increment(increment);
TestCoprocessorForTags.checkTagPresence = true;

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

increment.setAttribute(attribute.getName(), attribute.getValue().toByteArray());

相关文章