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

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

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

TableName.getNameWithNamespaceInclAsString介绍

[英]Ideally, getNameAsString should contain namespace within it, but if the namespace is default, it just returns the name. This method takes care of this corner case.
[中]理想情况下,getNameAsString应该包含名称空间,但如果名称空间是默认名称空间,则只返回名称。这种方法可以解决这个问题。

代码示例

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

  1. /**
  2. * @return a description of the operation
  3. */
  4. protected String getDescription() {
  5. return "Operation: " + getOperationType() + ", " + "Table Name: " +
  6. tableName.getNameWithNamespaceInclAsString() + ", procId: " + procId;
  7. }

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

  1. String getDescription() {
  2. return "Operation: " + getOperationType() + ", " + "Table Name: "
  3. + tableName.getNameWithNamespaceInclAsString();
  4. }

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

  1. @Override
  2. public boolean checkState(int tries) throws IOException {
  3. try {
  4. if (getAdmin().isTableAvailable(tableName)) {
  5. return true;
  6. }
  7. } catch (TableNotFoundException tnfe) {
  8. LOG.debug("Table " + tableName.getNameWithNamespaceInclAsString()
  9. + " was not enabled, sleeping. tries=" + tries);
  10. }
  11. return false;
  12. }
  13. });

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

  1. public String toContextString() {
  2. StringBuilder sb = new StringBuilder();
  3. String familiesString = toFamiliesString(families, family, qualifier);
  4. sb.append("(user=")
  5. .append(user != null ? user.getName() : "UNKNOWN")
  6. .append(", ");
  7. sb.append("scope=")
  8. .append(namespace != null ? namespace :
  9. table == null ? "GLOBAL" : table.getNameWithNamespaceInclAsString())
  10. .append(", ");
  11. if(namespace == null && familiesString.length() > 0) {
  12. sb.append("family=")
  13. .append(familiesString)
  14. .append(", ");
  15. }
  16. String paramsString = params.toString();
  17. if(paramsString.length() > 0) {
  18. sb.append("params=[")
  19. .append(paramsString)
  20. .append("],");
  21. }
  22. sb.append("action=")
  23. .append(action != null ? action.toString() : "")
  24. .append(")");
  25. return sb.toString();
  26. }

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

  1. @Override
  2. public String toString() {
  3. String familiesString = toFamiliesString(families, family, qualifier);
  4. String[] params = new String[] {
  5. namespace != null ? "namespace=" + namespace : null,
  6. tableName != null ? "table=" + tableName.getNameWithNamespaceInclAsString() : null,
  7. familiesString.length() > 0 ? "family=" + familiesString : null,
  8. extraParams.isEmpty() ? null : concatenateExtraParams()
  9. };
  10. return Joiner.on(",").skipNulls().join(params);
  11. }

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

  1. tableInfo.getRegionLocator().getName().getNameWithNamespaceInclAsString():
  2. tableInfo.getRegionLocator().getName().getNameAsString();
  3. allTableNames.add(tn);

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

  1. String tableName = table.getNameWithNamespaceInclAsString();
  2. List<Pair<byte[], List<String>>> familyHFilePathsList = bulkLoadHFileMap.get(tableName);
  3. if (familyHFilePathsList != null) {

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

  1. @Test
  2. public void testAccessControlClientUserPerms() throws Exception {
  3. final TableName tableName = TableName.valueOf(name.getMethodName());
  4. createTestTable(tableName);
  5. try {
  6. final String regex = tableName.getNameWithNamespaceInclAsString();
  7. User testUserPerms = User.createUserForTesting(conf, "testUserPerms", new String[0]);
  8. assertEquals(0, testUserPerms.runAs(getPrivilegedAction(regex)).size());
  9. // Grant TABLE ADMIN privs to testUserPerms
  10. grantOnTable(TEST_UTIL, testUserPerms.getShortName(), tableName, null, null, Action.ADMIN);
  11. List<UserPermission> perms = testUserPerms.runAs(getPrivilegedAction(regex));
  12. assertNotNull(perms);
  13. // Superuser, testUserPerms
  14. assertEquals(2, perms.size());
  15. } finally {
  16. deleteTable(TEST_UTIL, tableName);
  17. }
  18. }

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

  1. public String authString(String user, TableName table, Set<Action> actions) {
  2. StringBuilder sb = new StringBuilder();
  3. sb.append(" (user=").append(user != null ? user : "UNKNOWN").append(", ");
  4. sb.append("scope=").append(table == null ? "GLOBAL" : table.getNameWithNamespaceInclAsString()).append(", ");
  5. sb.append(actions.size() > 1 ? "actions=" : "action=").append(actions != null ? actions.toString() : "")
  6. .append(")");
  7. return sb.toString();
  8. }

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

  1. /**
  2. * @return a description of the operation
  3. */
  4. protected String getDescription() {
  5. return "Operation: " + getOperationType() + ", " + "Table Name: " +
  6. tableName.getNameWithNamespaceInclAsString() + ", procId: " + procId;
  7. }

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

  1. String getDescription() {
  2. return "Operation: " + getOperationType() + ", " + "Table Name: "
  3. + tableName.getNameWithNamespaceInclAsString();
  4. }

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

  1. @Override
  2. public boolean checkState(int tries) throws IOException {
  3. try {
  4. if (getAdmin().isTableAvailable(tableName)) {
  5. return true;
  6. }
  7. } catch (TableNotFoundException tnfe) {
  8. LOG.debug("Table " + tableName.getNameWithNamespaceInclAsString()
  9. + " was not enabled, sleeping. tries=" + tries);
  10. }
  11. return false;
  12. }
  13. });

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

  1. Set<TableDescriptor> tableDescriptorsToSynchronize = new HashSet<>();
  2. for (TableDescriptor origTableDesc : admin.listTableDescriptors()) {
  3. if (MetaDataUtil.isViewIndex(origTableDesc.getTableName().getNameWithNamespaceInclAsString())) {

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

  1. public String authString(String user, TableName table, Set<Action> actions) {
  2. StringBuilder sb = new StringBuilder();
  3. sb.append(" (user=").append(user != null ? user : "UNKNOWN").append(", ");
  4. sb.append("scope=").append(table == null ? "GLOBAL" : table.getNameWithNamespaceInclAsString()).append(", ");
  5. sb.append(actions.size() > 1 ? "actions=" : "action=").append(actions != null ? actions.toString() : "")
  6. .append(")");
  7. return sb.toString();
  8. }

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

  1. public String authString(String user, TableName table, Set<Action> actions) {
  2. StringBuilder sb = new StringBuilder();
  3. sb.append(" (user=").append(user != null ? user : "UNKNOWN").append(", ");
  4. sb.append("scope=").append(table == null ? "GLOBAL" : table.getNameWithNamespaceInclAsString()).append(", ");
  5. sb.append(actions.size() > 1 ? "actions=" : "action=").append(actions != null ? actions.toString() : "")
  6. .append(")");
  7. return sb.toString();
  8. }

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

  1. /**
  2. * @return a description of the operation
  3. */
  4. protected String getDescription() {
  5. return "Operation: " + getOperationType() + ", "
  6. + "Table Name: " + tableName.getNameWithNamespaceInclAsString();
  7. }

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

  1. String getDescription() {
  2. return "Operation: " + getOperationType() + ", " + "Table Name: "
  3. + tableName.getNameWithNamespaceInclAsString();
  4. }

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

  1. public String toString() {
  2. String familiesString = toFamiliesString(families, family, qualifier);
  3. String[] params = new String[] {
  4. namespace != null ? "namespace=" + namespace : null,
  5. tableName != null ? "table=" + tableName.getNameWithNamespaceInclAsString() : null,
  6. familiesString.length() > 0 ? "family=" + familiesString : null
  7. };
  8. return Joiner.on(",").skipNulls().join(params);
  9. }

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

  1. private void deleteTableInstance(HBaseOperationContext hbaseOperationContext) {
  2. TableName tableName = hbaseOperationContext.getTableName();
  3. String nameSpaceName = tableName.getNamespaceAsString();
  4. if (nameSpaceName == null) {
  5. nameSpaceName = tableName.getNameWithNamespaceInclAsString();
  6. }
  7. String tableNameStr = tableName.getNameAsString();
  8. String tableQName = getTableQualifiedName(clusterName, nameSpaceName, tableNameStr);
  9. AtlasObjectId tableId = new AtlasObjectId(HBaseDataTypes.HBASE_TABLE.getName(), REFERENCEABLE_ATTRIBUTE_NAME, tableQName);
  10. LOG.info("Delete Table {}", tableQName);
  11. hbaseOperationContext.addMessage(new EntityDeleteRequestV2(hbaseOperationContext.getUser(), Collections.singletonList(tableId)));
  12. }

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

  1. private void deleteTableInstance(HBaseOperationContext hbaseOperationContext) {
  2. TableName tableName = hbaseOperationContext.getTableName();
  3. String nameSpaceName = tableName.getNamespaceAsString();
  4. if (nameSpaceName == null) {
  5. nameSpaceName = tableName.getNameWithNamespaceInclAsString();
  6. }
  7. String tableNameStr = tableName.getNameAsString();
  8. String tableQName = getTableQualifiedName(clusterName, nameSpaceName, tableNameStr);
  9. AtlasObjectId tableId = new AtlasObjectId(HBaseDataTypes.HBASE_TABLE.getName(), REFERENCEABLE_ATTRIBUTE_NAME, tableQName);
  10. LOG.info("Delete Table {}", tableQName);
  11. hbaseOperationContext.addMessage(new EntityDeleteRequestV2(hbaseOperationContext.getUser(), Collections.singletonList(tableId)));
  12. }

相关文章