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

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

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

Append.getTimeRange介绍

[英]Gets the TimeRange used for this append.
[中]获取用于此附加的时间范围。

代码示例

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

  1. /**
  2.  * Copy constructor
  3.  * @param appendToCopy append to copy
  4.  */
  5. public Append(Append appendToCopy) {
  6.  super(appendToCopy);
  7.  this.tr = appendToCopy.getTimeRange();
  8. }

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

  1. @Override
  2.  public Result preAppend(final ObserverContext<RegionCoprocessorEnvironment> e,
  3.    final Append append) throws IOException {
  4.   NavigableMap<byte [], List<Cell>> map = append.getFamilyCellMap();
  5.   for (Map.Entry<byte [], List<Cell>> entry : map.entrySet()) {
  6.    for (Cell cell : entry.getValue()) {
  7.     String appendStr = Bytes.toString(cell.getValueArray(), cell.getValueOffset(),
  8.       cell.getValueLength());
  9.     if (appendStr.equals("b")) {
  10.      tr10 = append.getTimeRange();
  11.     } else if (appendStr.equals("c") && !append.getTimeRange().isAllTime()) {
  12.      tr2 = append.getTimeRange();
  13.     }
  14.    }
  15.   }
  16.   return null;
  17.  }
  18. }

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

  1. break;
  2. case APPEND:
  3.  tr = ((Append)mutation).getTimeRange();
  4.  break;
  5. default:

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

  1. public static MutationProto toMutationNoData(final MutationType type, final Mutation mutation,
  2.   final MutationProto.Builder builder, long nonce) throws IOException {
  3.  getMutationBuilderAndSetCommonFields(type, mutation, builder);
  4.  builder.setAssociatedCellCount(mutation.size());
  5.  if (mutation instanceof Increment) {
  6.   builder.setTimeRange(ProtobufUtil.toTimeRange(((Increment) mutation).getTimeRange()));
  7.  }
  8.  if (mutation instanceof Append) {
  9.   builder.setTimeRange(ProtobufUtil.toTimeRange(((Append) mutation).getTimeRange()));
  10.  }
  11.  if (nonce != HConstants.NO_NONCE) {
  12.   builder.setNonce(nonce);
  13.  }
  14.  return builder.build();
  15. }

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

  1. /**
  2.  * Copy constructor
  3.  * @param appendToCopy append to copy
  4.  */
  5. public Append(Append appendToCopy) {
  6.  super(appendToCopy);
  7.  this.tr = appendToCopy.getTimeRange();
  8. }

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

  1. public static MutationProto toMutationNoData(final MutationType type, final Mutation mutation,
  2.   final MutationProto.Builder builder, long nonce) throws IOException {
  3.  getMutationBuilderAndSetCommonFields(type, mutation, builder);
  4.  builder.setAssociatedCellCount(mutation.size());
  5.  if (mutation instanceof Increment) {
  6.   builder.setTimeRange(toTimeRange(((Increment)mutation).getTimeRange()));
  7.  }
  8.  if (mutation instanceof Append) {
  9.   builder.setTimeRange(toTimeRange(((Append)mutation).getTimeRange()));
  10.  }
  11.  if (nonce != HConstants.NO_NONCE) {
  12.   builder.setNonce(nonce);
  13.  }
  14.  return builder.build();
  15. }

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

  1. private void assertEquals(Mutation origin, Mutation clone) {
  2.  Assert.assertEquals(origin.getFamilyCellMap().size(), clone.getFamilyCellMap().size());
  3.  for (byte[] family : origin.getFamilyCellMap().keySet()) {
  4.   List<Cell> originCells = origin.getCellList(family);
  5.   List<Cell> cloneCells = clone.getCellList(family);
  6.   Assert.assertEquals(originCells.size(), cloneCells.size());
  7.   for (int i = 0; i != cloneCells.size(); ++i) {
  8.    Cell originCell = originCells.get(i);
  9.    Cell cloneCell = cloneCells.get(i);
  10.    assertTrue(CellUtil.equals(originCell, cloneCell));
  11.    assertTrue(CellUtil.matchingValue(originCell, cloneCell));
  12.   }
  13.  }
  14.  Assert.assertEquals(origin.getAttributesMap().size(), clone.getAttributesMap().size());
  15.  for (String name : origin.getAttributesMap().keySet()) {
  16.   byte[] originValue = origin.getAttributesMap().get(name);
  17.   byte[] cloneValue = clone.getAttributesMap().get(name);
  18.   assertTrue(Bytes.equals(originValue, cloneValue));
  19.  }
  20.  Assert.assertEquals(origin.getTimestamp(), clone.getTimestamp());
  21.  Assert.assertEquals(origin.getPriority(), clone.getPriority());
  22.  if (origin instanceof Append) {
  23.   assertEquals(((Append)origin).getTimeRange(), ((Append)clone).getTimeRange());
  24.  }
  25.  if (origin instanceof Increment) {
  26.   assertEquals(((Increment)origin).getTimeRange(), ((Increment)clone).getTimeRange());
  27.  }
  28. }

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

  1. builder.setTimeRange(ProtobufUtil.toTimeRange(((Append) mutation).getTimeRange()));

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

  1. builder.setTimeRange(toTimeRange(((Append) mutation).getTimeRange()));

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

  1. mutateBuilder.setTimeRange(ProtobufUtil.toTimeRange(append.getTimeRange()));
  2. assertEquals(mutateBuilder.build(), ProtobufUtil.toMutation(MutationType.APPEND, append));

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

  1. @Override
  2. public Result preAppendAfterRowLock(final ObserverContext<RegionCoprocessorEnvironment> c,
  3.   final Append append) throws IOException {
  4.  if (append.getAttribute(CHECK_COVERING_PERM) != null) {
  5.   // We had failure with table, cf and q perm checks and now giving a chance for cell
  6.   // perm check
  7.   TableName table = c.getEnvironment().getRegion().getRegionInfo().getTable();
  8.   AuthResult authResult = null;
  9.   User user = getActiveUser(c);
  10.   if (checkCoveringPermission(user, OpType.APPEND, c.getEnvironment(), append.getRow(),
  11.     append.getFamilyCellMap(), append.getTimeRange().getMax(), Action.WRITE)) {
  12.    authResult = AuthResult.allow(OpType.APPEND.toString(),
  13.      "Covering cell set", user, Action.WRITE, table, append.getFamilyCellMap());
  14.   } else {
  15.    authResult = AuthResult.deny(OpType.APPEND.toString(),
  16.      "Covering cell set", user, Action.WRITE, table, append.getFamilyCellMap());
  17.   }
  18.   AccessChecker.logResult(authResult);
  19.   if (authorizationEnabled && !authResult.isAllowed()) {
  20.    throw new AccessDeniedException("Insufficient permissions " +
  21.     authResult.toContextString());
  22.   }
  23.  }
  24.  return null;
  25. }

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

  1. mutateBuilder.setTimeRange(ProtobufUtil.toTimeRange(append.getTimeRange()));
  2. assertEquals(mutateBuilder.build(), ProtobufUtil.toMutation(MutationType.APPEND, append));

