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

x33g5p2x  于2022-01-16 转载在 其他  
字(18.6k)|赞(0)|评价(0)|浏览(212)

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

Append.setAttribute介绍

暂无

代码示例

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

  1. @Override
  2. public Result preAppend(ObserverContext<RegionCoprocessorEnvironment> c, Append append)
  3.   throws IOException {
  4.  User user = getActiveUser(c);
  5.  checkForReservedTagPresence(user, append);
  6.  // Require WRITE permission to the table, CF, and the KV to be appended
  7.  RegionCoprocessorEnvironment env = c.getEnvironment();
  8.  Map<byte[],? extends Collection<Cell>> families = append.getFamilyCellMap();
  9.  AuthResult authResult = permissionGranted(OpType.APPEND, user,
  10.    env, families, Action.WRITE);
  11.  AccessChecker.logResult(authResult);
  12.  if (!authResult.isAllowed()) {
  13.   if (cellFeaturesEnabled && !compatibleEarlyTermination) {
  14.    append.setAttribute(CHECK_COVERING_PERM, TRUE);
  15.   } else if (authorizationEnabled)  {
  16.    throw new AccessDeniedException("Insufficient permissions " +
  17.     authResult.toContextString());
  18.   }
  19.  }
  20.  byte[] bytes = append.getAttribute(AccessControlConstants.OP_ATTRIBUTE_ACL);
  21.  if (bytes != null) {
  22.   if (cellFeaturesEnabled) {
  23.    addCellPermissions(bytes, append.getFamilyCellMap());
  24.   } else {
  25.    throw new DoNotRetryIOException("Cell ACLs cannot be persisted");
  26.   }
  27.  }
  28.  return null;
  29. }

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

  1. append.setAttribute("visibility", Bytes.toBytes("tag2"));
  2. table.append(append);
  3. TestCoprocessorForTags.checkTagPresence = true;
  4. append = new Append(row4);
  5. append.add(new KeyValue(row4, f, q, 1234L, v));
  6. append.setAttribute("visibility", Bytes.toBytes("tag2"));
  7. table.append(append);
  8. TestCoprocessorForTags.checkTagPresence = true;

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

  1. public Append dropSequence(long timestamp) {
  2.   byte[] key =  this.key.getKey();
  3.   Append append = new Append(key);
  4.   append.setAttribute(SequenceRegionObserver.OPERATION_ATTRIB, new byte[] {(byte)MetaOp.DROP_SEQUENCE.ordinal()});
  5.   if (timestamp != HConstants.LATEST_TIMESTAMP) {
  6.     append.setAttribute(SequenceRegionObserver.MAX_TIMERANGE_ATTRIB, Bytes.toBytes(timestamp));
  7.   }
  8.   Map<byte[], List<Cell>> familyMap = append.getFamilyCellMap();
  9.   familyMap.put(PhoenixDatabaseMetaData.SYSTEM_SEQUENCE_FAMILY_BYTES, Arrays.<Cell>asList(
  10.       PhoenixKeyValueUtil.newKeyValue(key, PhoenixDatabaseMetaData.SYSTEM_SEQUENCE_FAMILY_BYTES, QueryConstants.EMPTY_COLUMN_BYTES, timestamp, ByteUtil.EMPTY_BYTE_ARRAY)));
  11.   return append;
  12. }

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

  1. public Append dropSequence(long timestamp) {
  2.   byte[] key = SchemaUtil.getSequenceKey(this.key.getTenantId(), this.key.getSchemaName(), this.key.getSequenceName());
  3.   Append append = new Append(key);
  4.   append.setAttribute(SequenceRegionObserver.OPERATION_ATTRIB, new byte[] {(byte)SequenceRegionObserver.Op.DROP_SEQUENCE.ordinal()});
  5.   if (timestamp != HConstants.LATEST_TIMESTAMP) {
  6.     append.setAttribute(SequenceRegionObserver.MAX_TIMERANGE_ATTRIB, Bytes.toBytes(timestamp));
  7.   }
  8.   Map<byte[], List<KeyValue>> familyMap = append.getFamilyMap();
  9.   familyMap.put(PhoenixDatabaseMetaData.SEQUENCE_FAMILY_BYTES, Arrays.<KeyValue>asList(
  10.       KeyValueUtil.newKeyValue(key, PhoenixDatabaseMetaData.SEQUENCE_FAMILY_BYTES, QueryConstants.EMPTY_COLUMN_BYTES, timestamp, ByteUtil.EMPTY_BYTE_ARRAY)));
  11.   return append;
  12. }

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

  1. private Append newReturn(SequenceValue value) {
  2.   byte[] key = SchemaUtil.getSequenceKey(this.key.getTenantId(), this.key.getSchemaName(), this.key.getSequenceName());
  3.   Append append = new Append(key);
  4.   byte[] opBuf = new byte[] {(byte)SequenceRegionObserver.Op.RETURN_SEQUENCE.ordinal()};
  5.   append.setAttribute(SequenceRegionObserver.OPERATION_ATTRIB, opBuf);
  6.   append.setAttribute(SequenceRegionObserver.CURRENT_VALUE_ATTRIB, PDataType.LONG.toBytes(value.nextValue));
  7.   Map<byte[], List<KeyValue>> familyMap = append.getFamilyMap();
  8.   familyMap.put(PhoenixDatabaseMetaData.SEQUENCE_FAMILY_BYTES, Arrays.<KeyValue>asList(
  9.       KeyValueUtil.newKeyValue(key, PhoenixDatabaseMetaData.SEQUENCE_FAMILY_BYTES, PhoenixDatabaseMetaData.CURRENT_VALUE_BYTES, value.timestamp, PDataType.LONG.toBytes(value.currentValue))
  10.       ));
  11.   return append;
  12. }

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

  1. private Append newReturn(SequenceValue value) {
  2.   byte[] key = this.key.getKey();
  3.   Append append = new Append(key);
  4.   byte[] opBuf = new byte[] {(byte)MetaOp.RETURN_SEQUENCE.ordinal()};
  5.   append.setAttribute(SequenceRegionObserver.OPERATION_ATTRIB, opBuf);
  6.   append.setAttribute(SequenceRegionObserver.CURRENT_VALUE_ATTRIB, PLong.INSTANCE.toBytes(value.nextValue));
  7.   Map<byte[], List<Cell>> familyMap = append.getFamilyCellMap();
  8.   familyMap.put(PhoenixDatabaseMetaData.SYSTEM_SEQUENCE_FAMILY_BYTES, Arrays.<Cell>asList(
  9.       PhoenixKeyValueUtil.newKeyValue(key, PhoenixDatabaseMetaData.SYSTEM_SEQUENCE_FAMILY_BYTES, PhoenixDatabaseMetaData.CURRENT_VALUE_BYTES, value.timestamp, PLong.INSTANCE.toBytes(value.currentValue)),
  10.       PhoenixKeyValueUtil.newKeyValue(key, PhoenixDatabaseMetaData.SYSTEM_SEQUENCE_FAMILY_BYTES, PhoenixDatabaseMetaData.LIMIT_REACHED_FLAG_BYTES, value.timestamp, PBoolean.INSTANCE.toBytes(value.limitReached))
  11.       ));
  12.   return append;
  13. }

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

  1. public Append createSequence(long startWith, long incrementBy, int cacheSize, long timestamp) {
  2.   byte[] key = SchemaUtil.getSequenceKey(this.key.getTenantId(), this.key.getSchemaName(), this.key.getSequenceName());
  3.   Append append = new Append(key);
  4.   append.setAttribute(SequenceRegionObserver.OPERATION_ATTRIB, new byte[] {(byte)SequenceRegionObserver.Op.CREATE_SEQUENCE.ordinal()});
  5.   if (timestamp != HConstants.LATEST_TIMESTAMP) {
  6.     append.setAttribute(SequenceRegionObserver.MAX_TIMERANGE_ATTRIB, Bytes.toBytes(timestamp));
  7.   }
  8.   Map<byte[], List<KeyValue>> familyMap = append.getFamilyMap();
  9.   byte[] startWithBuf = PDataType.LONG.toBytes(startWith);
  10.   familyMap.put(PhoenixDatabaseMetaData.SEQUENCE_FAMILY_BYTES, Arrays.<KeyValue>asList(
  11.       KeyValueUtil.newKeyValue(key, PhoenixDatabaseMetaData.SEQUENCE_FAMILY_BYTES, QueryConstants.EMPTY_COLUMN_BYTES, timestamp, ByteUtil.EMPTY_BYTE_ARRAY),
  12.       KeyValueUtil.newKeyValue(key, PhoenixDatabaseMetaData.SEQUENCE_FAMILY_BYTES, PhoenixDatabaseMetaData.CURRENT_VALUE_BYTES, timestamp, startWithBuf),
  13.       KeyValueUtil.newKeyValue(key, PhoenixDatabaseMetaData.SEQUENCE_FAMILY_BYTES, PhoenixDatabaseMetaData.START_WITH_BYTES, timestamp, startWithBuf),
  14.       KeyValueUtil.newKeyValue(key, PhoenixDatabaseMetaData.SEQUENCE_FAMILY_BYTES, PhoenixDatabaseMetaData.INCREMENT_BY_BYTES, timestamp, PDataType.LONG.toBytes(incrementBy)),
  15.       KeyValueUtil.newKeyValue(key, PhoenixDatabaseMetaData.SEQUENCE_FAMILY_BYTES, PhoenixDatabaseMetaData.CACHE_SIZE_BYTES, timestamp, PDataType.INTEGER.toBytes(cacheSize))
  16.       ));
  17.   return append;
  18. }

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

  1. public Append createSequence(long startWith, long incrementBy, long cacheSize, long timestamp, long minValue, long maxValue, boolean cycle) {
  2.   byte[] key = this.key.getKey();
  3.   Append append = new Append(key);
  4.   append.setAttribute(SequenceRegionObserver.OPERATION_ATTRIB, new byte[] {(byte)MetaOp.CREATE_SEQUENCE.ordinal()});
  5.   if (timestamp != HConstants.LATEST_TIMESTAMP) {
  6.     append.setAttribute(SequenceRegionObserver.MAX_TIMERANGE_ATTRIB, Bytes.toBytes(timestamp));
  7.   }
  8.   Map<byte[], List<Cell>> familyMap = append.getFamilyCellMap();
  9.   byte[] startWithBuf = PLong.INSTANCE.toBytes(startWith);
  10.   familyMap.put(PhoenixDatabaseMetaData.SYSTEM_SEQUENCE_FAMILY_BYTES, Arrays.<Cell>asList(
  11.       PhoenixKeyValueUtil.newKeyValue(key, PhoenixDatabaseMetaData.SYSTEM_SEQUENCE_FAMILY_BYTES, QueryConstants.EMPTY_COLUMN_BYTES, timestamp, ByteUtil.EMPTY_BYTE_ARRAY),
  12.       PhoenixKeyValueUtil.newKeyValue(key, PhoenixDatabaseMetaData.SYSTEM_SEQUENCE_FAMILY_BYTES, PhoenixDatabaseMetaData.CURRENT_VALUE_BYTES, timestamp, startWithBuf),
  13.       PhoenixKeyValueUtil.newKeyValue(key, PhoenixDatabaseMetaData.SYSTEM_SEQUENCE_FAMILY_BYTES, PhoenixDatabaseMetaData.START_WITH_BYTES, timestamp, startWithBuf),
  14.       PhoenixKeyValueUtil.newKeyValue(key, PhoenixDatabaseMetaData.SYSTEM_SEQUENCE_FAMILY_BYTES, PhoenixDatabaseMetaData.INCREMENT_BY_BYTES, timestamp, PLong.INSTANCE.toBytes(incrementBy)),
  15.       PhoenixKeyValueUtil.newKeyValue(key, PhoenixDatabaseMetaData.SYSTEM_SEQUENCE_FAMILY_BYTES, PhoenixDatabaseMetaData.CACHE_SIZE_BYTES, timestamp, PLong.INSTANCE.toBytes(cacheSize)),
  16.       PhoenixKeyValueUtil.newKeyValue(key, PhoenixDatabaseMetaData.SYSTEM_SEQUENCE_FAMILY_BYTES, PhoenixDatabaseMetaData.MIN_VALUE_BYTES, timestamp, PLong.INSTANCE.toBytes(minValue)),
  17.       PhoenixKeyValueUtil.newKeyValue(key, PhoenixDatabaseMetaData.SYSTEM_SEQUENCE_FAMILY_BYTES, PhoenixDatabaseMetaData.MAX_VALUE_BYTES, timestamp, PLong.INSTANCE.toBytes(maxValue)),
  18.       PhoenixKeyValueUtil.newKeyValue(key, PhoenixDatabaseMetaData.SYSTEM_SEQUENCE_FAMILY_BYTES, PhoenixDatabaseMetaData.CYCLE_FLAG_BYTES, timestamp, PBoolean.INSTANCE.toBytes(cycle)),
  19.       PhoenixKeyValueUtil.newKeyValue(key, PhoenixDatabaseMetaData.SYSTEM_SEQUENCE_FAMILY_BYTES, PhoenixDatabaseMetaData.LIMIT_REACHED_FLAG_BYTES, timestamp, PDataType.FALSE_BYTES)
  20.       ));
  21.   return append;
  22. }

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

  1. /**
  2.  * @param returnResults
  3.  *          True (default) if the append operation should return the results.
  4.  *          A client that is not interested in the result can save network
  5.  *          bandwidth setting this to false.
  6.  */
  7. public void setReturnResults(boolean returnResults) {
  8.  setAttribute(RETURN_RESULTS, Bytes.toBytes(returnResults));
  9. }

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

  1. public Append dropSequence(long timestamp) {
  2.   byte[] key =  this.key.getKey();
  3.   Append append = new Append(key);
  4.   append.setAttribute(SequenceRegionObserver.OPERATION_ATTRIB, new byte[] {(byte)MetaOp.DROP_SEQUENCE.ordinal()});
  5.   if (timestamp != HConstants.LATEST_TIMESTAMP) {
  6.     append.setAttribute(SequenceRegionObserver.MAX_TIMERANGE_ATTRIB, Bytes.toBytes(timestamp));
  7.   }
  8.   Map<byte[], List<Cell>> familyMap = append.getFamilyCellMap();
  9.   familyMap.put(PhoenixDatabaseMetaData.SYSTEM_SEQUENCE_FAMILY_BYTES, Arrays.<Cell>asList(
  10.       PhoenixKeyValueUtil.newKeyValue(key, PhoenixDatabaseMetaData.SYSTEM_SEQUENCE_FAMILY_BYTES, QueryConstants.EMPTY_COLUMN_BYTES, timestamp, ByteUtil.EMPTY_BYTE_ARRAY)));
  11.   return append;
  12. }

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

  1. public Append dropSequence(long timestamp) {
  2.   byte[] key =  this.key.getKey();
  3.   Append append = new Append(key);
  4.   append.setAttribute(SequenceRegionObserver.OPERATION_ATTRIB, new byte[] {(byte)MetaOp.DROP_SEQUENCE.ordinal()});
  5.   if (timestamp != HConstants.LATEST_TIMESTAMP) {
  6.     append.setAttribute(SequenceRegionObserver.MAX_TIMERANGE_ATTRIB, Bytes.toBytes(timestamp));
  7.   }
  8.   Map<byte[], List<Cell>> familyMap = append.getFamilyCellMap();
  9.   familyMap.put(PhoenixDatabaseMetaData.SYSTEM_SEQUENCE_FAMILY_BYTES, Arrays.<Cell>asList(
  10.       PhoenixKeyValueUtil.newKeyValue(key, PhoenixDatabaseMetaData.SYSTEM_SEQUENCE_FAMILY_BYTES, QueryConstants.EMPTY_COLUMN_BYTES, timestamp, ByteUtil.EMPTY_BYTE_ARRAY)));
  11.   return append;
  12. }

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

  1. /**
  2.  * Copy constructor
  3.  * @param a
  4.  */
  5. public Append(Append a) {
  6.  this.row = a.getRow();
  7.  this.ts = a.getTimeStamp();
  8.  this.familyMap.putAll(a.getFamilyCellMap());
  9.  for (Map.Entry<String, byte[]> entry : a.getAttributesMap().entrySet()) {
  10.   this.setAttribute(entry.getKey(), entry.getValue());
  11.  }
  12. }

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

  1. private Append newReturn(SequenceValue value) {
  2.   byte[] key = this.key.getKey();
  3.   Append append = new Append(key);
  4.   byte[] opBuf = new byte[] {(byte)MetaOp.RETURN_SEQUENCE.ordinal()};
  5.   append.setAttribute(SequenceRegionObserver.OPERATION_ATTRIB, opBuf);
  6.   append.setAttribute(SequenceRegionObserver.CURRENT_VALUE_ATTRIB, PLong.INSTANCE.toBytes(value.nextValue));
  7.   Map<byte[], List<Cell>> familyMap = append.getFamilyCellMap();
  8.   familyMap.put(PhoenixDatabaseMetaData.SYSTEM_SEQUENCE_FAMILY_BYTES, Arrays.<Cell>asList(
  9.       PhoenixKeyValueUtil.newKeyValue(key, PhoenixDatabaseMetaData.SYSTEM_SEQUENCE_FAMILY_BYTES, PhoenixDatabaseMetaData.CURRENT_VALUE_BYTES, value.timestamp, PLong.INSTANCE.toBytes(value.currentValue)),
  10.       PhoenixKeyValueUtil.newKeyValue(key, PhoenixDatabaseMetaData.SYSTEM_SEQUENCE_FAMILY_BYTES, PhoenixDatabaseMetaData.LIMIT_REACHED_FLAG_BYTES, value.timestamp, PBoolean.INSTANCE.toBytes(value.limitReached))
  11.       ));
  12.   return append;
  13. }

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

  1. private Append newReturn(SequenceValue value) {
  2.   byte[] key = this.key.getKey();
  3.   Append append = new Append(key);
  4.   byte[] opBuf = new byte[] {(byte)MetaOp.RETURN_SEQUENCE.ordinal()};
  5.   append.setAttribute(SequenceRegionObserver.OPERATION_ATTRIB, opBuf);
  6.   append.setAttribute(SequenceRegionObserver.CURRENT_VALUE_ATTRIB, PLong.INSTANCE.toBytes(value.nextValue));
  7.   Map<byte[], List<Cell>> familyMap = append.getFamilyCellMap();
  8.   familyMap.put(PhoenixDatabaseMetaData.SYSTEM_SEQUENCE_FAMILY_BYTES, Arrays.<Cell>asList(
  9.       PhoenixKeyValueUtil.newKeyValue(key, PhoenixDatabaseMetaData.SYSTEM_SEQUENCE_FAMILY_BYTES, PhoenixDatabaseMetaData.CURRENT_VALUE_BYTES, value.timestamp, PLong.INSTANCE.toBytes(value.currentValue)),
  10.       PhoenixKeyValueUtil.newKeyValue(key, PhoenixDatabaseMetaData.SYSTEM_SEQUENCE_FAMILY_BYTES, PhoenixDatabaseMetaData.LIMIT_REACHED_FLAG_BYTES, value.timestamp, PBoolean.INSTANCE.toBytes(value.limitReached))
  11.       ));
  12.   return append;
  13. }

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

  1. public Append createSequence(long startWith, long incrementBy, long cacheSize, long timestamp, long minValue, long maxValue, boolean cycle) {
  2.   byte[] key = this.key.getKey();
  3.   Append append = new Append(key);
  4.   append.setAttribute(SequenceRegionObserver.OPERATION_ATTRIB, new byte[] {(byte)MetaOp.CREATE_SEQUENCE.ordinal()});
  5.   if (timestamp != HConstants.LATEST_TIMESTAMP) {
  6.     append.setAttribute(SequenceRegionObserver.MAX_TIMERANGE_ATTRIB, Bytes.toBytes(timestamp));
  7.   }
  8.   Map<byte[], List<Cell>> familyMap = append.getFamilyCellMap();
  9.   byte[] startWithBuf = PLong.INSTANCE.toBytes(startWith);
  10.   familyMap.put(PhoenixDatabaseMetaData.SYSTEM_SEQUENCE_FAMILY_BYTES, Arrays.<Cell>asList(
  11.       PhoenixKeyValueUtil.newKeyValue(key, PhoenixDatabaseMetaData.SYSTEM_SEQUENCE_FAMILY_BYTES, QueryConstants.EMPTY_COLUMN_BYTES, timestamp, ByteUtil.EMPTY_BYTE_ARRAY),
  12.       PhoenixKeyValueUtil.newKeyValue(key, PhoenixDatabaseMetaData.SYSTEM_SEQUENCE_FAMILY_BYTES, PhoenixDatabaseMetaData.CURRENT_VALUE_BYTES, timestamp, startWithBuf),
  13.       PhoenixKeyValueUtil.newKeyValue(key, PhoenixDatabaseMetaData.SYSTEM_SEQUENCE_FAMILY_BYTES, PhoenixDatabaseMetaData.START_WITH_BYTES, timestamp, startWithBuf),
  14.       PhoenixKeyValueUtil.newKeyValue(key, PhoenixDatabaseMetaData.SYSTEM_SEQUENCE_FAMILY_BYTES, PhoenixDatabaseMetaData.INCREMENT_BY_BYTES, timestamp, PLong.INSTANCE.toBytes(incrementBy)),
  15.       PhoenixKeyValueUtil.newKeyValue(key, PhoenixDatabaseMetaData.SYSTEM_SEQUENCE_FAMILY_BYTES, PhoenixDatabaseMetaData.CACHE_SIZE_BYTES, timestamp, PLong.INSTANCE.toBytes(cacheSize)),
  16.       PhoenixKeyValueUtil.newKeyValue(key, PhoenixDatabaseMetaData.SYSTEM_SEQUENCE_FAMILY_BYTES, PhoenixDatabaseMetaData.MIN_VALUE_BYTES, timestamp, PLong.INSTANCE.toBytes(minValue)),
  17.       PhoenixKeyValueUtil.newKeyValue(key, PhoenixDatabaseMetaData.SYSTEM_SEQUENCE_FAMILY_BYTES, PhoenixDatabaseMetaData.MAX_VALUE_BYTES, timestamp, PLong.INSTANCE.toBytes(maxValue)),
  18.       PhoenixKeyValueUtil.newKeyValue(key, PhoenixDatabaseMetaData.SYSTEM_SEQUENCE_FAMILY_BYTES, PhoenixDatabaseMetaData.CYCLE_FLAG_BYTES, timestamp, PBoolean.INSTANCE.toBytes(cycle)),
  19.       PhoenixKeyValueUtil.newKeyValue(key, PhoenixDatabaseMetaData.SYSTEM_SEQUENCE_FAMILY_BYTES, PhoenixDatabaseMetaData.LIMIT_REACHED_FLAG_BYTES, timestamp, PDataType.FALSE_BYTES)
  20.       ));
  21.   return append;
  22. }

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

  1. public Append createSequence(long startWith, long incrementBy, long cacheSize, long timestamp, long minValue, long maxValue, boolean cycle) {
  2.   byte[] key = this.key.getKey();
  3.   Append append = new Append(key);
  4.   append.setAttribute(SequenceRegionObserver.OPERATION_ATTRIB, new byte[] {(byte)MetaOp.CREATE_SEQUENCE.ordinal()});
  5.   if (timestamp != HConstants.LATEST_TIMESTAMP) {
  6.     append.setAttribute(SequenceRegionObserver.MAX_TIMERANGE_ATTRIB, Bytes.toBytes(timestamp));
  7.   }
  8.   Map<byte[], List<Cell>> familyMap = append.getFamilyCellMap();
  9.   byte[] startWithBuf = PLong.INSTANCE.toBytes(startWith);
  10.   familyMap.put(PhoenixDatabaseMetaData.SYSTEM_SEQUENCE_FAMILY_BYTES, Arrays.<Cell>asList(
  11.       PhoenixKeyValueUtil.newKeyValue(key, PhoenixDatabaseMetaData.SYSTEM_SEQUENCE_FAMILY_BYTES, QueryConstants.EMPTY_COLUMN_BYTES, timestamp, ByteUtil.EMPTY_BYTE_ARRAY),
  12.       PhoenixKeyValueUtil.newKeyValue(key, PhoenixDatabaseMetaData.SYSTEM_SEQUENCE_FAMILY_BYTES, PhoenixDatabaseMetaData.CURRENT_VALUE_BYTES, timestamp, startWithBuf),
  13.       PhoenixKeyValueUtil.newKeyValue(key, PhoenixDatabaseMetaData.SYSTEM_SEQUENCE_FAMILY_BYTES, PhoenixDatabaseMetaData.START_WITH_BYTES, timestamp, startWithBuf),
  14.       PhoenixKeyValueUtil.newKeyValue(key, PhoenixDatabaseMetaData.SYSTEM_SEQUENCE_FAMILY_BYTES, PhoenixDatabaseMetaData.INCREMENT_BY_BYTES, timestamp, PLong.INSTANCE.toBytes(incrementBy)),
  15.       PhoenixKeyValueUtil.newKeyValue(key, PhoenixDatabaseMetaData.SYSTEM_SEQUENCE_FAMILY_BYTES, PhoenixDatabaseMetaData.CACHE_SIZE_BYTES, timestamp, PLong.INSTANCE.toBytes(cacheSize)),
  16.       PhoenixKeyValueUtil.newKeyValue(key, PhoenixDatabaseMetaData.SYSTEM_SEQUENCE_FAMILY_BYTES, PhoenixDatabaseMetaData.MIN_VALUE_BYTES, timestamp, PLong.INSTANCE.toBytes(minValue)),
  17.       PhoenixKeyValueUtil.newKeyValue(key, PhoenixDatabaseMetaData.SYSTEM_SEQUENCE_FAMILY_BYTES, PhoenixDatabaseMetaData.MAX_VALUE_BYTES, timestamp, PLong.INSTANCE.toBytes(maxValue)),
  18.       PhoenixKeyValueUtil.newKeyValue(key, PhoenixDatabaseMetaData.SYSTEM_SEQUENCE_FAMILY_BYTES, PhoenixDatabaseMetaData.CYCLE_FLAG_BYTES, timestamp, PBoolean.INSTANCE.toBytes(cycle)),
  19.       PhoenixKeyValueUtil.newKeyValue(key, PhoenixDatabaseMetaData.SYSTEM_SEQUENCE_FAMILY_BYTES, PhoenixDatabaseMetaData.LIMIT_REACHED_FLAG_BYTES, timestamp, PDataType.FALSE_BYTES)
  20.       ));
  21.   return append;
  22. }

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

  1. @Override
  2. public Result preAppend(ObserverContext<RegionCoprocessorEnvironment> c, Append append)
  3.   throws IOException {
  4.  User user = getActiveUser();
  5.  checkForReservedTagPresence(user, append);
  6.  // Require WRITE permission to the table, CF, and the KV to be appended
  7.  RegionCoprocessorEnvironment env = c.getEnvironment();
  8.  Map<byte[],? extends Collection<Cell>> families = append.getFamilyCellMap();
  9.  AuthResult authResult = permissionGranted(OpType.APPEND, user, env, families, Action.WRITE);
  10.  logResult(authResult);
  11.  if (!authResult.isAllowed()) {
  12.   if (cellFeaturesEnabled && !compatibleEarlyTermination) {
  13.    append.setAttribute(CHECK_COVERING_PERM, TRUE);
  14.   } else if (authorizationEnabled)  {
  15.    throw new AccessDeniedException("Insufficient permissions " +
  16.     authResult.toContextString());
  17.   }
  18.  }
  19.  byte[] bytes = append.getAttribute(AccessControlConstants.OP_ATTRIBUTE_ACL);
  20.  if (bytes != null) {
  21.   if (cellFeaturesEnabled) {
  22.    addCellPermissions(bytes, append.getFamilyCellMap());
  23.   } else {
  24.    throw new DoNotRetryIOException("Cell ACLs cannot be persisted");
  25.   }
  26.  }
  27.  return null;
  28. }

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

  1. append.setAttribute("visibility", Bytes.toBytes("tag2"));
  2. table.append(append);
  3. TestCoprocessorForTags.checkTagPresence = true;
  4. append = new Append(row4);
  5. append.add(new KeyValue(row4, f, q, 1234L, v));
  6. append.setAttribute("visibility", Bytes.toBytes("tag2"));
  7. table.append(append);
  8. TestCoprocessorForTags.checkTagPresence = true;

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

  1. append.setAttribute(attribute.getName(), attribute.getValue().toByteArray());

内容来源于网络，如有侵权，请联系作者删除！

Append

相关文章

    查看更多

    热门标签

    更多
    JavaquerypythonNode开发语言requestUtil数据库Table后端算法LoggerMessageElementParser

    最新文章

    更多
    • 蜀ICP备13028337号-1 大数据知识库 https://www.saoniuhuo.com © All rights reserved
    • 本站内容来源互联网,如果侵犯您的权益请联系我们删除, 联系方式：448109455@qq.com