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

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

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

TableName.isLegalFullyQualifiedTableName介绍

[英]Check passed byte array, "tableName", is legal user-space table name.
[中]检查传递的字节数组“tableName”是否为合法的用户空间表名。

代码示例

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

  1. private TableName parseTable(String msg) {
  2. // ... TableNotFoundException: '<table>'/n...
  3. Pattern p = Pattern.compile("TableNotFoundException: '([\\S]*)'");
  4. Matcher m = p.matcher(msg);
  5. if (m.find()) {
  6. String table = m.group(1);
  7. try {
  8. // double check that table is a valid table name
  9. TableName.valueOf(TableName.isLegalFullyQualifiedTableName(Bytes.toBytes(table)));
  10. return TableName.valueOf(table);
  11. } catch (IllegalArgumentException ignore) {
  12. }
  13. }
  14. return null;
  15. }

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

  1. @Override
  2. public void deleteSnapshot(final String snapshotName) throws IOException {
  3. // make sure the snapshot is possibly valid
  4. TableName.isLegalFullyQualifiedTableName(Bytes.toBytes(snapshotName));
  5. // do the delete
  6. executeCallable(new MasterCallable<Void>(getConnection(), getRpcControllerFactory()) {
  7. @Override
  8. protected Void rpcCall() throws Exception {
  9. master.deleteSnapshot(getRpcController(),
  10. DeleteSnapshotRequest.newBuilder().setSnapshot(
  11. SnapshotProtos.SnapshotDescription.newBuilder().setName(snapshotName).build())
  12. .build()
  13. );
  14. return null;
  15. }
  16. });
  17. }

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

  1. @Test
  2. public void testLegalTableNames() {
  3. for (String tn : legalTableNames) {
  4. TableName.isLegalFullyQualifiedTableName(Bytes.toBytes(tn));
  5. }
  6. }

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

  1. @Test
  2. public void testLegalHTableNames() {
  3. for (String tn : legalTableNames) {
  4. TableName.isLegalFullyQualifiedTableName(Bytes.toBytes(tn));
  5. }
  6. }

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

  1. @Test
  2. public void testLegalHTableNames() {
  3. for (String tn : legalTableNames) {
  4. TableName.isLegalFullyQualifiedTableName(Bytes.toBytes(tn));
  5. }
  6. }

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

  1. @Test
  2. public void testIllegalZooKeeperName() {
  3. for (String name : Arrays.asList("zookeeper", "ns:zookeeper", "zookeeper:table")) {
  4. try {
  5. TableName.isLegalFullyQualifiedTableName(Bytes.toBytes(name));
  6. fail("invalid tablename " + name + " should have failed");
  7. } catch (Exception e) {
  8. // expected
  9. }
  10. }
  11. }

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

  1. @Test(expected = IllegalArgumentException.class)
  2. public void testInvalidNamespace() {
  3. for (String tn : invalidNamespace) {
  4. TableName.isLegalFullyQualifiedTableName(Bytes.toBytes(tn));
  5. fail("invalid namespace " + tn
  6. + " should have failed with IllegalArgumentException for namespace");
  7. }
  8. }

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

  1. @Test(expected = IllegalArgumentException.class)
  2. public void testEmptyTableName() {
  3. for (String tn : emptyNames) {
  4. TableName.isLegalFullyQualifiedTableName(Bytes.toBytes(tn));
  5. fail("invalid tablename " + tn + " should have failed with IllegalArgumentException");
  6. }
  7. }

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

  1. @Test
  2. public void testIllegalHTableNames() {
  3. for (String tn : illegalTableNames) {
  4. try {
  5. TableName.isLegalFullyQualifiedTableName(Bytes.toBytes(tn));
  6. fail("invalid tablename " + tn + " should have failed");
  7. } catch (Exception e) {
  8. // expected
  9. }
  10. }
  11. }

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

  1. @Test
  2. public void testIllegalTableNames() {
  3. for (String tn : illegalTableNames) {
  4. try {
  5. TableName.isLegalFullyQualifiedTableName(Bytes.toBytes(tn));
  6. fail("invalid tablename " + tn + " should have failed");
  7. } catch (Exception e) {
  8. // expected
  9. }
  10. }
  11. }

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

  1. @Test
  2. public void testIllegalHTableNames() {
  3. for (String tn : illegalTableNames) {
  4. try {
  5. TableName.isLegalFullyQualifiedTableName(Bytes.toBytes(tn));
  6. fail("invalid tablename " + tn + " should have failed");
  7. } catch (Exception e) {
  8. // expected
  9. }
  10. }
  11. }

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

  1. @Override
  2. public Future<Void> disableTableAsync(final TableName tableName) throws IOException {
  3. TableName.isLegalFullyQualifiedTableName(tableName.getName());
  4. DisableTableResponse response = executeCallable(
  5. new MasterCallable<DisableTableResponse>(getConnection(), getRpcControllerFactory()) {
  6. Long nonceGroup = ng.getNonceGroup();
  7. Long nonce = ng.newNonce();
  8. @Override
  9. protected DisableTableResponse rpcCall() throws Exception {
  10. setPriority(tableName);
  11. LOG.info("Started disable of " + tableName);
  12. DisableTableRequest req =
  13. RequestConverter.buildDisableTableRequest(
  14. tableName, nonceGroup, nonce);
  15. return master.disableTable(getRpcController(), req);
  16. }
  17. });
  18. return new DisableTableFuture(this, tableName, response);
  19. }

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

  1. @Override
  2. public Future<Void> enableTableAsync(final TableName tableName) throws IOException {
  3. TableName.isLegalFullyQualifiedTableName(tableName.getName());
  4. EnableTableResponse response = executeCallable(
  5. new MasterCallable<EnableTableResponse>(getConnection(), getRpcControllerFactory()) {
  6. Long nonceGroup = ng.getNonceGroup();
  7. Long nonce = ng.newNonce();
  8. @Override
  9. protected EnableTableResponse rpcCall() throws Exception {
  10. setPriority(tableName);
  11. LOG.info("Started enable of " + tableName);
  12. EnableTableRequest req =
  13. RequestConverter.buildEnableTableRequest(tableName, nonceGroup, nonce);
  14. return master.enableTable(getRpcController(),req);
  15. }
  16. });
  17. return new EnableTableFuture(this, tableName, response);
  18. }

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

  1. @Test
  2. public void testLegalHTableNames() {
  3. for (String tn : legalTableNames) {
  4. TableName.isLegalFullyQualifiedTableName(Bytes.toBytes(tn));
  5. }
  6. }

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

  1. @Override
  2. public void deleteSnapshot(final String snapshotName) throws IOException {
  3. // make sure the snapshot is possibly valid
  4. TableName.isLegalFullyQualifiedTableName(Bytes.toBytes(snapshotName));
  5. // do the delete
  6. executeCallable(new MasterCallable<Void>(getConnection(), getRpcControllerFactory()) {
  7. @Override
  8. protected Void rpcCall() throws Exception {
  9. master.deleteSnapshot(getRpcController(),
  10. DeleteSnapshotRequest.newBuilder().setSnapshot(
  11. SnapshotProtos.SnapshotDescription.newBuilder().setName(snapshotName).build())
  12. .build()
  13. );
  14. return null;
  15. }
  16. });
  17. }

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

  1. @Test
  2. public void testLegalTableNames() {
  3. for (String tn : legalTableNames) {
  4. TableName.isLegalFullyQualifiedTableName(Bytes.toBytes(tn));
  5. }
  6. }

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

  1. @Test
  2. public void testIllegalZooKeeperName() {
  3. for (String name : Arrays.asList("zookeeper", "ns:zookeeper", "zookeeper:table")) {
  4. try {
  5. TableName.isLegalFullyQualifiedTableName(Bytes.toBytes(name));
  6. fail("invalid tablename " + name + " should have failed");
  7. } catch (Exception e) {
  8. // expected
  9. }
  10. }
  11. }

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

  1. @Test
  2. public void testIllegalTableNames() {
  3. for (String tn : illegalTableNames) {
  4. try {
  5. TableName.isLegalFullyQualifiedTableName(Bytes.toBytes(tn));
  6. fail("invalid tablename " + tn + " should have failed");
  7. } catch (Exception e) {
  8. // expected
  9. }
  10. }
  11. }

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

  1. @Test
  2. public void testIllegalHTableNames() {
  3. for (String tn : illegalTableNames) {
  4. try {
  5. TableName.isLegalFullyQualifiedTableName(Bytes.toBytes(tn));
  6. fail("invalid tablename " + tn + " should have failed");
  7. } catch (Exception e) {
  8. // expected
  9. }
  10. }
  11. }

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

  1. @Override
  2. public Future<Void> enableTableAsync(final TableName tableName) throws IOException {
  3. TableName.isLegalFullyQualifiedTableName(tableName.getName());
  4. EnableTableResponse response = executeCallable(
  5. new MasterCallable<EnableTableResponse>(getConnection(), getRpcControllerFactory()) {
  6. Long nonceGroup = ng.getNonceGroup();
  7. Long nonce = ng.newNonce();
  8. @Override
  9. protected EnableTableResponse rpcCall() throws Exception {
  10. setPriority(tableName);
  11. LOG.info("Started enable of " + tableName);
  12. EnableTableRequest req =
  13. RequestConverter.buildEnableTableRequest(tableName, nonceGroup, nonce);
  14. return master.enableTable(getRpcController(),req);
  15. }
  16. });
  17. return new EnableTableFuture(this, tableName, response);
  18. }

相关文章