org.apache.hadoop.hbase.TableName.getNamespace()方法的使用及代码示例

x33g5p2x  于2022-01-29 转载在 其他  
字(9.0k)|赞(0)|评价(0)|浏览(258)

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

TableName.getNamespace介绍

暂无

代码示例

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

  1. public static TableName valueOf(byte[] namespace, byte[] qualifier) {
  2.  if (namespace == null || namespace.length < 1) {
  3.   namespace = NamespaceDescriptor.DEFAULT_NAMESPACE_NAME;
  4.  }
  5.  for (TableName tn : tableCache) {
  6.   if (Arrays.equals(tn.getQualifier(), qualifier) &&
  7.     Arrays.equals(tn.getNamespace(), namespace)) {
  8.    return tn;
  9.   }
  10.  }
  11.  return createTableNameIfNecessary(
  12.    ByteBuffer.wrap(namespace), ByteBuffer.wrap(qualifier));
  13. }

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

  1. private TableName validateNames(TableName expected, Names names) {
  2.  assertEquals(expected.getNameAsString(), names.nn);
  3.  assertArrayEquals(expected.getName(), names.nnb);
  4.  assertEquals(expected.getQualifierAsString(), names.tn);
  5.  assertArrayEquals(expected.getQualifier(), names.tnb);
  6.  assertEquals(expected.getNamespaceAsString(), names.ns);
  7.  assertArrayEquals(expected.getNamespace(), names.nsb);
  8.  return expected;
  9. }

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

  1. Collections.sort(rsGroupServers);
  2. rsGroupTables.sort((o1, o2) -> {
  3.  int compare = Bytes.compareTo(o1.getNamespace(), o2.getNamespace());
  4.  if (compare != 0)
  5.    return compare;

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

  1. /**
  2.  * Check that the object does not exist already. There are two reasons for creating the objects
  3.  * only once:
  4.  * 1) With 100K regions, the table names take ~20MB.
  5.  * 2) Equals becomes much faster as it's resolved with a reference and an int comparison.
  6.  */
  7. private static TableName createTableNameIfNecessary(ByteBuffer bns, ByteBuffer qns) {
  8.  for (TableName tn : tableCache) {
  9.   if (Bytes.equals(tn.getQualifier(), qns) && Bytes.equals(tn.getNamespace(), bns)) {
  10.    return tn;
  11.   }
  12.  }
  13.  TableName newTable = new TableName(bns, qns);
  14.  if (tableCache.add(newTable)) {  // Adds the specified element if it is not already present
  15.   return newTable;
  16.  }
  17.  // Someone else added it. Let's find it.
  18.  for (TableName tn : tableCache) {
  19.   if (Bytes.equals(tn.getQualifier(), qns) && Bytes.equals(tn.getNamespace(), bns)) {
  20.    return tn;
  21.   }
  22.  }
  23.  // this should never happen.
  24.  throw new IllegalStateException(newTable + " was supposed to be in the cache");
  25. }

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

  1. private TableName validateNames(TableName expected, Names names) {
  2.  assertEquals(expected.getNameAsString(), names.nn);
  3.  assertArrayEquals(expected.getName(), names.nnb);
  4.  assertEquals(expected.getQualifierAsString(), names.tn);
  5.  assertArrayEquals(expected.getQualifier(), names.tnb);
  6.  assertEquals(expected.getNamespaceAsString(), names.ns);
  7.  assertArrayEquals(expected.getNamespace(), names.nsb);
  8.  return expected;
  9. }

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

  1. @Override
  2. public WAL getWAL(RegionInfo region) throws IOException {
  3.  String group;
  4.  if (META_WAL_PROVIDER_ID.equals(this.providerId)) {
  5.   group = META_WAL_GROUP_NAME;
  6.  } else {
  7.   byte[] id;
  8.   byte[] namespace;
  9.   if (region != null) {
  10.    id = region.getEncodedNameAsBytes();
  11.    namespace = region.getTable().getNamespace();
  12.   } else {
  13.    id = HConstants.EMPTY_BYTE_ARRAY;
  14.    namespace = null;
  15.   }
  16.   group = strategy.group(id, namespace);
  17.  }
  18.  return getWAL(group);
  19. }

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

  1. private TableName validateNames(TableName expected, Names names) {
  2.  assertEquals(expected.getNameAsString(), names.nn);
  3.  assertArrayEquals(expected.getName(), names.nnb);
  4.  assertEquals(expected.getQualifierAsString(), names.tn);
  5.  assertArrayEquals(expected.getQualifier(), names.tnb);
  6.  assertEquals(expected.getNamespaceAsString(), names.ns);
  7.  assertArrayEquals(expected.getNamespace(), names.nsb);
  8.  return expected;
  9. }

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

  1. public static TTableName tableNameFromHBase(TableName table) {
  2.  TTableName tableName = new TTableName();
  3.  tableName.setNs(table.getNamespace());
  4.  tableName.setQualifier(table.getQualifier());
  5.  return tableName;
  6. }

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

  1. public static HBaseProtos.TableName toProtoTableName(TableName tableName) {
  2.  return HBaseProtos.TableName.newBuilder()
  3.    .setNamespace(ByteString.copyFrom(tableName.getNamespace()))
  4.    .setQualifier(ByteString.copyFrom(tableName.getQualifier())).build();
  5. }

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

  1. public static HBaseProtos.TableName toProtoTableName(TableName tableName) {
  2.  return HBaseProtos.TableName.newBuilder()
  3.    .setNamespace(UnsafeByteOperations.unsafeWrap(tableName.getNamespace()))
  4.    .setQualifier(UnsafeByteOperations.unsafeWrap(tableName.getQualifier())).build();
  5. }

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

  1. public static HBaseProtos.TableName toProtoTableName(TableName tableName) {
  2.  return HBaseProtos.TableName.newBuilder()
  3.    .setNamespace(ByteStringer.wrap(tableName.getNamespace()))
  4.    .setQualifier(ByteStringer.wrap(tableName.getQualifier())).build();
  5. }

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

  1. @Test
  2. public void testConvert() {
  3.  final TableName tableName = TableName.valueOf("ns1:" + name.getMethodName());
  4.  byte[] startKey = Bytes.toBytes("startKey");
  5.  byte[] endKey = Bytes.toBytes("endKey");
  6.  boolean split = false;
  7.  long regionId = System.currentTimeMillis();
  8.  int replicaId = 42;
  9.  HRegionInfo hri = new HRegionInfo(tableName, startKey, endKey, split,
  10.   regionId, replicaId);
  11.  // convert two times, compare
  12.  HRegionInfo convertedHri = HRegionInfo.convert(HRegionInfo.convert(hri));
  13.  assertEquals(hri, convertedHri);
  14.  // test convert RegionInfo without replicaId
  15.  RegionInfo info = RegionInfo.newBuilder()
  16.   .setTableName(HBaseProtos.TableName.newBuilder()
  17.    .setQualifier(UnsafeByteOperations.unsafeWrap(tableName.getQualifier()))
  18.    .setNamespace(UnsafeByteOperations.unsafeWrap(tableName.getNamespace()))
  19.    .build())
  20.   .setStartKey(UnsafeByteOperations.unsafeWrap(startKey))
  21.   .setEndKey(UnsafeByteOperations.unsafeWrap(endKey))
  22.   .setSplit(split)
  23.   .setRegionId(regionId)
  24.   .build();
  25.  convertedHri = HRegionInfo.convert(info);
  26.  HRegionInfo expectedHri = new HRegionInfo(tableName, startKey, endKey, split,
  27.   regionId, 0); // expecting default replicaId
  28.  assertEquals(expectedHri, convertedHri);
  29. }
  30. @Test

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

  1. .setTableName(HBaseProtos.TableName.newBuilder()
  2.  .setQualifier(UnsafeByteOperations.unsafeWrap(tableName.getQualifier()))
  3.  .setNamespace(UnsafeByteOperations.unsafeWrap(tableName.getNamespace()))
  4.  .build())
  5. .setStartKey(UnsafeByteOperations.unsafeWrap(startKey))

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

  1. public static HBaseProtos.TableName toProtoTableName(TableName tableName) {
  2.  return HBaseProtos.TableName.newBuilder()
  3.    .setNamespace(UnsafeByteOperations.unsafeWrap(tableName.getNamespace()))
  4.    .setQualifier(UnsafeByteOperations.unsafeWrap(tableName.getQualifier())).build();
  5. }

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

  1. public static TableProtos.TableName toProtoTableName(TableName tableName) {
  2.  return TableProtos.TableName.newBuilder()
  3.    .setNamespace(ByteStringer.wrap(tableName.getNamespace()))
  4.    .setQualifier(ByteStringer.wrap(tableName.getQualifier())).build();
  5. }

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

  1. public static HBaseProtos.TableName toProtoTableName(TableName tableName) {
  2.  return HBaseProtos.TableName.newBuilder()
  3.    .setNamespace(ByteString.copyFrom(tableName.getNamespace()))
  4.    .setQualifier(ByteString.copyFrom(tableName.getQualifier())).build();
  5. }

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

  1. private void getUserPermsFromUserDefinedAccessController(final List<UserPermission> userPermissions, Connection connection, AccessControlService.Interface service) {
  2.   RpcController controller = (RpcController) ((ClusterConnection)connection)
  3.       .getRpcControllerFactory().newController();
  4.   AccessControlProtos.GetUserPermissionsRequest.Builder builderTablePerms = AccessControlProtos.GetUserPermissionsRequest
  5.       .newBuilder();
  6.   builderTablePerms.setTableName(ProtobufUtil.toProtoTableName(tableName));
  7.   builderTablePerms.setType(AccessControlProtos.Permission.Type.Table);
  8.   AccessControlProtos.GetUserPermissionsRequest requestTablePerms = builderTablePerms.build();
  9.   callGetUserPermissionsRequest(userPermissions, service, requestTablePerms, controller);
  10.   AccessControlProtos.GetUserPermissionsRequest.Builder builderNamespacePerms = AccessControlProtos.GetUserPermissionsRequest
  11.       .newBuilder();
  12.   builderNamespacePerms.setNamespaceName(ByteString.copyFrom(tableName.getNamespace()));
  13.   builderNamespacePerms.setType(AccessControlProtos.Permission.Type.Namespace);
  14.   AccessControlProtos.GetUserPermissionsRequest requestNamespacePerms = builderNamespacePerms.build();
  15.   callGetUserPermissionsRequest(userPermissions, service, requestNamespacePerms, controller);
  16. }

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

  1. public static TableName valueOf(byte[] namespace, byte[] qualifier) {
  2.  if (namespace == null || namespace.length < 1) {
  3.   namespace = NamespaceDescriptor.DEFAULT_NAMESPACE_NAME;
  4.  }
  5.  for (TableName tn : tableCache) {
  6.   if (Arrays.equals(tn.getQualifier(), qualifier) &&
  7.     Arrays.equals(tn.getNamespace(), namespace)) {
  8.    return tn;
  9.   }
  10.  }
  11.  return createTableNameIfNecessary(
  12.    ByteBuffer.wrap(namespace), ByteBuffer.wrap(qualifier));
  13. }

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

  1. public static TableProtos.TableName toProtoTableName(TableName tableName) {
  2.  return TableProtos.TableName.newBuilder()
  3.    .setNamespace(ByteStringer.wrap(tableName.getNamespace()))
  4.    .setQualifier(ByteStringer.wrap(tableName.getQualifier())).build();
  5. }

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

  1. public static HBaseProtos.TableName toProtoTableName(TableName tableName) {
  2.  return HBaseProtos.TableName.newBuilder()
  3.    .setNamespace(ByteString.copyFrom(tableName.getNamespace()))
  4.    .setQualifier(ByteString.copyFrom(tableName.getQualifier())).build();
  5. }

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

tablename

相关文章

    查看更多

    热门标签

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

    最新文章

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