代码示例来源：origin: com.aliyun.hbase/alihbase-client

  1. /**
  2.  * Copy constructor
  3.  * @param appendToCopy append to copy
  4.  */
  5. public Append(Append appendToCopy) {
  6.  super(appendToCopy);
  7.  this.tr = appendToCopy.getTimeRange();
  8. }

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

  1. public static MutationProto toMutationNoData(final MutationType type, final Mutation mutation,
  2.   final MutationProto.Builder builder, long nonce) throws IOException {
  3.  getMutationBuilderAndSetCommonFields(type, mutation, builder);
  4.  builder.setAssociatedCellCount(mutation.size());
  5.  if (mutation instanceof Increment) {
  6.   builder.setTimeRange(ProtobufUtil.toTimeRange(((Increment) mutation).getTimeRange()));
  7.  }
  8.  if (mutation instanceof Append) {
  9.   builder.setTimeRange(ProtobufUtil.toTimeRange(((Append) mutation).getTimeRange()));
  10.  }
  11.  if (nonce != HConstants.NO_NONCE) {
  12.   builder.setNonce(nonce);
  13.  }
  14.  return builder.build();
  15. }

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

  1. public static MutationProto toMutationNoData(final MutationType type, final Mutation mutation,
  2.   final MutationProto.Builder builder, long nonce) throws IOException {
  3.  getMutationBuilderAndSetCommonFields(type, mutation, builder);
  4.  builder.setAssociatedCellCount(mutation.size());
  5.  if (mutation instanceof Increment) {
  6.   builder.setTimeRange(toTimeRange(((Increment)mutation).getTimeRange()));
  7.  }
  8.  if (mutation instanceof Append) {
  9.   builder.setTimeRange(toTimeRange(((Append)mutation).getTimeRange()));
  10.  }
  11.  if (nonce != HConstants.NO_NONCE) {
  12.   builder.setNonce(nonce);
  13.  }
  14.  return builder.build();
  15. }

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

  1. private void assertEquals(Mutation origin, Mutation clone) {
  2.  Assert.assertEquals(origin.getFamilyCellMap().size(), clone.getFamilyCellMap().size());
  3.  for (byte[] family : origin.getFamilyCellMap().keySet()) {
  4.   List<Cell> originCells = origin.getCellList(family);
  5.   List<Cell> cloneCells = clone.getCellList(family);
  6.   Assert.assertEquals(originCells.size(), cloneCells.size());
  7.   for (int i = 0; i != cloneCells.size(); ++i) {
  8.    Cell originCell = originCells.get(i);
  9.    Cell cloneCell = cloneCells.get(i);
  10.    assertTrue(CellUtil.equals(originCell, cloneCell));
  11.    assertTrue(CellUtil.matchingValue(originCell, cloneCell));
  12.   }
  13.  }
  14.  Assert.assertEquals(origin.getAttributesMap().size(), clone.getAttributesMap().size());
  15.  for (String name : origin.getAttributesMap().keySet()) {
  16.   byte[] originValue = origin.getAttributesMap().get(name);
  17.   byte[] cloneValue = clone.getAttributesMap().get(name);
  18.   assertTrue(Bytes.equals(originValue, cloneValue));
  19.  }
  20.  Assert.assertEquals(origin.getTimestamp(), clone.getTimestamp());
  21.  Assert.assertEquals(origin.getPriority(), clone.getPriority());
  22.  if (origin instanceof Append) {
  23.   assertEquals(((Append)origin).getTimeRange(), ((Append)clone).getTimeRange());
  24.  }
  25.  if (origin instanceof Increment) {
  26.   assertEquals(((Increment)origin).getTimeRange(), ((Increment)clone).getTimeRange());
  27.  }
  28. }

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

  1. builder.setTimeRange(toTimeRange(((Append) mutation).getTimeRange()));

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

  1. builder.setTimeRange(ProtobufUtil.toTimeRange(((Append) mutation).getTimeRange()));

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

  1. mutateBuilder.setTimeRange(ProtobufUtil.toTimeRange(append.getTimeRange()));
  2. assertEquals(mutateBuilder.build(), ProtobufUtil.toMutation(MutationType.APPEND, append));

代码示例来源：origin: com.aliyun.hbase/alihbase-client

  1. public static MutationProto toMutationNoData(final MutationType type, final Mutation mutation,
  2.   final MutationProto.Builder builder, long nonce) throws IOException {
  3.  getMutationBuilderAndSetCommonFields(type, mutation, builder);
  4.  builder.setAssociatedCellCount(mutation.size());
  5.  if (mutation instanceof Increment) {
  6.   builder.setTimeRange(toTimeRange(((Increment)mutation).getTimeRange()));
  7.  }
  8.  if (mutation instanceof Append) {
  9.   builder.setTimeRange(toTimeRange(((Append)mutation).getTimeRange()));
  10.  }
  11.  if (nonce != HConstants.NO_NONCE) {
  12.   builder.setNonce(nonce);
  13.  }
  14.  return builder.build();
  15. }

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

Append

相关文章

    查看更多

    热门标签

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

    最新文章

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