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

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

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

TableName.valueOf介绍

暂无

代码示例

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

  1. @Test(expected=IllegalArgumentException.class)
  2. public void testModifyInexistentFamily() {
  3.  HTableDescriptor htd = new HTableDescriptor(TableName.valueOf(name.getMethodName()));
  4.  byte[] familyName = Bytes.toBytes("cf");
  5.  HColumnDescriptor hcd = new HColumnDescriptor(familyName);
  6.  htd.modifyFamily(hcd);
  7. }

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

  1. @Test
  2. public void testLegalHTableNamesRegex() {
  3.  for (String tn : legalTableNames) {
  4.   TableName tName = TableName.valueOf(tn);
  5.   assertTrue("Testing: '" + tn + "'", Pattern.matches(TableName.VALID_USER_TABLE_REGEX,
  6.     tName.getNameAsString()));
  7.  }
  8. }

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

  1. @Test
  2. public void testGetter() {
  3.  final TableName tableName = TableName.valueOf("table");
  4.  Map<TableName, SpaceViolationPolicyEnforcement> map = new HashMap<>();
  5.  map.put(tableName, new NoWritesViolationPolicyEnforcement());
  6.  ActivePolicyEnforcement ape = new ActivePolicyEnforcement(map, Collections.emptyMap(), null);
  7.  assertEquals(map.get(tableName), ape.getPolicyEnforcement(tableName));
  8. }

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

  1. /**
  2.  * For HADOOP-2579
  3.  * @throws IOException
  4.  */
  5. @Test (expected=TableNotFoundException.class)
  6. public void testTableNotFoundExceptionWithoutAnyTables() throws IOException {
  7.  TableName tableName = TableName
  8.    .valueOf("testTableNotFoundExceptionWithoutAnyTables");
  9.  Table ht = TEST_UTIL.getConnection().getTable(tableName);
  10.  ht.get(new Get(Bytes.toBytes("e")));
  11. }

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

  1. @Before
  2. public void setUp() throws IOException {
  3.  byte[][] families = new byte[][] { Bytes.toBytes("cf") };
  4.  TableDescriptor htd = getTableDesc(
  5.   TableName.valueOf(name.getMethodName().replaceAll("[^0-9A-Za-z_]", "_")), families);
  6.  region = initHRegion(htd, HConstants.EMPTY_START_ROW, HConstants.EMPTY_END_ROW, 0);
  7. }

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

  1. @Test
  2. public void testSimpleCreateWithSplits() throws Exception {
  3.  final TableName tableName = TableName.valueOf(name.getMethodName());
  4.  final byte[][] splitKeys = new byte[][] {
  5.   Bytes.toBytes("a"), Bytes.toBytes("b"), Bytes.toBytes("c")
  6.  };
  7.  testSimpleCreate(tableName, splitKeys);
  8. }

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

  1. @Test
  2. public void testGetName() {
  3.  TableRegionModel model = buildTestModel();
  4.  String modelName = model.getName();
  5.  HRegionInfo hri = new HRegionInfo(TableName.valueOf(TABLE),
  6.   START_KEY, END_KEY, false, ID);
  7.  assertEquals(modelName, hri.getRegionNameAsString());
  8. }

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

  1. @Test
  2. public void testLegalTableNamesRegex() {
  3.  for (String tn : legalTableNames) {
  4.   TableName tName = TableName.valueOf(tn);
  5.   assertTrue("Testing: '" + tn + "'", Pattern.matches(TableName.VALID_USER_TABLE_REGEX,
  6.     tName.getNameAsString()));
  7.  }
  8. }

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

  1. @Test
  2. public void testSimpleDeleteWithSplits() throws Exception {
  3.  final TableName tableName = TableName.valueOf(name.getMethodName());
  4.  final byte[][] splitKeys = new byte[][] {
  5.   Bytes.toBytes("a"), Bytes.toBytes("b"), Bytes.toBytes("c")
  6.  };
  7.  testSimpleDelete(tableName, splitKeys);
  8. }

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

  1. @Test
  2. public void testIOExceptionOnAssignment() throws Exception {
  3.  // collect AM metrics before test
  4.  collectAssignmentManagerMetrics();
  5.  testFailedOpen(TableName.valueOf("testExceptionOnAssignment"),
  6.   new FaultyRsExecutor(new IOException("test fault")));
  7.  assertEquals(assignSubmittedCount + 1, assignProcMetrics.getSubmittedCounter().getCount());
  8.  assertEquals(assignFailedCount + 1, assignProcMetrics.getFailedCounter().getCount());
  9. }

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

  1. @Test
  2. public void testNoPolicyReturnsNoopEnforcement() {
  3.  ActivePolicyEnforcement ape = new ActivePolicyEnforcement(
  4.    new HashMap<>(), Collections.emptyMap(), mock(RegionServerServices.class));
  5.  SpaceViolationPolicyEnforcement enforcement = ape.getPolicyEnforcement(
  6.    TableName.valueOf("nonexistent"));
  7.  assertNotNull(enforcement);
  8.  assertTrue(
  9.    "Expected an instance of MissingSnapshotViolationPolicyEnforcement, but got "
  10.      + enforcement.getClass(),
  11.    enforcement instanceof MissingSnapshotViolationPolicyEnforcement);
  12. }

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

  1. /**
  2.  * For HADOOP-2579
  3.  * @throws IOException
  4.  */
  5. @Test (expected=TableExistsException.class)
  6. public void testTableExistsExceptionWithATable() throws IOException {
  7.  final TableName name = TableName.valueOf(this.name.getMethodName());
  8.  TEST_UTIL.createTable(name, HConstants.CATALOG_FAMILY).close();
  9.  TEST_UTIL.createTable(name, HConstants.CATALOG_FAMILY);
  10. }

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

  1. @Test
  2. public void testDoNotRetryExceptionOnAssignment() throws Exception {
  3.  // collect AM metrics before test
  4.  collectAssignmentManagerMetrics();
  5.  testFailedOpen(TableName.valueOf("testDoNotRetryExceptionOnAssignment"),
  6.   new FaultyRsExecutor(new DoNotRetryIOException("test do not retry fault")));
  7.  assertEquals(assignSubmittedCount + 1, assignProcMetrics.getSubmittedCounter().getCount());
  8.  assertEquals(assignFailedCount + 1, assignProcMetrics.getFailedCounter().getCount());
  9. }

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

  1. @Test
  2. public void testGetRegionByStateOfTable() throws Exception {
  3.  RegionInfo hri = createTableAndGetOneRegion(tableName);
  4.  RegionStates regionStates =
  5.    TEST_UTIL.getHBaseCluster().getMaster().getAssignmentManager().getRegionStates();
  6.  assertTrue(regionStates.getRegionByStateOfTable(tableName).get(RegionState.State.OPEN)
  7.    .stream().anyMatch(r -> RegionInfo.COMPARATOR.compare(r, hri) == 0));
  8.  assertFalse(regionStates.getRegionByStateOfTable(TableName.valueOf("I_am_the_phantom"))
  9.    .get(RegionState.State.OPEN).stream().anyMatch(r -> RegionInfo.COMPARATOR.compare(r, hri) == 0));
  10. }

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

  1. @Test
  2. public void testTableExist() throws IOException {
  3.  final TableName table = TableName.valueOf(name.getMethodName());
  4.  boolean exist;
  5.  exist = this.admin.tableExists(table);
  6.  assertEquals(false, exist);
  7.  TEST_UTIL.createTable(table, HConstants.CATALOG_FAMILY);
  8.  exist = this.admin.tableExists(table);
  9.  assertEquals(true, exist);
  10. }

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

  1. @Test
  2. public void testCloneTableSchemaWithNonExistentSourceTable() throws Exception {
  3.  final TableName newTableName = TableName.valueOf(tableName.getNameAsString() + "_new");
  4.  // test for non-existent source table
  5.  try {
  6.   admin.cloneTableSchema(tableName, newTableName, false).join();
  7.   fail("Should have failed when source table doesn't exist.");
  8.  } catch (CompletionException e) {
  9.   assertTrue(e.getCause() instanceof TableNotFoundException);
  10.  }
  11. }

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

  1. @Test
  2. public void testSimpleLoadWithFileCopy() throws Exception {
  3.  String testName = tn.getMethodName();
  4.  final byte[] TABLE_NAME = Bytes.toBytes("mytable_" + testName);
  5.  runTest(testName, buildHTD(TableName.valueOf(TABLE_NAME), BloomType.NONE),
  6.    false, null, new byte[][][] { new byte[][] { Bytes.toBytes("aaaa"), Bytes.toBytes("cccc") },
  7.     new byte[][] { Bytes.toBytes("ddd"), Bytes.toBytes("ooo") }, },
  8.   false, true, 2);
  9. }

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

  1. @Test
  2. public void testGetTableDescriptor() throws Exception {
  3.  ThriftHBaseServiceHandler handler = createHandler();
  4.  TTableDescriptor tableDescriptor = handler
  5.    .getTableDescriptor(ThriftUtilities.tableNameFromHBase(TableName.valueOf(tableAname)));
  6.  TableDescriptor table = ThriftUtilities.tableDescriptorFromThrift(tableDescriptor);
  7.  assertTrue(table.getTableName().equals(TableName.valueOf(tableAname)));
  8.  assertTrue(table.getColumnFamilies().length == 2);
  9.  assertTrue(table.getColumnFamily(familyAname).getMaxVersions() == 3);
  10.  assertTrue(table.getColumnFamily(familyBname).getMaxVersions() == 2);
  11. }

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

  1. @Test
  2.  public void testPriority() {
  3.   HTableDescriptor htd = new HTableDescriptor(TableName.valueOf(name.getMethodName()));
  4.   htd.setPriority(42);
  5.   assertEquals(42, htd.getPriority());
  6.  }
  7. }

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

  1. @Test
  2. public void testCreateTableWithOnlyEmptyStartRow() throws IOException {
  3.  final byte[] tableName = Bytes.toBytes(name.getMethodName());
  4.  byte[][] splitKeys = new byte[1][];
  5.  splitKeys[0] = HConstants.EMPTY_BYTE_ARRAY;
  6.  HTableDescriptor desc = new HTableDescriptor(TableName.valueOf(tableName));
  7.  desc.addFamily(new HColumnDescriptor("col"));
  8.  try {
  9.   admin.createTable(desc, splitKeys);
  10.   fail("Test case should fail as empty split key is passed.");
  11.  } catch (IllegalArgumentException e) {
  12.  }
  13. }

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

tablename

相关文章

    查看更多

    热门标签

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

    最新文章

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