This is an automated email from the ASF dual-hosted git repository.
zhangduo pushed a commit to branch HBASE-21512
in repository https://gitbox.apache.org/repos/asf/hbase.git
commit 88566e6a4db8c6ac0b8e63d1a97c30f9d919262a
Author: Duo Zhang <zhang...@apache.org>
AuthorDate: Fri Apr 12 15:08:11 2019 +0800
HBASE-21718 Implement Admin based on AsyncAdmin
---
.../hadoop/hbase/backup/util/RestoreTool.java | 2 +-
.../apache/hadoop/hbase/backup/TestBackupBase.java | 6 +-
.../hbase/backup/TestBackupDeleteRestore.java | 4 +-
.../hadoop/hbase/backup/TestBackupMerge.java | 4 +-
.../hbase/backup/TestBackupMultipleDeletes.java | 5 +-
.../hadoop/hbase/backup/TestBackupSystemTable.java | 2 +-
.../hadoop/hbase/backup/TestFullBackupSet.java | 4 +-
.../hbase/backup/TestFullBackupSetRestoreSet.java | 6 +-
.../hadoop/hbase/backup/TestFullRestore.java | 16 +-
.../hadoop/hbase/backup/TestIncrementalBackup.java | 7 +-
.../backup/TestIncrementalBackupDeleteTable.java | 7 +-
.../TestIncrementalBackupMergeWithFailures.java | 4 +-
.../backup/TestIncrementalBackupWithBulkLoad.java | 6 +-
.../backup/TestIncrementalBackupWithFailures.java | 5 +-
.../hadoop/hbase/backup/TestRemoteBackup.java | 4 +-
.../hadoop/hbase/backup/TestRemoteRestore.java | 4 +-
.../hbase/backup/TestRestoreBoundaryTests.java | 6 +-
.../hbase/backup/TestSystemTableSnapshot.java | 4 +-
.../hadoop/hbase/AsyncMetaTableAccessor.java | 29 +-
.../java/org/apache/hadoop/hbase/client/Admin.java | 50 +-
.../hadoop/hbase/client/AdminOverAsyncAdmin.java | 945 +++++++++++++++++++++
.../client/ConnectionOverAsyncConnection.java | 2 +-
.../hadoop/hbase/client/ConnectionUtils.java | 18 +
.../client/CoprocessorBlockingRpcCallback.java | 68 ++
.../org/apache/hadoop/hbase/client/HBaseAdmin.java | 9 +-
.../hadoop/hbase/client/RawAsyncHBaseAdmin.java | 37 +-
.../client/RegionCoprocessorRpcChannelImpl.java | 21 +-
.../hbase/client/SyncCoprocessorRpcChannel.java | 3 +
.../hadoop/hbase/client/TableOverAsyncTable.java | 51 +-
.../hadoop/hbase/client/TestInterfaceAlign.java | 2 +
.../apache/hadoop/hbase/PerformanceEvaluation.java | 6 +-
.../hadoop/hbase/rest/client/TestRemoteTable.java | 4 +-
.../apache/hadoop/hbase/HBaseTestingUtility.java | 42 +-
.../org/apache/hadoop/hbase/client/TestAdmin1.java | 41 +-
.../org/apache/hadoop/hbase/client/TestAdmin2.java | 35 +-
.../hadoop/hbase/client/TestFromClientSide.java | 7 +-
.../hadoop/hbase/client/TestFromClientSide3.java | 10 +-
.../client/TestSnapshotDFSTemporaryDirectory.java | 5 +-
.../client/TestSnapshotTemporaryDirectory.java | 6 +-
.../hbase/client/TestSplitOrMergeStatus.java | 13 +-
.../hbase/coprocessor/TestMasterObserver.java | 2 +-
.../org/apache/hadoop/hbase/master/TestMaster.java | 4 +-
.../hbase/master/TestMasterMetricsWrapper.java | 4 +-
.../master/TestMergeTableRegionsWhileRSCrash.java | 2 +-
.../hbase/master/TestSplitRegionWhileRSCrash.java | 2 +-
.../master/assignment/TestAssignmentOnRSCrash.java | 2 +-
.../TestMasterAbortWhileMergingTable.java | 2 +-
.../assignment/TestModifyTableWhileMerging.java | 2 +-
.../TestCleanupCompactedFileOnRegionClose.java | 6 +-
.../TestNewVersionBehaviorFromClientSide.java | 2 +-
.../hbase/regionserver/TestRegionServerAbort.java | 2 +-
.../replication/regionserver/TestReplicator.java | 4 +-
.../hbase/snapshot/SnapshotTestingUtils.java | 29 -
.../snapshot/TestFlushSnapshotFromClient.java | 41 +-
.../hadoop/hbase/tool/TestBulkLoadHFiles.java | 6 +-
.../hbase/thrift2/ThriftHBaseServiceHandler.java | 6 +-
.../hadoop/hbase/thrift2/client/ThriftAdmin.java | 9 +-
57 files changed, 1276 insertions(+), 349 deletions(-)
diff --git
a/hbase-backup/src/main/java/org/apache/hadoop/hbase/backup/util/RestoreTool.java
b/hbase-backup/src/main/java/org/apache/hadoop/hbase/backup/util/RestoreTool.java
index d2038c7..ff8d26a 100644
---
a/hbase-backup/src/main/java/org/apache/hadoop/hbase/backup/util/RestoreTool.java
+++
b/hbase-backup/src/main/java/org/apache/hadoop/hbase/backup/util/RestoreTool.java
@@ -489,7 +489,7 @@ public class RestoreTool {
LOG.info("Creating target table '" + targetTableName + "'");
byte[][] keys;
if (regionDirList == null || regionDirList.size() == 0) {
- admin.createTable(htd, null);
+ admin.createTable(htd);
} else {
keys = generateBoundaryKeys(regionDirList);
// create table using table descriptor and region boundaries
diff --git
a/hbase-backup/src/test/java/org/apache/hadoop/hbase/backup/TestBackupBase.java
b/hbase-backup/src/test/java/org/apache/hadoop/hbase/backup/TestBackupBase.java
index e0fca20..64978bc 100644
---
a/hbase-backup/src/test/java/org/apache/hadoop/hbase/backup/TestBackupBase.java
+++
b/hbase-backup/src/test/java/org/apache/hadoop/hbase/backup/TestBackupBase.java
@@ -26,7 +26,6 @@ import java.util.List;
import java.util.Map;
import java.util.Map.Entry;
import java.util.Objects;
-
import org.apache.hadoop.conf.Configuration;
import org.apache.hadoop.fs.FileSystem;
import org.apache.hadoop.fs.LocatedFileStatus;
@@ -53,7 +52,6 @@ import org.apache.hadoop.hbase.client.Admin;
import org.apache.hadoop.hbase.client.Connection;
import org.apache.hadoop.hbase.client.ConnectionFactory;
import org.apache.hadoop.hbase.client.Durability;
-import org.apache.hadoop.hbase.client.HBaseAdmin;
import org.apache.hadoop.hbase.client.Put;
import org.apache.hadoop.hbase.client.Table;
import org.apache.hadoop.hbase.master.cleaner.LogCleaner;
@@ -342,7 +340,7 @@ public class TestBackupBase {
@AfterClass
public static void tearDown() throws Exception {
try{
- SnapshotTestingUtils.deleteAllSnapshots(TEST_UTIL.getHBaseAdmin());
+ SnapshotTestingUtils.deleteAllSnapshots(TEST_UTIL.getAdmin());
} catch (Exception e) {
}
SnapshotTestingUtils.deleteArchiveDirectory(TEST_UTIL);
@@ -416,7 +414,7 @@ public class TestBackupBase {
protected static void createTables() throws Exception {
long tid = System.currentTimeMillis();
table1 = TableName.valueOf("test-" + tid);
- HBaseAdmin ha = TEST_UTIL.getHBaseAdmin();
+ Admin ha = TEST_UTIL.getAdmin();
// Create namespaces
NamespaceDescriptor desc1 = NamespaceDescriptor.create("ns1").build();
diff --git
a/hbase-backup/src/test/java/org/apache/hadoop/hbase/backup/TestBackupDeleteRestore.java
b/hbase-backup/src/test/java/org/apache/hadoop/hbase/backup/TestBackupDeleteRestore.java
index 74176e3..f649b92 100644
---
a/hbase-backup/src/test/java/org/apache/hadoop/hbase/backup/TestBackupDeleteRestore.java
+++
b/hbase-backup/src/test/java/org/apache/hadoop/hbase/backup/TestBackupDeleteRestore.java
@@ -24,8 +24,8 @@ import java.util.List;
import org.apache.hadoop.hbase.HBaseClassTestRule;
import org.apache.hadoop.hbase.TableName;
import org.apache.hadoop.hbase.backup.util.BackupUtils;
+import org.apache.hadoop.hbase.client.Admin;
import org.apache.hadoop.hbase.client.Delete;
-import org.apache.hadoop.hbase.client.HBaseAdmin;
import org.apache.hadoop.hbase.client.Table;
import org.apache.hadoop.hbase.testclassification.MediumTests;
import org.apache.hadoop.hbase.util.Bytes;
@@ -61,7 +61,7 @@ public class TestBackupDeleteRestore extends TestBackupBase {
assertTrue(checkSucceeded(backupId));
LOG.info("backup complete");
int numRows = TEST_UTIL.countRows(table1);
- HBaseAdmin hba = TEST_UTIL.getHBaseAdmin();
+ Admin hba = TEST_UTIL.getAdmin();
// delete row
try (Table table = TEST_UTIL.getConnection().getTable(table1)) {
Delete delete = new Delete(Bytes.toBytes("row0"));
diff --git
a/hbase-backup/src/test/java/org/apache/hadoop/hbase/backup/TestBackupMerge.java
b/hbase-backup/src/test/java/org/apache/hadoop/hbase/backup/TestBackupMerge.java
index beacef3..1a8638c 100644
---
a/hbase-backup/src/test/java/org/apache/hadoop/hbase/backup/TestBackupMerge.java
+++
b/hbase-backup/src/test/java/org/apache/hadoop/hbase/backup/TestBackupMerge.java
@@ -24,9 +24,9 @@ import org.apache.hadoop.hbase.HBaseClassTestRule;
import org.apache.hadoop.hbase.TableName;
import org.apache.hadoop.hbase.backup.impl.BackupAdminImpl;
import org.apache.hadoop.hbase.backup.util.BackupUtils;
+import org.apache.hadoop.hbase.client.Admin;
import org.apache.hadoop.hbase.client.Connection;
import org.apache.hadoop.hbase.client.ConnectionFactory;
-import org.apache.hadoop.hbase.client.HBaseAdmin;
import org.apache.hadoop.hbase.client.Table;
import org.apache.hadoop.hbase.testclassification.LargeTests;
import org.junit.Assert;
@@ -62,7 +62,7 @@ public class TestBackupMerge extends TestBackupBase {
Connection conn = ConnectionFactory.createConnection(conf1);
- HBaseAdmin admin = (HBaseAdmin) conn.getAdmin();
+ Admin admin = conn.getAdmin();
BackupAdminImpl client = new BackupAdminImpl(conn);
BackupRequest request = createBackupRequest(BackupType.FULL, tables,
BACKUP_ROOT_DIR);
diff --git
a/hbase-backup/src/test/java/org/apache/hadoop/hbase/backup/TestBackupMultipleDeletes.java
b/hbase-backup/src/test/java/org/apache/hadoop/hbase/backup/TestBackupMultipleDeletes.java
index bffa480..538488b 100644
---
a/hbase-backup/src/test/java/org/apache/hadoop/hbase/backup/TestBackupMultipleDeletes.java
+++
b/hbase-backup/src/test/java/org/apache/hadoop/hbase/backup/TestBackupMultipleDeletes.java
@@ -26,9 +26,9 @@ import java.util.Set;
import org.apache.hadoop.hbase.HBaseClassTestRule;
import org.apache.hadoop.hbase.TableName;
import org.apache.hadoop.hbase.backup.impl.BackupAdminImpl;
+import org.apache.hadoop.hbase.client.Admin;
import org.apache.hadoop.hbase.client.Connection;
import org.apache.hadoop.hbase.client.ConnectionFactory;
-import org.apache.hadoop.hbase.client.HBaseAdmin;
import org.apache.hadoop.hbase.client.Put;
import org.apache.hadoop.hbase.client.Table;
import org.apache.hadoop.hbase.testclassification.LargeTests;
@@ -59,9 +59,8 @@ public class TestBackupMultipleDeletes extends TestBackupBase
{
// #1 - create full backup for all tables
LOG.info("create full backup image for all tables");
List<TableName> tables = Lists.newArrayList(table1, table2);
- HBaseAdmin admin = null;
Connection conn = ConnectionFactory.createConnection(conf1);
- admin = (HBaseAdmin) conn.getAdmin();
+ Admin admin = conn.getAdmin();
BackupAdmin client = new BackupAdminImpl(conn);
BackupRequest request = createBackupRequest(BackupType.FULL, tables,
BACKUP_ROOT_DIR);
String backupIdFull = client.backupTables(request);
diff --git
a/hbase-backup/src/test/java/org/apache/hadoop/hbase/backup/TestBackupSystemTable.java
b/hbase-backup/src/test/java/org/apache/hadoop/hbase/backup/TestBackupSystemTable.java
index aa6e5dd..5d48fc5 100644
---
a/hbase-backup/src/test/java/org/apache/hadoop/hbase/backup/TestBackupSystemTable.java
+++
b/hbase-backup/src/test/java/org/apache/hadoop/hbase/backup/TestBackupSystemTable.java
@@ -119,7 +119,7 @@ public class TestBackupSystemTable {
}
private void cleanBackupTable() throws IOException {
- Admin admin = UTIL.getHBaseAdmin();
+ Admin admin = UTIL.getAdmin();
admin.disableTable(BackupSystemTable.getTableName(conf));
admin.truncateTable(BackupSystemTable.getTableName(conf), true);
if (admin.isTableDisabled(BackupSystemTable.getTableName(conf))) {
diff --git
a/hbase-backup/src/test/java/org/apache/hadoop/hbase/backup/TestFullBackupSet.java
b/hbase-backup/src/test/java/org/apache/hadoop/hbase/backup/TestFullBackupSet.java
index 89ff571..7a3aec4 100644
---
a/hbase-backup/src/test/java/org/apache/hadoop/hbase/backup/TestFullBackupSet.java
+++
b/hbase-backup/src/test/java/org/apache/hadoop/hbase/backup/TestFullBackupSet.java
@@ -25,7 +25,7 @@ import java.util.List;
import org.apache.hadoop.hbase.HBaseClassTestRule;
import org.apache.hadoop.hbase.TableName;
import org.apache.hadoop.hbase.backup.impl.BackupSystemTable;
-import org.apache.hadoop.hbase.client.HBaseAdmin;
+import org.apache.hadoop.hbase.client.Admin;
import org.apache.hadoop.hbase.testclassification.LargeTests;
import org.apache.hadoop.util.ToolRunner;
import org.junit.ClassRule;
@@ -80,7 +80,7 @@ public class TestFullBackupSet extends TestBackupBase {
// Run backup
ret = ToolRunner.run(conf1, new RestoreDriver(), args);
assertTrue(ret == 0);
- HBaseAdmin hba = TEST_UTIL.getHBaseAdmin();
+ Admin hba = TEST_UTIL.getAdmin();
assertTrue(hba.tableExists(table1_restore));
// Verify number of rows in both tables
assertEquals(TEST_UTIL.countRows(table1),
TEST_UTIL.countRows(table1_restore));
diff --git
a/hbase-backup/src/test/java/org/apache/hadoop/hbase/backup/TestFullBackupSetRestoreSet.java
b/hbase-backup/src/test/java/org/apache/hadoop/hbase/backup/TestFullBackupSetRestoreSet.java
index ca70f6a..3543133 100644
---
a/hbase-backup/src/test/java/org/apache/hadoop/hbase/backup/TestFullBackupSetRestoreSet.java
+++
b/hbase-backup/src/test/java/org/apache/hadoop/hbase/backup/TestFullBackupSetRestoreSet.java
@@ -25,7 +25,7 @@ import java.util.List;
import org.apache.hadoop.hbase.HBaseClassTestRule;
import org.apache.hadoop.hbase.TableName;
import org.apache.hadoop.hbase.backup.impl.BackupSystemTable;
-import org.apache.hadoop.hbase.client.HBaseAdmin;
+import org.apache.hadoop.hbase.client.Admin;
import org.apache.hadoop.hbase.testclassification.LargeTests;
import org.apache.hadoop.util.ToolRunner;
import org.junit.ClassRule;
@@ -76,7 +76,7 @@ public class TestFullBackupSetRestoreSet extends
TestBackupBase {
// Run backup
ret = ToolRunner.run(conf1, new RestoreDriver(), args);
assertTrue(ret == 0);
- HBaseAdmin hba = TEST_UTIL.getHBaseAdmin();
+ Admin hba = TEST_UTIL.getAdmin();
assertTrue(hba.tableExists(table1_restore));
// Verify number of rows in both tables
assertEquals(TEST_UTIL.countRows(table1),
TEST_UTIL.countRows(table1_restore));
@@ -118,7 +118,7 @@ public class TestFullBackupSetRestoreSet extends
TestBackupBase {
// Run backup
ret = ToolRunner.run(conf1, new RestoreDriver(), args);
assertTrue(ret == 0);
- HBaseAdmin hba = TEST_UTIL.getHBaseAdmin();
+ Admin hba = TEST_UTIL.getAdmin();
assertTrue(hba.tableExists(table1));
// Verify number of rows in both tables
assertEquals(count, TEST_UTIL.countRows(table1));
diff --git
a/hbase-backup/src/test/java/org/apache/hadoop/hbase/backup/TestFullRestore.java
b/hbase-backup/src/test/java/org/apache/hadoop/hbase/backup/TestFullRestore.java
index 2201e2f..f5ad0d7 100644
---
a/hbase-backup/src/test/java/org/apache/hadoop/hbase/backup/TestFullRestore.java
+++
b/hbase-backup/src/test/java/org/apache/hadoop/hbase/backup/TestFullRestore.java
@@ -26,7 +26,7 @@ import org.apache.commons.lang3.StringUtils;
import org.apache.hadoop.hbase.HBaseClassTestRule;
import org.apache.hadoop.hbase.TableName;
import org.apache.hadoop.hbase.backup.util.BackupUtils;
-import org.apache.hadoop.hbase.client.HBaseAdmin;
+import org.apache.hadoop.hbase.client.Admin;
import org.apache.hadoop.hbase.testclassification.LargeTests;
import org.apache.hadoop.util.ToolRunner;
import org.junit.ClassRule;
@@ -66,7 +66,7 @@ public class TestFullRestore extends TestBackupBase {
BackupAdmin client = getBackupAdmin();
client.restore(BackupUtils.createRestoreRequest(BACKUP_ROOT_DIR, backupId,
false,
tableset, tablemap, false));
- HBaseAdmin hba = TEST_UTIL.getHBaseAdmin();
+ Admin hba = TEST_UTIL.getAdmin();
assertTrue(hba.tableExists(table1_restore));
TEST_UTIL.deleteTable(table1_restore);
hba.close();
@@ -88,7 +88,7 @@ public class TestFullRestore extends TestBackupBase {
int ret = ToolRunner.run(conf1, new RestoreDriver(), args);
assertTrue(ret == 0);
- HBaseAdmin hba = TEST_UTIL.getHBaseAdmin();
+ Admin hba = TEST_UTIL.getAdmin();
assertTrue(hba.tableExists(table1_restore));
TEST_UTIL.deleteTable(table1_restore);
hba.close();
@@ -110,7 +110,7 @@ public class TestFullRestore extends TestBackupBase {
int ret = ToolRunner.run(conf1, new RestoreDriver(), args);
assertTrue(ret == 0);
//Verify that table has not been restored
- HBaseAdmin hba = TEST_UTIL.getHBaseAdmin();
+ Admin hba = TEST_UTIL.getAdmin();
assertFalse(hba.tableExists(table1_restore));
}
@@ -131,7 +131,7 @@ public class TestFullRestore extends TestBackupBase {
BackupAdmin client = getBackupAdmin();
client.restore(BackupUtils.createRestoreRequest(BACKUP_ROOT_DIR, backupId,
false,
restore_tableset, tablemap, false));
- HBaseAdmin hba = TEST_UTIL.getHBaseAdmin();
+ Admin hba = TEST_UTIL.getAdmin();
assertTrue(hba.tableExists(table2_restore));
assertTrue(hba.tableExists(table3_restore));
TEST_UTIL.deleteTable(table2_restore);
@@ -162,7 +162,7 @@ public class TestFullRestore extends TestBackupBase {
int ret = ToolRunner.run(conf1, new RestoreDriver(), args);
assertTrue(ret == 0);
- HBaseAdmin hba = TEST_UTIL.getHBaseAdmin();
+ Admin hba = TEST_UTIL.getAdmin();
assertTrue(hba.tableExists(table2_restore));
assertTrue(hba.tableExists(table3_restore));
TEST_UTIL.deleteTable(table2_restore);
@@ -210,7 +210,7 @@ public class TestFullRestore extends TestBackupBase {
int ret = ToolRunner.run(conf1, new RestoreDriver(), args);
assertTrue(ret == 0);
- HBaseAdmin hba = TEST_UTIL.getHBaseAdmin();
+ Admin hba = TEST_UTIL.getAdmin();
assertTrue(hba.tableExists(table1));
hba.close();
}
@@ -256,7 +256,7 @@ public class TestFullRestore extends TestBackupBase {
int ret = ToolRunner.run(conf1, new RestoreDriver(), args);
assertTrue(ret == 0);
- HBaseAdmin hba = TEST_UTIL.getHBaseAdmin();
+ Admin hba = TEST_UTIL.getAdmin();
assertTrue(hba.tableExists(table2));
assertTrue(hba.tableExists(table3));
hba.close();
diff --git
a/hbase-backup/src/test/java/org/apache/hadoop/hbase/backup/TestIncrementalBackup.java
b/hbase-backup/src/test/java/org/apache/hadoop/hbase/backup/TestIncrementalBackup.java
index 35a77ea..d7c2cd0 100644
---
a/hbase-backup/src/test/java/org/apache/hadoop/hbase/backup/TestIncrementalBackup.java
+++
b/hbase-backup/src/test/java/org/apache/hadoop/hbase/backup/TestIncrementalBackup.java
@@ -29,9 +29,9 @@ import org.apache.hadoop.hbase.MiniHBaseCluster;
import org.apache.hadoop.hbase.TableName;
import org.apache.hadoop.hbase.backup.impl.BackupAdminImpl;
import org.apache.hadoop.hbase.backup.util.BackupUtils;
+import org.apache.hadoop.hbase.client.Admin;
import org.apache.hadoop.hbase.client.Connection;
import org.apache.hadoop.hbase.client.ConnectionFactory;
-import org.apache.hadoop.hbase.client.HBaseAdmin;
import org.apache.hadoop.hbase.client.Put;
import org.apache.hadoop.hbase.client.Table;
import org.apache.hadoop.hbase.regionserver.HRegion;
@@ -93,8 +93,7 @@ public class TestIncrementalBackup extends TestBackupBase {
int NB_ROWS_FAM3 = 6;
insertIntoTable(conn, table1, fam3Name, 3, NB_ROWS_FAM3).close();
insertIntoTable(conn, table1, mobName, 3, NB_ROWS_FAM3).close();
- HBaseAdmin admin = null;
- admin = (HBaseAdmin) conn.getAdmin();
+ Admin admin = conn.getAdmin();
BackupAdminImpl client = new BackupAdminImpl(conn);
BackupRequest request = createBackupRequest(BackupType.FULL, tables,
BACKUP_ROOT_DIR);
String backupIdFull = client.backupTables(request);
@@ -182,7 +181,7 @@ public class TestIncrementalBackup extends TestBackupBase {
tablesRestoreFull, tablesMapFull, true));
// #6.1 - check tables for full restore
- HBaseAdmin hAdmin = TEST_UTIL.getHBaseAdmin();
+ Admin hAdmin = TEST_UTIL.getAdmin();
assertTrue(hAdmin.tableExists(table1_restore));
assertTrue(hAdmin.tableExists(table2_restore));
hAdmin.close();
diff --git
a/hbase-backup/src/test/java/org/apache/hadoop/hbase/backup/TestIncrementalBackupDeleteTable.java
b/hbase-backup/src/test/java/org/apache/hadoop/hbase/backup/TestIncrementalBackupDeleteTable.java
index 08834f2..837de4d 100644
---
a/hbase-backup/src/test/java/org/apache/hadoop/hbase/backup/TestIncrementalBackupDeleteTable.java
+++
b/hbase-backup/src/test/java/org/apache/hadoop/hbase/backup/TestIncrementalBackupDeleteTable.java
@@ -24,9 +24,9 @@ import org.apache.hadoop.hbase.HBaseClassTestRule;
import org.apache.hadoop.hbase.TableName;
import org.apache.hadoop.hbase.backup.impl.BackupAdminImpl;
import org.apache.hadoop.hbase.backup.util.BackupUtils;
+import org.apache.hadoop.hbase.client.Admin;
import org.apache.hadoop.hbase.client.Connection;
import org.apache.hadoop.hbase.client.ConnectionFactory;
-import org.apache.hadoop.hbase.client.HBaseAdmin;
import org.apache.hadoop.hbase.client.Put;
import org.apache.hadoop.hbase.client.Table;
import org.apache.hadoop.hbase.testclassification.LargeTests;
@@ -64,9 +64,8 @@ public class TestIncrementalBackupDeleteTable extends
TestBackupBase {
LOG.info("create full backup image for all tables");
List<TableName> tables = Lists.newArrayList(table1, table2);
- HBaseAdmin admin = null;
Connection conn = ConnectionFactory.createConnection(conf1);
- admin = (HBaseAdmin) conn.getAdmin();
+ Admin admin = conn.getAdmin();
BackupAdminImpl client = new BackupAdminImpl(conn);
BackupRequest request = createBackupRequest(BackupType.FULL, tables,
BACKUP_ROOT_DIR);
@@ -105,7 +104,7 @@ public class TestIncrementalBackupDeleteTable extends
TestBackupBase {
tablesRestoreFull, tablesMapFull, false));
// #5.1 - check tables for full restore
- HBaseAdmin hAdmin = TEST_UTIL.getHBaseAdmin();
+ Admin hAdmin = TEST_UTIL.getAdmin();
assertTrue(hAdmin.tableExists(table1_restore));
assertTrue(hAdmin.tableExists(table2_restore));
diff --git
a/hbase-backup/src/test/java/org/apache/hadoop/hbase/backup/TestIncrementalBackupMergeWithFailures.java
b/hbase-backup/src/test/java/org/apache/hadoop/hbase/backup/TestIncrementalBackupMergeWithFailures.java
index 7351258..1bde63b 100644
---
a/hbase-backup/src/test/java/org/apache/hadoop/hbase/backup/TestIncrementalBackupMergeWithFailures.java
+++
b/hbase-backup/src/test/java/org/apache/hadoop/hbase/backup/TestIncrementalBackupMergeWithFailures.java
@@ -36,9 +36,9 @@ import org.apache.hadoop.hbase.backup.impl.BackupSystemTable;
import org.apache.hadoop.hbase.backup.mapreduce.MapReduceBackupMergeJob;
import org.apache.hadoop.hbase.backup.mapreduce.MapReduceHFileSplitterJob;
import org.apache.hadoop.hbase.backup.util.BackupUtils;
+import org.apache.hadoop.hbase.client.Admin;
import org.apache.hadoop.hbase.client.Connection;
import org.apache.hadoop.hbase.client.ConnectionFactory;
-import org.apache.hadoop.hbase.client.HBaseAdmin;
import org.apache.hadoop.hbase.client.Table;
import org.apache.hadoop.hbase.testclassification.LargeTests;
import org.apache.hadoop.hbase.util.Pair;
@@ -235,7 +235,7 @@ public class TestIncrementalBackupMergeWithFailures extends
TestBackupBase {
Connection conn = ConnectionFactory.createConnection(conf1);
- HBaseAdmin admin = (HBaseAdmin) conn.getAdmin();
+ Admin admin = conn.getAdmin();
BackupAdminImpl client = new BackupAdminImpl(conn);
BackupRequest request = createBackupRequest(BackupType.FULL, tables,
BACKUP_ROOT_DIR);
diff --git
a/hbase-backup/src/test/java/org/apache/hadoop/hbase/backup/TestIncrementalBackupWithBulkLoad.java
b/hbase-backup/src/test/java/org/apache/hadoop/hbase/backup/TestIncrementalBackupWithBulkLoad.java
index 4b02077..60aa635 100644
---
a/hbase-backup/src/test/java/org/apache/hadoop/hbase/backup/TestIncrementalBackupWithBulkLoad.java
+++
b/hbase-backup/src/test/java/org/apache/hadoop/hbase/backup/TestIncrementalBackupWithBulkLoad.java
@@ -26,9 +26,9 @@ import org.apache.hadoop.hbase.TableName;
import org.apache.hadoop.hbase.backup.impl.BackupAdminImpl;
import org.apache.hadoop.hbase.backup.impl.BackupSystemTable;
import org.apache.hadoop.hbase.backup.util.BackupUtils;
+import org.apache.hadoop.hbase.client.Admin;
import org.apache.hadoop.hbase.client.Connection;
import org.apache.hadoop.hbase.client.ConnectionFactory;
-import org.apache.hadoop.hbase.client.HBaseAdmin;
import org.apache.hadoop.hbase.client.Put;
import org.apache.hadoop.hbase.client.Table;
import org.apache.hadoop.hbase.testclassification.LargeTests;
@@ -70,7 +70,7 @@ public class TestIncrementalBackupWithBulkLoad extends
TestBackupBase {
List<TableName> tables = Lists.newArrayList(table1);
Connection conn = ConnectionFactory.createConnection(conf1);
- HBaseAdmin admin = (HBaseAdmin) conn.getAdmin();
+ Admin admin = conn.getAdmin();
BackupAdminImpl client = new BackupAdminImpl(conn);
BackupRequest request = createBackupRequest(BackupType.FULL, tables,
BACKUP_ROOT_DIR);
@@ -119,7 +119,7 @@ public class TestIncrementalBackupWithBulkLoad extends
TestBackupBase {
// Delete all data in table1
TEST_UTIL.deleteTableData(table1);
// #5.1 - check tables for full restore */
- HBaseAdmin hAdmin = TEST_UTIL.getHBaseAdmin();
+ Admin hAdmin = TEST_UTIL.getAdmin();
// #6 - restore incremental backup for table1
TableName[] tablesRestoreIncMultiple = new TableName[] { table1 };
diff --git
a/hbase-backup/src/test/java/org/apache/hadoop/hbase/backup/TestIncrementalBackupWithFailures.java
b/hbase-backup/src/test/java/org/apache/hadoop/hbase/backup/TestIncrementalBackupWithFailures.java
index f6725d9..546cf41 100644
---
a/hbase-backup/src/test/java/org/apache/hadoop/hbase/backup/TestIncrementalBackupWithFailures.java
+++
b/hbase-backup/src/test/java/org/apache/hadoop/hbase/backup/TestIncrementalBackupWithFailures.java
@@ -32,9 +32,9 @@ import org.apache.hadoop.hbase.backup.impl.BackupAdminImpl;
import org.apache.hadoop.hbase.backup.impl.BackupSystemTable;
import org.apache.hadoop.hbase.backup.impl.TableBackupClient;
import org.apache.hadoop.hbase.backup.impl.TableBackupClient.Stage;
+import org.apache.hadoop.hbase.client.Admin;
import org.apache.hadoop.hbase.client.Connection;
import org.apache.hadoop.hbase.client.ConnectionFactory;
-import org.apache.hadoop.hbase.client.HBaseAdmin;
import org.apache.hadoop.hbase.client.Put;
import org.apache.hadoop.hbase.client.Table;
import org.apache.hadoop.hbase.testclassification.LargeTests;
@@ -90,8 +90,7 @@ public class TestIncrementalBackupWithFailures extends
TestBackupBase {
int NB_ROWS_FAM3 = 6;
insertIntoTable(conn, table1, fam3Name, 3, NB_ROWS_FAM3).close();
- HBaseAdmin admin = null;
- admin = (HBaseAdmin) conn.getAdmin();
+ Admin admin = conn.getAdmin();
BackupAdminImpl client = new BackupAdminImpl(conn);
BackupRequest request = createBackupRequest(BackupType.FULL, tables,
BACKUP_ROOT_DIR);
diff --git
a/hbase-backup/src/test/java/org/apache/hadoop/hbase/backup/TestRemoteBackup.java
b/hbase-backup/src/test/java/org/apache/hadoop/hbase/backup/TestRemoteBackup.java
index 05826e2..2d99e0d 100644
---
a/hbase-backup/src/test/java/org/apache/hadoop/hbase/backup/TestRemoteBackup.java
+++
b/hbase-backup/src/test/java/org/apache/hadoop/hbase/backup/TestRemoteBackup.java
@@ -26,9 +26,9 @@ import org.apache.hadoop.hbase.HBaseTestingUtility;
import org.apache.hadoop.hbase.HColumnDescriptor;
import org.apache.hadoop.hbase.TableName;
import org.apache.hadoop.hbase.backup.util.BackupUtils;
+import org.apache.hadoop.hbase.client.Admin;
import org.apache.hadoop.hbase.client.Connection;
import org.apache.hadoop.hbase.client.ConnectionFactory;
-import org.apache.hadoop.hbase.client.HBaseAdmin;
import org.apache.hadoop.hbase.client.Put;
import org.apache.hadoop.hbase.client.Table;
import org.apache.hadoop.hbase.snapshot.MobSnapshotTestingUtils;
@@ -126,7 +126,7 @@ public class TestRemoteBackup extends TestBackupBase {
tablesRestoreFull, tablesMapFull, false));
// check tables for full restore
- HBaseAdmin hAdmin = TEST_UTIL.getHBaseAdmin();
+ Admin hAdmin = TEST_UTIL.getAdmin();
assertTrue(hAdmin.tableExists(table1_restore));
// #5.2 - checking row count of tables for full restore
diff --git
a/hbase-backup/src/test/java/org/apache/hadoop/hbase/backup/TestRemoteRestore.java
b/hbase-backup/src/test/java/org/apache/hadoop/hbase/backup/TestRemoteRestore.java
index 25ebca2..d670144 100644
---
a/hbase-backup/src/test/java/org/apache/hadoop/hbase/backup/TestRemoteRestore.java
+++
b/hbase-backup/src/test/java/org/apache/hadoop/hbase/backup/TestRemoteRestore.java
@@ -22,7 +22,7 @@ import static org.junit.Assert.assertTrue;
import org.apache.hadoop.hbase.HBaseClassTestRule;
import org.apache.hadoop.hbase.TableName;
import org.apache.hadoop.hbase.backup.util.BackupUtils;
-import org.apache.hadoop.hbase.client.HBaseAdmin;
+import org.apache.hadoop.hbase.client.Admin;
import org.apache.hadoop.hbase.testclassification.LargeTests;
import org.junit.ClassRule;
import org.junit.Test;
@@ -61,7 +61,7 @@ public class TestRemoteRestore extends TestBackupBase {
getBackupAdmin().restore(
BackupUtils.createRestoreRequest(BACKUP_REMOTE_ROOT_DIR, backupId,
false, tableset,
tablemap, false));
- HBaseAdmin hba = TEST_UTIL.getHBaseAdmin();
+ Admin hba = TEST_UTIL.getAdmin();
assertTrue(hba.tableExists(table1_restore));
TEST_UTIL.deleteTable(table1_restore);
hba.close();
diff --git
a/hbase-backup/src/test/java/org/apache/hadoop/hbase/backup/TestRestoreBoundaryTests.java
b/hbase-backup/src/test/java/org/apache/hadoop/hbase/backup/TestRestoreBoundaryTests.java
index 07f57cc..a6808cd 100644
---
a/hbase-backup/src/test/java/org/apache/hadoop/hbase/backup/TestRestoreBoundaryTests.java
+++
b/hbase-backup/src/test/java/org/apache/hadoop/hbase/backup/TestRestoreBoundaryTests.java
@@ -23,7 +23,7 @@ import java.util.List;
import org.apache.hadoop.hbase.HBaseClassTestRule;
import org.apache.hadoop.hbase.TableName;
import org.apache.hadoop.hbase.backup.util.BackupUtils;
-import org.apache.hadoop.hbase.client.HBaseAdmin;
+import org.apache.hadoop.hbase.client.Admin;
import org.apache.hadoop.hbase.testclassification.LargeTests;
import org.junit.ClassRule;
import org.junit.Test;
@@ -55,7 +55,7 @@ public class TestRestoreBoundaryTests extends TestBackupBase {
getBackupAdmin().restore(
BackupUtils.createRestoreRequest(BACKUP_ROOT_DIR, backupId, false,
tableset, tablemap,
false));
- HBaseAdmin hba = TEST_UTIL.getHBaseAdmin();
+ Admin hba = TEST_UTIL.getAdmin();
assertTrue(hba.tableExists(table1_restore));
TEST_UTIL.deleteTable(table1_restore);
}
@@ -76,7 +76,7 @@ public class TestRestoreBoundaryTests extends TestBackupBase {
getBackupAdmin().restore(
BackupUtils.createRestoreRequest(BACKUP_ROOT_DIR, backupId, false,
restore_tableset,
tablemap, false));
- HBaseAdmin hba = TEST_UTIL.getHBaseAdmin();
+ Admin hba = TEST_UTIL.getAdmin();
assertTrue(hba.tableExists(table2_restore));
assertTrue(hba.tableExists(table3_restore));
TEST_UTIL.deleteTable(table2_restore);
diff --git
a/hbase-backup/src/test/java/org/apache/hadoop/hbase/backup/TestSystemTableSnapshot.java
b/hbase-backup/src/test/java/org/apache/hadoop/hbase/backup/TestSystemTableSnapshot.java
index b93fa77..bd29512 100644
---
a/hbase-backup/src/test/java/org/apache/hadoop/hbase/backup/TestSystemTableSnapshot.java
+++
b/hbase-backup/src/test/java/org/apache/hadoop/hbase/backup/TestSystemTableSnapshot.java
@@ -20,7 +20,7 @@ package org.apache.hadoop.hbase.backup;
import org.apache.hadoop.hbase.HBaseClassTestRule;
import org.apache.hadoop.hbase.TableName;
import org.apache.hadoop.hbase.backup.impl.BackupSystemTable;
-import org.apache.hadoop.hbase.client.HBaseAdmin;
+import org.apache.hadoop.hbase.client.Admin;
import org.apache.hadoop.hbase.testclassification.LargeTests;
import org.junit.ClassRule;
import org.junit.experimental.categories.Category;
@@ -47,7 +47,7 @@ public class TestSystemTableSnapshot extends TestBackupBase {
TableName backupSystem = BackupSystemTable.getTableName(conf1);
- HBaseAdmin hba = TEST_UTIL.getHBaseAdmin();
+ Admin hba = TEST_UTIL.getAdmin();
String snapshotName = "sysTable";
hba.snapshot(snapshotName, backupSystem);
diff --git
a/hbase-client/src/main/java/org/apache/hadoop/hbase/AsyncMetaTableAccessor.java
b/hbase-client/src/main/java/org/apache/hadoop/hbase/AsyncMetaTableAccessor.java
index 4a886d1..d04ea52 100644
---
a/hbase-client/src/main/java/org/apache/hadoop/hbase/AsyncMetaTableAccessor.java
+++
b/hbase-client/src/main/java/org/apache/hadoop/hbase/AsyncMetaTableAccessor.java
@@ -47,7 +47,6 @@ import org.apache.hadoop.hbase.client.Scan.ReadType;
import org.apache.hadoop.hbase.client.TableState;
import org.apache.hadoop.hbase.exceptions.DeserializationException;
import org.apache.hadoop.hbase.util.Bytes;
-import org.apache.hadoop.hbase.util.EnvironmentEdgeManager;
import org.apache.hadoop.hbase.util.Pair;
import org.apache.yetus.audience.InterfaceAudience;
import org.slf4j.Logger;
@@ -80,23 +79,17 @@ public class AsyncMetaTableAccessor {
TableName tableName) {
CompletableFuture<Optional<TableState>> future = new CompletableFuture<>();
Get get = new Get(tableName.getName()).addColumn(getTableFamily(),
getStateColumn());
- long time = EnvironmentEdgeManager.currentTime();
- try {
- get.setTimeRange(0, time);
- addListener(metaTable.get(get), (result, error) -> {
- if (error != null) {
- future.completeExceptionally(error);
- return;
- }
- try {
- future.complete(getTableState(result));
- } catch (IOException e) {
- future.completeExceptionally(e);
- }
- });
- } catch (IOException ioe) {
- future.completeExceptionally(ioe);
- }
+ addListener(metaTable.get(get), (result, error) -> {
+ if (error != null) {
+ future.completeExceptionally(error);
+ return;
+ }
+ try {
+ future.complete(getTableState(result));
+ } catch (IOException e) {
+ future.completeExceptionally(e);
+ }
+ });
return future;
}
diff --git
a/hbase-client/src/main/java/org/apache/hadoop/hbase/client/Admin.java
b/hbase-client/src/main/java/org/apache/hadoop/hbase/client/Admin.java
index e2280df..cf12639 100644
--- a/hbase-client/src/main/java/org/apache/hadoop/hbase/client/Admin.java
+++ b/hbase-client/src/main/java/org/apache/hadoop/hbase/client/Admin.java
@@ -60,7 +60,6 @@ import
org.apache.hadoop.hbase.snapshot.HBaseSnapshotException;
import org.apache.hadoop.hbase.snapshot.RestoreSnapshotException;
import org.apache.hadoop.hbase.snapshot.SnapshotCreationException;
import org.apache.hadoop.hbase.snapshot.UnknownSnapshotException;
-import org.apache.hadoop.hbase.util.Bytes;
import org.apache.yetus.audience.InterfaceAudience;
/**
@@ -255,13 +254,14 @@ public interface Admin extends Abortable, Closeable {
Future<Void> createTableAsync(TableDescriptor desc) throws IOException;
/**
- * Creates a new table but does not block and wait for it to come online.
You can use
- * Future.get(long, TimeUnit) to wait on the operation to complete. It may
throw
- * ExecutionException if there was an error while executing the operation or
TimeoutException in
- * case the wait timeout was not long enough to allow the operation to
complete.
- * <p/>
- * Throws IllegalArgumentException Bad table name, if the split keys are
repeated and if the split
- * key has empty byte array.
+ * Creates a new table but does not block and wait for it to come online.
+ * You can use Future.get(long, TimeUnit) to wait on the operation to
complete.
+ * It may throw ExecutionException if there was an error while executing the
operation
+ * or TimeoutException in case the wait timeout was not long enough to allow
the
+ * operation to complete.
+ * Throws IllegalArgumentException Bad table name, if the split keys
+ * are repeated and if the split key has empty byte array.
+ *
* @param desc table descriptor for table
* @param splitKeys keys to check if the table has been created with all
split keys
* @throws IOException if a remote or network exception occurs
@@ -699,29 +699,7 @@ public interface Admin extends Abortable, Closeable {
void move(byte[] encodedRegionName) throws IOException;
/**
- * Move the region <code>rencodedRegionName</code> to
<code>destServerName</code>.
- * @param encodedRegionName The encoded region name; i.e. the hash that
makes up the region name
- * suffix: e.g. if regionname is
- *
<code>TestTable,0094429456,1289497600452.527db22f95c8a9e0116f0cc13c680396.</code>,
- * then the encoded region name is:
<code>527db22f95c8a9e0116f0cc13c680396</code>.
- * @param destServerName The servername of the destination regionserver. If
passed the empty byte
- * array we'll assign to a random server. A server name is made of
host, port and
- * startcode. Here is an example: <code>
host187.example.com,60020,1289493121758</code>
- * @throws IOException if we can't find a region named
<code>encodedRegionName</code>
- * @deprecated Use {@link #move(byte[], ServerName)} instead. And if you
want to move the region
- * to a random server, please use {@link #move(byte[])}.
- */
- @Deprecated
- default void move(byte[] encodedRegionName, byte[] destServerName) throws
IOException {
- if (destServerName == null || destServerName.length == 0) {
- move(encodedRegionName);
- } else {
- move(encodedRegionName,
ServerName.valueOf(Bytes.toString(destServerName)));
- }
- }
-
- /**
- * Move the region <code>rencodedRegionName</code> to
<code>destServerName</code>.
+ * Move the region <code>encodedRegionName</code> to
<code>destServerName</code>.
* @param encodedRegionName The encoded region name; i.e. the hash that
makes up the region name
* suffix: e.g. if regionname is
*
<code>TestTable,0094429456,1289497600452.527db22f95c8a9e0116f0cc13c680396.</code>,
@@ -1063,9 +1041,7 @@ public interface Admin extends Abortable, Closeable {
* @return a {@link RegionMetrics} list of all regions hosted on a region
server
* @throws IOException if a remote or network exception occurs
*/
- default List<RegionMetrics> getRegionMetrics(ServerName serverName) throws
IOException {
- return getRegionMetrics(serverName, null);
- }
+ List<RegionMetrics> getRegionMetrics(ServerName serverName) throws
IOException;
/**
* Get {@link RegionMetrics} of all regions hosted on a regionserver for a
table.
@@ -1656,7 +1632,10 @@ public interface Admin extends Abortable, Closeable {
* </pre></blockquote></div>
*
* @return A MasterCoprocessorRpcChannel instance
+ * @deprecated since 3.0.0, will removed in 4.0.0. This is too low level,
please stop using it any
+ * more. Use the coprocessorService methods in {@link
AsyncAdmin} instead.
*/
+ @Deprecated
CoprocessorRpcChannel coprocessorService();
@@ -1681,7 +1660,10 @@ public interface Admin extends Abortable, Closeable {
*
* @param serverName the server name to which the endpoint call is made
* @return A RegionServerCoprocessorRpcChannel instance
+ * @deprecated since 3.0.0, will removed in 4.0.0. This is too low level,
please stop using it any
+ * more. Use the coprocessorService methods in {@link
AsyncAdmin} instead.
*/
+ @Deprecated
CoprocessorRpcChannel coprocessorService(ServerName serverName);
diff --git
a/hbase-client/src/main/java/org/apache/hadoop/hbase/client/AdminOverAsyncAdmin.java
b/hbase-client/src/main/java/org/apache/hadoop/hbase/client/AdminOverAsyncAdmin.java
new file mode 100644
index 0000000..599e5d6
--- /dev/null
+++
b/hbase-client/src/main/java/org/apache/hadoop/hbase/client/AdminOverAsyncAdmin.java
@@ -0,0 +1,945 @@
+/**
+ * Licensed to the Apache Software Foundation (ASF) under one
+ * or more contributor license agreements. See the NOTICE file
+ * distributed with this work for additional information
+ * regarding copyright ownership. The ASF licenses this file
+ * to you under the Apache License, Version 2.0 (the
+ * "License"); you may not use this file except in compliance
+ * with the License. You may obtain a copy of the License at
+ *
+ * http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing, software
+ * distributed under the License is distributed on an "AS IS" BASIS,
+ * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+ * See the License for the specific language governing permissions and
+ * limitations under the License.
+ */
+package org.apache.hadoop.hbase.client;
+
+import static
org.apache.hadoop.hbase.client.ConnectionUtils.setCoprocessorError;
+import static org.apache.hadoop.hbase.util.FutureUtils.get;
+
+import com.google.protobuf.Descriptors.MethodDescriptor;
+import com.google.protobuf.Message;
+import com.google.protobuf.RpcCallback;
+import com.google.protobuf.RpcChannel;
+import com.google.protobuf.RpcController;
+import com.google.protobuf.ServiceException;
+import java.io.IOException;
+import java.util.Arrays;
+import java.util.EnumSet;
+import java.util.List;
+import java.util.Map;
+import java.util.Set;
+import java.util.concurrent.Future;
+import java.util.regex.Pattern;
+import org.apache.hadoop.conf.Configuration;
+import org.apache.hadoop.hbase.CacheEvictionStats;
+import org.apache.hadoop.hbase.ClusterMetrics;
+import org.apache.hadoop.hbase.ClusterMetrics.Option;
+import org.apache.hadoop.hbase.HConstants;
+import org.apache.hadoop.hbase.NamespaceDescriptor;
+import org.apache.hadoop.hbase.NamespaceNotFoundException;
+import org.apache.hadoop.hbase.RegionMetrics;
+import org.apache.hadoop.hbase.ServerName;
+import org.apache.hadoop.hbase.TableExistsException;
+import org.apache.hadoop.hbase.TableName;
+import org.apache.hadoop.hbase.TableNotFoundException;
+import org.apache.hadoop.hbase.client.replication.TableCFs;
+import org.apache.hadoop.hbase.client.security.SecurityCapability;
+import org.apache.hadoop.hbase.ipc.CoprocessorRpcChannel;
+import org.apache.hadoop.hbase.quotas.QuotaFilter;
+import org.apache.hadoop.hbase.quotas.QuotaSettings;
+import org.apache.hadoop.hbase.quotas.SpaceQuotaSnapshotView;
+import org.apache.hadoop.hbase.regionserver.wal.FailedLogCloseException;
+import org.apache.hadoop.hbase.replication.ReplicationPeerConfig;
+import org.apache.hadoop.hbase.replication.ReplicationPeerDescription;
+import org.apache.hadoop.hbase.replication.SyncReplicationState;
+import org.apache.hadoop.hbase.security.access.GetUserPermissionsRequest;
+import org.apache.hadoop.hbase.security.access.Permission;
+import org.apache.hadoop.hbase.security.access.UserPermission;
+import org.apache.hadoop.hbase.snapshot.HBaseSnapshotException;
+import org.apache.hadoop.hbase.snapshot.RestoreSnapshotException;
+import org.apache.hadoop.hbase.snapshot.SnapshotCreationException;
+import org.apache.hadoop.hbase.snapshot.UnknownSnapshotException;
+import org.apache.hadoop.hbase.util.Bytes;
+import org.apache.yetus.audience.InterfaceAudience;
+import org.slf4j.Logger;
+import org.slf4j.LoggerFactory;
+
+/**
+ * The {@link Admin} implementation which is based on an {@link AsyncAdmin}.
+ */
+@InterfaceAudience.Private
+class AdminOverAsyncAdmin implements Admin {
+
+ private static final Logger LOG =
LoggerFactory.getLogger(AdminOverAsyncAdmin.class);
+
+ private volatile boolean aborted = false;
+
+ private final Connection conn;
+
+ private final RawAsyncHBaseAdmin admin;
+
+ private final int operationTimeout;
+
+ private final int syncWaitTimeout;
+
+ public AdminOverAsyncAdmin(Connection conn, RawAsyncHBaseAdmin admin) {
+ this.conn = conn;
+ this.admin = admin;
+ this.operationTimeout = conn.getConfiguration().getInt(
+ HConstants.HBASE_CLIENT_OPERATION_TIMEOUT,
HConstants.DEFAULT_HBASE_CLIENT_OPERATION_TIMEOUT);
+ this.syncWaitTimeout =
+ conn.getConfiguration().getInt("hbase.client.sync.wait.timeout.msec", 10
* 60000); // 10min
+ }
+
+ @Override
+ public int getOperationTimeout() {
+ return operationTimeout;
+ }
+
+ @Override
+ public int getSyncWaitTimeout() {
+ return syncWaitTimeout;
+ }
+
+ @Override
+ public void abort(String why, Throwable e) {
+ LOG.warn("Aborting becasue of {}", why, e);
+ this.aborted = true;
+ }
+
+ @Override
+ public boolean isAborted() {
+ return aborted;
+ }
+
+ @Override
+ public Connection getConnection() {
+ return conn;
+ }
+
+ @Override
+ public boolean tableExists(TableName tableName) throws IOException {
+ return get(admin.tableExists(tableName));
+ }
+
+ @Override
+ public List<TableDescriptor> listTableDescriptors() throws IOException {
+ return get(admin.listTableDescriptors());
+ }
+
+ @Override
+ public List<TableDescriptor> listTableDescriptors(Pattern pattern, boolean
includeSysTables)
+ throws IOException {
+ return get(admin.listTableDescriptors(pattern, includeSysTables));
+ }
+
+ @Override
+ public TableName[] listTableNames() throws IOException {
+ return get(admin.listTableNames()).toArray(new TableName[0]);
+ }
+
+ @Override
+ public TableName[] listTableNames(Pattern pattern, boolean includeSysTables)
throws IOException {
+ return get(admin.listTableNames(pattern, includeSysTables)).toArray(new
TableName[0]);
+ }
+
+ @Override
+ public TableDescriptor getDescriptor(TableName tableName)
+ throws TableNotFoundException, IOException {
+ return get(admin.getDescriptor(tableName));
+ }
+
+ @Override
+ public void createTable(TableDescriptor desc, byte[] startKey, byte[]
endKey, int numRegions)
+ throws IOException {
+ get(admin.createTable(desc, startKey, endKey, numRegions));
+ }
+
+ @Override
+ public Future<Void> createTableAsync(TableDescriptor desc) throws
IOException {
+ return admin.createTable(desc);
+ }
+
+ @Override
+ public Future<Void> createTableAsync(TableDescriptor desc, byte[][]
splitKeys)
+ throws IOException {
+ return admin.createTable(desc, splitKeys);
+ }
+
+ @Override
+ public Future<Void> deleteTableAsync(TableName tableName) throws IOException
{
+ return admin.deleteTable(tableName);
+ }
+
+ @Override
+ public Future<Void> truncateTableAsync(TableName tableName, boolean
preserveSplits)
+ throws IOException {
+ return admin.truncateTable(tableName, preserveSplits);
+ }
+
+ @Override
+ public Future<Void> enableTableAsync(TableName tableName) throws IOException
{
+ return admin.enableTable(tableName);
+ }
+
+ @Override
+ public Future<Void> disableTableAsync(TableName tableName) throws
IOException {
+ return admin.disableTable(tableName);
+ }
+
+ @Override
+ public boolean isTableEnabled(TableName tableName) throws IOException {
+ return get(admin.isTableEnabled(tableName));
+ }
+
+ @Override
+ public boolean isTableDisabled(TableName tableName) throws IOException {
+ return get(admin.isTableDisabled(tableName));
+ }
+
+ @Override
+ public boolean isTableAvailable(TableName tableName) throws IOException {
+ return get(admin.isTableAvailable(tableName));
+ }
+
+ @Override
+ public Future<Void> addColumnFamilyAsync(TableName tableName,
ColumnFamilyDescriptor columnFamily)
+ throws IOException {
+ return admin.addColumnFamily(tableName, columnFamily);
+ }
+
+ @Override
+ public Future<Void> deleteColumnFamilyAsync(TableName tableName, byte[]
columnFamily)
+ throws IOException {
+ return admin.deleteColumnFamily(tableName, columnFamily);
+ }
+
+ @Override
+ public Future<Void> modifyColumnFamilyAsync(TableName tableName,
+ ColumnFamilyDescriptor columnFamily) throws IOException {
+ return admin.modifyColumnFamily(tableName, columnFamily);
+ }
+
+ @Override
+ public List<RegionInfo> getRegions(ServerName serverName) throws IOException
{
+ return get(admin.getRegions(serverName));
+ }
+
+ @Override
+ public void flush(TableName tableName) throws IOException {
+ get(admin.flush(tableName));
+ }
+
+ @Override
+ public void flushRegion(byte[] regionName) throws IOException {
+ get(admin.flushRegion(regionName));
+ }
+
+ @Override
+ public void flushRegionServer(ServerName serverName) throws IOException {
+ get(admin.flushRegionServer(serverName));
+ }
+
+ @Override
+ public void compact(TableName tableName) throws IOException {
+ get(admin.compact(tableName));
+ }
+
+ @Override
+ public void compactRegion(byte[] regionName) throws IOException {
+ get(admin.compactRegion(regionName));
+ }
+
+ @Override
+ public void compact(TableName tableName, byte[] columnFamily) throws
IOException {
+ get(admin.compact(tableName, columnFamily));
+ }
+
+ @Override
+ public void compactRegion(byte[] regionName, byte[] columnFamily) throws
IOException {
+ get(admin.compactRegion(regionName, columnFamily));
+ }
+
+ @Override
+ public void compact(TableName tableName, CompactType compactType)
+ throws IOException, InterruptedException {
+ get(admin.compact(tableName, compactType));
+ }
+
+ @Override
+ public void compact(TableName tableName, byte[] columnFamily, CompactType
compactType)
+ throws IOException, InterruptedException {
+ get(admin.compact(tableName, columnFamily, compactType));
+ }
+
+ @Override
+ public void majorCompact(TableName tableName) throws IOException {
+ get(admin.majorCompact(tableName));
+ }
+
+ @Override
+ public void majorCompactRegion(byte[] regionName) throws IOException {
+ get(admin.majorCompactRegion(regionName));
+ }
+
+ @Override
+ public void majorCompact(TableName tableName, byte[] columnFamily) throws
IOException {
+ get(admin.majorCompact(tableName, columnFamily));
+ }
+
+ @Override
+ public void majorCompactRegion(byte[] regionName, byte[] columnFamily)
throws IOException {
+ get(admin.majorCompactRegion(regionName, columnFamily));
+ }
+
+ @Override
+ public void majorCompact(TableName tableName, CompactType compactType)
+ throws IOException, InterruptedException {
+ get(admin.majorCompact(tableName, compactType));
+ }
+
+ @Override
+ public void majorCompact(TableName tableName, byte[] columnFamily,
CompactType compactType)
+ throws IOException, InterruptedException {
+ get(admin.majorCompact(tableName, columnFamily, compactType));
+ }
+
+ @Override
+ public Map<ServerName, Boolean> compactionSwitch(boolean switchState,
+ List<String> serverNamesList) throws IOException {
+ return get(admin.compactionSwitch(switchState, serverNamesList));
+ }
+
+ @Override
+ public void compactRegionServer(ServerName serverName) throws IOException {
+ get(admin.compactRegionServer(serverName));
+ }
+
+ @Override
+ public void majorCompactRegionServer(ServerName serverName) throws
IOException {
+ get(admin.majorCompactRegionServer(serverName));
+ }
+
+ @Override
+ public void move(byte[] encodedRegionName) throws IOException {
+ get(admin.move(encodedRegionName));
+ }
+
+ @Override
+ public void move(byte[] encodedRegionName, ServerName destServerName) throws
IOException {
+ get(admin.move(encodedRegionName, destServerName));
+ }
+
+ @Override
+ public void assign(byte[] regionName) throws IOException {
+ get(admin.assign(regionName));
+ }
+
+ @Override
+ public void unassign(byte[] regionName, boolean force) throws IOException {
+ get(admin.unassign(regionName, force));
+ }
+
+ @Override
+ public void offline(byte[] regionName) throws IOException {
+ get(admin.offline(regionName));
+ }
+
+ @Override
+ public boolean balancerSwitch(boolean onOrOff, boolean synchronous) throws
IOException {
+ return get(admin.balancerSwitch(onOrOff, synchronous));
+ }
+
+ @Override
+ public boolean balance() throws IOException {
+ return get(admin.balance());
+ }
+
+ @Override
+ public boolean balance(boolean force) throws IOException {
+ return get(admin.balance(force));
+ }
+
+ @Override
+ public boolean isBalancerEnabled() throws IOException {
+ return get(admin.isBalancerEnabled());
+ }
+
+ @Override
+ public CacheEvictionStats clearBlockCache(TableName tableName) throws
IOException {
+ return get(admin.clearBlockCache(tableName));
+ }
+
+ @Override
+ public boolean normalize() throws IOException {
+ return get(admin.normalize());
+ }
+
+ @Override
+ public boolean isNormalizerEnabled() throws IOException {
+ return get(admin.isNormalizerEnabled());
+ }
+
+ @Override
+ public boolean normalizerSwitch(boolean on) throws IOException {
+ return get(admin.normalizerSwitch(on));
+ }
+
+ @Override
+ public boolean catalogJanitorSwitch(boolean onOrOff) throws IOException {
+ return get(admin.catalogJanitorSwitch(onOrOff));
+ }
+
+ @Override
+ public int runCatalogJanitor() throws IOException {
+ return get(admin.runCatalogJanitor());
+ }
+
+ @Override
+ public boolean isCatalogJanitorEnabled() throws IOException {
+ return get(admin.isCatalogJanitorEnabled());
+ }
+
+ @Override
+ public boolean cleanerChoreSwitch(boolean onOrOff) throws IOException {
+ return get(admin.cleanerChoreSwitch(onOrOff));
+ }
+
+ @Override
+ public boolean runCleanerChore() throws IOException {
+ return get(admin.runCleanerChore());
+ }
+
+ @Override
+ public boolean isCleanerChoreEnabled() throws IOException {
+ return get(admin.isCleanerChoreEnabled());
+ }
+
+ @Override
+ public Future<Void> mergeRegionsAsync(byte[][] nameOfRegionsToMerge, boolean
forcible)
+ throws IOException {
+ return admin.mergeRegions(Arrays.asList(nameOfRegionsToMerge), forcible);
+ }
+
+ @Override
+ public void split(TableName tableName) throws IOException {
+ get(admin.split(tableName));
+ }
+
+ @Override
+ public void split(TableName tableName, byte[] splitPoint) throws IOException
{
+ get(admin.split(tableName, splitPoint));
+ }
+
+ @Override
+ public Future<Void> splitRegionAsync(byte[] regionName) throws IOException {
+ return admin.splitRegion(regionName);
+ }
+
+ @Override
+ public Future<Void> splitRegionAsync(byte[] regionName, byte[] splitPoint)
throws IOException {
+ return admin.splitRegion(regionName, splitPoint);
+ }
+
+ @Override
+ public Future<Void> modifyTableAsync(TableDescriptor td) throws IOException {
+ return admin.modifyTable(td);
+ }
+
+ @Override
+ public void shutdown() throws IOException {
+ get(admin.shutdown());
+ }
+
+ @Override
+ public void stopMaster() throws IOException {
+ get(admin.stopMaster());
+ }
+
+ @Override
+ public boolean isMasterInMaintenanceMode() throws IOException {
+ return get(admin.isMasterInMaintenanceMode());
+ }
+
+ @Override
+ public void stopRegionServer(String hostnamePort) throws IOException {
+ get(admin.stopRegionServer(ServerName.valueOf(hostnamePort, 0)));
+ }
+
+ @Override
+ public ClusterMetrics getClusterMetrics(EnumSet<Option> options) throws
IOException {
+ return get(admin.getClusterMetrics(options));
+ }
+
+ @Override
+ public List<RegionMetrics> getRegionMetrics(ServerName serverName) throws
IOException {
+ return get(admin.getRegionMetrics(serverName));
+ }
+
+ @Override
+ public List<RegionMetrics> getRegionMetrics(ServerName serverName, TableName
tableName)
+ throws IOException {
+ return get(admin.getRegionMetrics(serverName, tableName));
+ }
+
+ @Override
+ public Configuration getConfiguration() {
+ return conn.getConfiguration();
+ }
+
+ @Override
+ public Future<Void> createNamespaceAsync(NamespaceDescriptor descriptor)
throws IOException {
+ return admin.createNamespace(descriptor);
+ }
+
+ @Override
+ public Future<Void> modifyNamespaceAsync(NamespaceDescriptor descriptor)
throws IOException {
+ return admin.modifyNamespace(descriptor);
+ }
+
+ @Override
+ public Future<Void> deleteNamespaceAsync(String name) throws IOException {
+ return admin.deleteNamespace(name);
+ }
+
+ @Override
+ public NamespaceDescriptor getNamespaceDescriptor(String name)
+ throws NamespaceNotFoundException, IOException {
+ return get(admin.getNamespaceDescriptor(name));
+ }
+
+ @Override
+ public String[] listNamespaces() throws IOException {
+ return get(admin.listNamespaces()).toArray(new String[0]);
+ }
+
+ @Override
+ public NamespaceDescriptor[] listNamespaceDescriptors() throws IOException {
+ return get(admin.listNamespaceDescriptors()).toArray(new
NamespaceDescriptor[0]);
+ }
+
+ @Override
+ public List<TableDescriptor> listTableDescriptorsByNamespace(byte[] name)
throws IOException {
+ return get(admin.listTableDescriptorsByNamespace(Bytes.toString(name)));
+ }
+
+ @Override
+ public TableName[] listTableNamesByNamespace(String name) throws IOException
{
+ return get(admin.listTableNamesByNamespace(name)).toArray(new
TableName[0]);
+ }
+
+ @Override
+ public List<RegionInfo> getRegions(TableName tableName) throws IOException {
+ return get(admin.getRegions(tableName));
+ }
+
+ @Override
+ public void close() {
+ // do nothing, AsyncAdmin is not a Closeable.
+ }
+
+ @Override
+ public List<TableDescriptor> listTableDescriptors(List<TableName>
tableNames) throws IOException {
+ return get(admin.listTableDescriptors(tableNames));
+ }
+
+ @Override
+ public Future<Boolean> abortProcedureAsync(long procId, boolean
mayInterruptIfRunning)
+ throws IOException {
+ return admin.abortProcedure(procId, mayInterruptIfRunning);
+ }
+
+ @Override
+ public String getProcedures() throws IOException {
+ return get(admin.getProcedures());
+ }
+
+ @Override
+ public String getLocks() throws IOException {
+ return get(admin.getLocks());
+ }
+
+ @Override
+ public void rollWALWriter(ServerName serverName) throws IOException,
FailedLogCloseException {
+ get(admin.rollWALWriter(serverName));
+ }
+
+ @Override
+ public CompactionState getCompactionState(TableName tableName) throws
IOException {
+ return get(admin.getCompactionState(tableName));
+ }
+
+ @Override
+ public CompactionState getCompactionState(TableName tableName, CompactType
compactType)
+ throws IOException {
+ return get(admin.getCompactionState(tableName, compactType));
+ }
+
+ @Override
+ public CompactionState getCompactionStateForRegion(byte[] regionName) throws
IOException {
+ return get(admin.getCompactionStateForRegion(regionName));
+ }
+
+ @Override
+ public long getLastMajorCompactionTimestamp(TableName tableName) throws
IOException {
+ return get(admin.getLastMajorCompactionTimestamp(tableName)).orElse(0L);
+ }
+
+ @Override
+ public long getLastMajorCompactionTimestampForRegion(byte[] regionName)
throws IOException {
+ return
get(admin.getLastMajorCompactionTimestampForRegion(regionName)).orElse(0L);
+ }
+
+ @Override
+ public void snapshot(SnapshotDescription snapshot)
+ throws IOException, SnapshotCreationException, IllegalArgumentException {
+ get(admin.snapshot(snapshot));
+ }
+
+ @Override
+ public Future<Void> snapshotAsync(SnapshotDescription snapshot)
+ throws IOException, SnapshotCreationException {
+ return admin.snapshot(snapshot);
+ }
+
+ @Override
+ public boolean isSnapshotFinished(SnapshotDescription snapshot)
+ throws IOException, HBaseSnapshotException, UnknownSnapshotException {
+ return get(admin.isSnapshotFinished(snapshot));
+ }
+
+ @Override
+ public void restoreSnapshot(String snapshotName) throws IOException,
RestoreSnapshotException {
+ get(admin.restoreSnapshot(snapshotName));
+ }
+
+ @Override
+ public void restoreSnapshot(String snapshotName, boolean
takeFailSafeSnapshot, boolean restoreAcl)
+ throws IOException, RestoreSnapshotException {
+ get(admin.restoreSnapshot(snapshotName, takeFailSafeSnapshot, restoreAcl));
+ }
+
+ @Override
+ public Future<Void> cloneSnapshotAsync(String snapshotName, TableName
tableName,
+ boolean restoreAcl) throws IOException, TableExistsException,
RestoreSnapshotException {
+ return admin.cloneSnapshot(snapshotName, tableName, restoreAcl);
+ }
+
+ @Override
+ public void execProcedure(String signature, String instance, Map<String,
String> props)
+ throws IOException {
+ get(admin.execProcedure(signature, instance, props));
+ }
+
+ @Override
+ public byte[] execProcedureWithReturn(String signature, String instance,
+ Map<String, String> props) throws IOException {
+ return get(admin.execProcedureWithReturn(signature, instance, props));
+ }
+
+ @Override
+ public boolean isProcedureFinished(String signature, String instance,
Map<String, String> props)
+ throws IOException {
+ return get(admin.isProcedureFinished(signature, instance, props));
+ }
+
+ @Override
+ public List<SnapshotDescription> listSnapshots() throws IOException {
+ return get(admin.listSnapshots());
+ }
+
+ @Override
+ public List<SnapshotDescription> listSnapshots(Pattern pattern) throws
IOException {
+ return get(admin.listSnapshots(pattern));
+ }
+
+ @Override
+ public List<SnapshotDescription> listTableSnapshots(Pattern tableNamePattern,
+ Pattern snapshotNamePattern) throws IOException {
+ return get(admin.listTableSnapshots(tableNamePattern,
snapshotNamePattern));
+ }
+
+ @Override
+ public void deleteSnapshot(String snapshotName) throws IOException {
+ get(admin.deleteSnapshot(snapshotName));
+ }
+
+ @Override
+ public void deleteSnapshots(Pattern pattern) throws IOException {
+ get(admin.deleteSnapshots(pattern));
+ }
+
+ @Override
+ public void deleteTableSnapshots(Pattern tableNamePattern, Pattern
snapshotNamePattern)
+ throws IOException {
+ get(admin.deleteTableSnapshots(tableNamePattern, snapshotNamePattern));
+ }
+
+ @Override
+ public void setQuota(QuotaSettings quota) throws IOException {
+ get(admin.setQuota(quota));
+ }
+
+ @Override
+ public List<QuotaSettings> getQuota(QuotaFilter filter) throws IOException {
+ return get(admin.getQuota(filter));
+ }
+
+ @SuppressWarnings("deprecation")
+ private static final class SyncCoprocessorRpcChannelOverAsync implements
CoprocessorRpcChannel {
+
+ private final RpcChannel delegate;
+
+ public SyncCoprocessorRpcChannelOverAsync(RpcChannel delegate) {
+ this.delegate = delegate;
+ }
+
+ @Override
+ public void callMethod(MethodDescriptor method, RpcController controller,
Message request,
+ Message responsePrototype, RpcCallback<Message> done) {
+ ClientCoprocessorRpcController c = new ClientCoprocessorRpcController();
+ CoprocessorBlockingRpcCallback<Message> callback = new
CoprocessorBlockingRpcCallback<>();
+ delegate.callMethod(method, c, request, responsePrototype, callback);
+ Message ret;
+ try {
+ ret = callback.get();
+ } catch (IOException e) {
+ setCoprocessorError(controller, e);
+ return;
+ }
+ if (c.failed()) {
+ setCoprocessorError(controller, c.getFailed());
+ }
+ done.run(ret);
+ }
+
+ @Override
+ public Message callBlockingMethod(MethodDescriptor method, RpcController
controller,
+ Message request, Message responsePrototype) throws ServiceException {
+ ClientCoprocessorRpcController c = new ClientCoprocessorRpcController();
+ CoprocessorBlockingRpcCallback<Message> done = new
CoprocessorBlockingRpcCallback<>();
+ callMethod(method, c, request, responsePrototype, done);
+ Message ret;
+ try {
+ ret = done.get();
+ } catch (IOException e) {
+ throw new ServiceException(e);
+ }
+ if (c.failed()) {
+ setCoprocessorError(controller, c.getFailed());
+ throw new ServiceException(c.getFailed());
+ }
+ return ret;
+ }
+ }
+
+ @SuppressWarnings("deprecation")
+ @Override
+ public CoprocessorRpcChannel coprocessorService() {
+ return new SyncCoprocessorRpcChannelOverAsync(
+ new MasterCoprocessorRpcChannelImpl(admin.<Message> newMasterCaller()));
+ }
+
+ @SuppressWarnings("deprecation")
+ @Override
+ public CoprocessorRpcChannel coprocessorService(ServerName serverName) {
+ return new SyncCoprocessorRpcChannelOverAsync(new
RegionServerCoprocessorRpcChannelImpl(
+ admin.<Message> newServerCaller().serverName(serverName)));
+ }
+
+ @Override
+ public void updateConfiguration(ServerName server) throws IOException {
+ get(admin.updateConfiguration(server));
+ }
+
+ @Override
+ public void updateConfiguration() throws IOException {
+ get(admin.updateConfiguration());
+ }
+
+ @Override
+ public List<SecurityCapability> getSecurityCapabilities() throws IOException
{
+ return get(admin.getSecurityCapabilities());
+ }
+
+ @Override
+ public boolean splitSwitch(boolean enabled, boolean synchronous) throws
IOException {
+ return get(admin.splitSwitch(enabled, synchronous));
+ }
+
+ @Override
+ public boolean mergeSwitch(boolean enabled, boolean synchronous) throws
IOException {
+ return get(admin.mergeSwitch(enabled, synchronous));
+ }
+
+ @Override
+ public boolean isSplitEnabled() throws IOException {
+ return get(admin.isSplitEnabled());
+ }
+
+ @Override
+ public boolean isMergeEnabled() throws IOException {
+ return get(admin.isMergeEnabled());
+ }
+
+ @Override
+ public Future<Void> addReplicationPeerAsync(String peerId,
ReplicationPeerConfig peerConfig,
+ boolean enabled) throws IOException {
+ return admin.addReplicationPeer(peerId, peerConfig, enabled);
+ }
+
+ @Override
+ public Future<Void> removeReplicationPeerAsync(String peerId) throws
IOException {
+ return admin.removeReplicationPeer(peerId);
+ }
+
+ @Override
+ public Future<Void> enableReplicationPeerAsync(String peerId) throws
IOException {
+ return admin.enableReplicationPeer(peerId);
+ }
+
+ @Override
+ public Future<Void> disableReplicationPeerAsync(String peerId) throws
IOException {
+ return admin.disableReplicationPeer(peerId);
+ }
+
+ @Override
+ public ReplicationPeerConfig getReplicationPeerConfig(String peerId) throws
IOException {
+ return get(admin.getReplicationPeerConfig(peerId));
+ }
+
+ @Override
+ public Future<Void> updateReplicationPeerConfigAsync(String peerId,
+ ReplicationPeerConfig peerConfig) throws IOException {
+ return admin.updateReplicationPeerConfig(peerId, peerConfig);
+ }
+
+ @Override
+ public List<ReplicationPeerDescription> listReplicationPeers() throws
IOException {
+ return get(admin.listReplicationPeers());
+ }
+
+ @Override
+ public List<ReplicationPeerDescription> listReplicationPeers(Pattern
pattern) throws IOException {
+ return get(admin.listReplicationPeers(pattern));
+ }
+
+ @Override
+ public Future<Void> transitReplicationPeerSyncReplicationStateAsync(String
peerId,
+ SyncReplicationState state) throws IOException {
+ return admin.transitReplicationPeerSyncReplicationState(peerId, state);
+ }
+
+ @Override
+ public void decommissionRegionServers(List<ServerName> servers, boolean
offload)
+ throws IOException {
+ get(admin.decommissionRegionServers(servers, offload));
+ }
+
+ @Override
+ public List<ServerName> listDecommissionedRegionServers() throws IOException
{
+ return get(admin.listDecommissionedRegionServers());
+ }
+
+ @Override
+ public void recommissionRegionServer(ServerName server, List<byte[]>
encodedRegionNames)
+ throws IOException {
+ get(admin.recommissionRegionServer(server, encodedRegionNames));
+ }
+
+ @Override
+ public List<TableCFs> listReplicatedTableCFs() throws IOException {
+ return get(admin.listReplicatedTableCFs());
+ }
+
+ @Override
+ public void enableTableReplication(TableName tableName) throws IOException {
+ get(admin.enableTableReplication(tableName));
+ }
+
+ @Override
+ public void disableTableReplication(TableName tableName) throws IOException {
+ get(admin.disableTableReplication(tableName));
+ }
+
+ @Override
+ public void clearCompactionQueues(ServerName serverName, Set<String> queues)
+ throws IOException, InterruptedException {
+ get(admin.clearCompactionQueues(serverName, queues));
+ }
+
+ @Override
+ public List<ServerName> clearDeadServers(List<ServerName> servers) throws
IOException {
+ return get(admin.clearDeadServers(servers));
+ }
+
+ @Override
+ public void cloneTableSchema(TableName tableName, TableName newTableName,
boolean preserveSplits)
+ throws IOException {
+ get(admin.cloneTableSchema(tableName, newTableName, preserveSplits));
+ }
+
+ @Override
+ public boolean switchRpcThrottle(boolean enable) throws IOException {
+ return get(admin.switchRpcThrottle(enable));
+ }
+
+ @Override
+ public boolean isRpcThrottleEnabled() throws IOException {
+ return get(admin.isRpcThrottleEnabled());
+ }
+
+ @Override
+ public boolean exceedThrottleQuotaSwitch(boolean enable) throws IOException {
+ return get(admin.exceedThrottleQuotaSwitch(enable));
+ }
+
+ @Override
+ public Map<TableName, Long> getSpaceQuotaTableSizes() throws IOException {
+ return get(admin.getSpaceQuotaTableSizes());
+ }
+
+ @Override
+ public Map<TableName, ? extends SpaceQuotaSnapshotView>
getRegionServerSpaceQuotaSnapshots(
+ ServerName serverName) throws IOException {
+ return get(admin.getRegionServerSpaceQuotaSnapshots(serverName));
+ }
+
+ @Override
+ public SpaceQuotaSnapshotView getCurrentSpaceQuotaSnapshot(String namespace)
throws IOException {
+ return get(admin.getCurrentSpaceQuotaSnapshot(namespace));
+ }
+
+ @Override
+ public SpaceQuotaSnapshotView getCurrentSpaceQuotaSnapshot(TableName
tableName)
+ throws IOException {
+ return get(admin.getCurrentSpaceQuotaSnapshot(tableName));
+ }
+
+ @Override
+ public void grant(UserPermission userPermission, boolean
mergeExistingPermissions)
+ throws IOException {
+ get(admin.grant(userPermission, mergeExistingPermissions));
+ }
+
+ @Override
+ public void revoke(UserPermission userPermission) throws IOException {
+ get(admin.revoke(userPermission));
+ }
+
+ @Override
+ public List<UserPermission> getUserPermissions(
+ GetUserPermissionsRequest getUserPermissionsRequest) throws IOException {
+ return get(admin.getUserPermissions(getUserPermissionsRequest));
+ }
+
+ @Override
+ public List<Boolean> hasUserPermissions(String userName, List<Permission>
permissions)
+ throws IOException {
+ return get(admin.hasUserPermissions(userName, permissions));
+ }
+}
diff --git
a/hbase-client/src/main/java/org/apache/hadoop/hbase/client/ConnectionOverAsyncConnection.java
b/hbase-client/src/main/java/org/apache/hadoop/hbase/client/ConnectionOverAsyncConnection.java
index 61cc708..dfe7d8f 100644
---
a/hbase-client/src/main/java/org/apache/hadoop/hbase/client/ConnectionOverAsyncConnection.java
+++
b/hbase-client/src/main/java/org/apache/hadoop/hbase/client/ConnectionOverAsyncConnection.java
@@ -102,7 +102,7 @@ class ConnectionOverAsyncConnection implements Connection {
@Override
public Admin getAdmin() throws IOException {
- return oldConn.getAdmin();
+ return new AdminOverAsyncAdmin(this, (RawAsyncHBaseAdmin) conn.getAdmin());
}
@Override
diff --git
a/hbase-client/src/main/java/org/apache/hadoop/hbase/client/ConnectionUtils.java
b/hbase-client/src/main/java/org/apache/hadoop/hbase/client/ConnectionUtils.java
index f55a276..d3ab9de 100644
---
a/hbase-client/src/main/java/org/apache/hadoop/hbase/client/ConnectionUtils.java
+++
b/hbase-client/src/main/java/org/apache/hadoop/hbase/client/ConnectionUtils.java
@@ -51,6 +51,7 @@ import org.apache.hadoop.hbase.ServerName;
import org.apache.hadoop.hbase.TableName;
import org.apache.hadoop.hbase.client.metrics.ScanMetrics;
import org.apache.hadoop.hbase.ipc.HBaseRpcController;
+import org.apache.hadoop.hbase.ipc.ServerRpcController;
import org.apache.hadoop.hbase.security.User;
import org.apache.hadoop.hbase.util.Bytes;
import org.apache.hadoop.hbase.util.ReflectionUtils;
@@ -715,4 +716,21 @@ public final class ConnectionUtils {
pool.shutdownNow();
}
}
+
+ static void setCoprocessorError(com.google.protobuf.RpcController
controller, Throwable error) {
+ if (controller == null) {
+ return;
+ }
+ if (controller instanceof ServerRpcController) {
+ if (error instanceof IOException) {
+ ((ServerRpcController) controller).setFailedOn((IOException) error);
+ } else {
+ ((ServerRpcController) controller).setFailedOn(new IOException(error));
+ }
+ } else if (controller instanceof ClientCoprocessorRpcController) {
+ ((ClientCoprocessorRpcController) controller).setFailed(error);
+ } else {
+ controller.setFailed(error.toString());
+ }
+ }
}
diff --git
a/hbase-client/src/main/java/org/apache/hadoop/hbase/client/CoprocessorBlockingRpcCallback.java
b/hbase-client/src/main/java/org/apache/hadoop/hbase/client/CoprocessorBlockingRpcCallback.java
new file mode 100644
index 0000000..30f6e7e
--- /dev/null
+++
b/hbase-client/src/main/java/org/apache/hadoop/hbase/client/CoprocessorBlockingRpcCallback.java
@@ -0,0 +1,68 @@
+/**
+ * Licensed to the Apache Software Foundation (ASF) under one
+ * or more contributor license agreements. See the NOTICE file
+ * distributed with this work for additional information
+ * regarding copyright ownership. The ASF licenses this file
+ * to you under the Apache License, Version 2.0 (the
+ * "License"); you may not use this file except in compliance
+ * with the License. You may obtain a copy of the License at
+ *
+ * http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing, software
+ * distributed under the License is distributed on an "AS IS" BASIS,
+ * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+ * See the License for the specific language governing permissions and
+ * limitations under the License.
+ */
+package org.apache.hadoop.hbase.client;
+
+import com.google.protobuf.RpcCallback;
+import java.io.IOException;
+import java.io.InterruptedIOException;
+import org.apache.yetus.audience.InterfaceAudience;
+
+/**
+ * For implementation coprocessor related methods in {@link Table} and {@link
Admin} interface.
+ * @deprecated since 3.0.0, will be removed in 4.0.0 along with the
coprocessor related methods in
+ * {@link Table} and {@link Admin} interface.
+ */
+@Deprecated
+@InterfaceAudience.Private
+class CoprocessorBlockingRpcCallback<R> implements RpcCallback<R> {
+ private R result;
+ private boolean resultSet = false;
+
+ /**
+ * Called on completion of the RPC call with the response object, or {@code
null} in the case of
+ * an error.
+ * @param parameter the response object or {@code null} if an error occurred
+ */
+ @Override
+ public void run(R parameter) {
+ synchronized (this) {
+ result = parameter;
+ resultSet = true;
+ this.notifyAll();
+ }
+ }
+
+ /**
+ * Returns the parameter passed to {@link #run(Object)} or {@code null} if a
null value was
+ * passed. When used asynchronously, this method will block until the {@link
#run(Object)} method
+ * has been called.
+ * @return the response object or {@code null} if no response was passed
+ */
+ public synchronized R get() throws IOException {
+ while (!resultSet) {
+ try {
+ this.wait();
+ } catch (InterruptedException ie) {
+ InterruptedIOException exception = new
InterruptedIOException(ie.getMessage());
+ exception.initCause(ie);
+ throw exception;
+ }
+ }
+ return result;
+ }
+}
\ No newline at end of file
diff --git
a/hbase-client/src/main/java/org/apache/hadoop/hbase/client/HBaseAdmin.java
b/hbase-client/src/main/java/org/apache/hadoop/hbase/client/HBaseAdmin.java
index c466e61..9c62678 100644
--- a/hbase-client/src/main/java/org/apache/hadoop/hbase/client/HBaseAdmin.java
+++ b/hbase-client/src/main/java/org/apache/hadoop/hbase/client/HBaseAdmin.java
@@ -1156,10 +1156,10 @@ public class HBaseAdmin implements Admin {
@Override
public void move(byte[] encodedRegionName) throws IOException {
- move(encodedRegionName, (ServerName) null);
+ move(encodedRegionName, null);
}
- public void move(final byte[] encodedRegionName, ServerName destServerName)
throws IOException {
+ public void move(byte[] encodedRegionName, ServerName destServerName) throws
IOException {
executeCallable(new MasterCallable<Void>(getConnection(),
getRpcControllerFactory()) {
@Override
protected Void rpcCall() throws Exception {
@@ -3910,6 +3910,11 @@ public class HBaseAdmin implements Admin {
}
@Override
+ public List<RegionMetrics> getRegionMetrics(ServerName serverName) throws
IOException {
+ return getRegionMetrics(serverName, null);
+ }
+
+ @Override
public Future<Void> createTableAsync(TableDescriptor desc) throws
IOException {
return createTableAsync(desc, null);
}
diff --git
a/hbase-client/src/main/java/org/apache/hadoop/hbase/client/RawAsyncHBaseAdmin.java
b/hbase-client/src/main/java/org/apache/hadoop/hbase/client/RawAsyncHBaseAdmin.java
index b3d3468..47a7902 100644
---
a/hbase-client/src/main/java/org/apache/hadoop/hbase/client/RawAsyncHBaseAdmin.java
+++
b/hbase-client/src/main/java/org/apache/hadoop/hbase/client/RawAsyncHBaseAdmin.java
@@ -360,7 +360,7 @@ class RawAsyncHBaseAdmin implements AsyncAdmin {
this.ng = connection.getNonceGenerator();
}
- private <T> MasterRequestCallerBuilder<T> newMasterCaller() {
+ <T> MasterRequestCallerBuilder<T> newMasterCaller() {
return this.connection.callerFactory.<T> masterRequest()
.rpcTimeout(rpcTimeoutNs, TimeUnit.NANOSECONDS)
.operationTimeout(operationTimeoutNs, TimeUnit.NANOSECONDS)
@@ -702,11 +702,6 @@ class RawAsyncHBaseAdmin implements AsyncAdmin {
@Override
public CompletableFuture<Boolean> isTableAvailable(TableName tableName) {
- return isTableAvailable(tableName, Optional.empty());
- }
-
- private CompletableFuture<Boolean> isTableAvailable(TableName tableName,
- Optional<byte[][]> splitKeys) {
if (TableName.isMetaTableName(tableName)) {
return connection.registry.getMetaRegionLocation().thenApply(locs ->
Stream
.of(locs.getRegionLocations()).allMatch(loc -> loc != null &&
loc.getServerName() != null));
@@ -740,35 +735,13 @@ class RawAsyncHBaseAdmin implements AsyncAdmin {
future.complete(false);
return;
}
-
- Optional<Boolean> available =
- splitKeys.map(keys -> compareRegionsWithSplitKeys(locations,
keys));
- future.complete(available.orElse(true));
+ future.complete(true);
});
}
});
return future;
}
- private boolean compareRegionsWithSplitKeys(List<HRegionLocation> locations,
byte[][] splitKeys) {
- int regionCount = 0;
- for (HRegionLocation location : locations) {
- RegionInfo info = location.getRegion();
- if (Bytes.equals(info.getStartKey(), HConstants.EMPTY_BYTE_ARRAY)) {
- regionCount++;
- continue;
- }
- for (byte[] splitKey : splitKeys) {
- // Just check if the splitkey is available
- if (Bytes.equals(info.getStartKey(), splitKey)) {
- regionCount++;
- break;
- }
- }
- }
- return regionCount == splitKeys.length + 1;
- }
-
@Override
public CompletableFuture<Void> addColumnFamily(TableName tableName,
ColumnFamilyDescriptor columnFamily) {
return this.<AddColumnRequest, AddColumnResponse> procedureCall(tableName,
@@ -2004,10 +1977,8 @@ class RawAsyncHBaseAdmin implements AsyncAdmin {
LOG.error(
"Unable to remove the failsafe snapshot: " +
failSafeSnapshotSnapshotName,
err3);
- future.completeExceptionally(err3);
- } else {
- future.complete(ret3);
}
+ future.complete(ret3);
});
}
});
@@ -3393,7 +3364,7 @@ class RawAsyncHBaseAdmin implements AsyncAdmin {
.call();
}
- private <T> ServerRequestCallerBuilder<T> newServerCaller() {
+ <T> ServerRequestCallerBuilder<T> newServerCaller() {
return this.connection.callerFactory.<T> serverRequest()
.rpcTimeout(rpcTimeoutNs, TimeUnit.NANOSECONDS)
.operationTimeout(operationTimeoutNs, TimeUnit.NANOSECONDS)
diff --git
a/hbase-client/src/main/java/org/apache/hadoop/hbase/client/RegionCoprocessorRpcChannelImpl.java
b/hbase-client/src/main/java/org/apache/hadoop/hbase/client/RegionCoprocessorRpcChannelImpl.java
index 3c25c57..b41727f 100644
---
a/hbase-client/src/main/java/org/apache/hadoop/hbase/client/RegionCoprocessorRpcChannelImpl.java
+++
b/hbase-client/src/main/java/org/apache/hadoop/hbase/client/RegionCoprocessorRpcChannelImpl.java
@@ -17,6 +17,7 @@
*/
package org.apache.hadoop.hbase.client;
+import static
org.apache.hadoop.hbase.client.ConnectionUtils.setCoprocessorError;
import static org.apache.hadoop.hbase.util.FutureUtils.addListener;
import com.google.protobuf.Descriptors.MethodDescriptor;
@@ -32,7 +33,6 @@ import org.apache.hadoop.hbase.HRegionLocation;
import org.apache.hadoop.hbase.TableName;
import org.apache.hadoop.hbase.ipc.CoprocessorRpcUtils;
import org.apache.hadoop.hbase.ipc.HBaseRpcController;
-import org.apache.hadoop.hbase.ipc.ServerRpcController;
import org.apache.hadoop.hbase.util.Bytes;
import org.apache.yetus.audience.InterfaceAudience;
@@ -101,23 +101,6 @@ class RegionCoprocessorRpcChannelImpl implements
RpcChannel {
return future;
}
- protected final void setError(RpcController controller, Throwable error) {
- if (controller == null) {
- return;
- }
- if (controller instanceof ServerRpcController) {
- if (error instanceof IOException) {
- ((ServerRpcController) controller).setFailedOn((IOException) error);
- } else {
- ((ServerRpcController) controller).setFailedOn(new IOException(error));
- }
- } else if (controller instanceof ClientCoprocessorRpcController) {
- ((ClientCoprocessorRpcController) controller).setFailed(error);
- } else {
- controller.setFailed(error.toString());
- }
- }
-
@Override
public void callMethod(MethodDescriptor method, RpcController controller,
Message request,
Message responsePrototype, RpcCallback<Message> done) {
@@ -128,7 +111,7 @@ class RegionCoprocessorRpcChannelImpl implements RpcChannel
{
.action((c, l, s) -> rpcCall(method, request, responsePrototype, c, l,
s)).call(),
(r, e) -> {
if (e != null) {
- setError(controller, e);
+ setCoprocessorError(controller, e);
}
done.run(r);
});
diff --git
a/hbase-client/src/main/java/org/apache/hadoop/hbase/client/SyncCoprocessorRpcChannel.java
b/hbase-client/src/main/java/org/apache/hadoop/hbase/client/SyncCoprocessorRpcChannel.java
index 6b4419d..2811219 100644
---
a/hbase-client/src/main/java/org/apache/hadoop/hbase/client/SyncCoprocessorRpcChannel.java
+++
b/hbase-client/src/main/java/org/apache/hadoop/hbase/client/SyncCoprocessorRpcChannel.java
@@ -36,7 +36,10 @@ import org.apache.hadoop.hbase.ipc.CoprocessorRpcUtils;
* call coprocessor endpoint {@link com.google.protobuf.Service}s.
* Note that clients should not use this class directly, except through
* {@link org.apache.hadoop.hbase.client.Table#coprocessorService(byte[])}.
+ * @deprecated Please stop using this class again, as it is too low level,
which is part of the rpc
+ * framework for HBase. Will be deleted in 4.0.0.
*/
+@Deprecated
@InterfaceAudience.Public
abstract class SyncCoprocessorRpcChannel implements CoprocessorRpcChannel {
private static final Logger LOG =
LoggerFactory.getLogger(SyncCoprocessorRpcChannel.class);
diff --git
a/hbase-client/src/main/java/org/apache/hadoop/hbase/client/TableOverAsyncTable.java
b/hbase-client/src/main/java/org/apache/hadoop/hbase/client/TableOverAsyncTable.java
index d581611..30e3062 100644
---
a/hbase-client/src/main/java/org/apache/hadoop/hbase/client/TableOverAsyncTable.java
+++
b/hbase-client/src/main/java/org/apache/hadoop/hbase/client/TableOverAsyncTable.java
@@ -17,6 +17,8 @@
*/
package org.apache.hadoop.hbase.client;
+import static
org.apache.hadoop.hbase.client.ConnectionUtils.setCoprocessorError;
+
import com.google.protobuf.Descriptors.MethodDescriptor;
import com.google.protobuf.Message;
import com.google.protobuf.RpcCallback;
@@ -298,44 +300,7 @@ class TableOverAsyncTable implements Table {
public void close() {
}
- private static final class BlockingRpcCallback<R> implements RpcCallback<R> {
- private R result;
- private boolean resultSet = false;
-
- /**
- * Called on completion of the RPC call with the response object, or
{@code null} in the case of
- * an error.
- * @param parameter the response object or {@code null} if an error
occurred
- */
- @Override
- public void run(R parameter) {
- synchronized (this) {
- result = parameter;
- resultSet = true;
- this.notifyAll();
- }
- }
-
- /**
- * Returns the parameter passed to {@link #run(Object)} or {@code null} if
a null value was
- * passed. When used asynchronously, this method will block until the
{@link #run(Object)}
- * method has been called.
- * @return the response object or {@code null} if no response was passed
- */
- public synchronized R get() throws IOException {
- while (!resultSet) {
- try {
- this.wait();
- } catch (InterruptedException ie) {
- InterruptedIOException exception = new
InterruptedIOException(ie.getMessage());
- exception.initCause(ie);
- throw exception;
- }
- }
- return result;
- }
- }
-
+ @SuppressWarnings("deprecation")
private static final class RegionCoprocessorRpcChannel extends
RegionCoprocessorRpcChannelImpl
implements CoprocessorRpcChannel {
@@ -348,17 +313,17 @@ class TableOverAsyncTable implements Table {
public void callMethod(MethodDescriptor method, RpcController controller,
Message request,
Message responsePrototype, RpcCallback<Message> done) {
ClientCoprocessorRpcController c = new ClientCoprocessorRpcController();
- BlockingRpcCallback<Message> callback = new BlockingRpcCallback<>();
+ CoprocessorBlockingRpcCallback<Message> callback = new
CoprocessorBlockingRpcCallback<>();
super.callMethod(method, c, request, responsePrototype, callback);
Message ret;
try {
ret = callback.get();
} catch (IOException e) {
- setError(controller, e);
+ setCoprocessorError(controller, e);
return;
}
if (c.failed()) {
- setError(controller, c.getFailed());
+ setCoprocessorError(controller, c.getFailed());
}
done.run(ret);
}
@@ -367,7 +332,7 @@ class TableOverAsyncTable implements Table {
public Message callBlockingMethod(MethodDescriptor method, RpcController
controller,
Message request, Message responsePrototype) throws ServiceException {
ClientCoprocessorRpcController c = new ClientCoprocessorRpcController();
- BlockingRpcCallback<Message> done = new BlockingRpcCallback<>();
+ CoprocessorBlockingRpcCallback<Message> done = new
CoprocessorBlockingRpcCallback<>();
callMethod(method, c, request, responsePrototype, done);
Message ret;
try {
@@ -376,7 +341,7 @@ class TableOverAsyncTable implements Table {
throw new ServiceException(e);
}
if (c.failed()) {
- setError(controller, c.getFailed());
+ setCoprocessorError(controller, c.getFailed());
throw new ServiceException(c.getFailed());
}
return ret;
diff --git
a/hbase-client/src/test/java/org/apache/hadoop/hbase/client/TestInterfaceAlign.java
b/hbase-client/src/test/java/org/apache/hadoop/hbase/client/TestInterfaceAlign.java
index 953fba7..3c8b04d 100644
---
a/hbase-client/src/test/java/org/apache/hadoop/hbase/client/TestInterfaceAlign.java
+++
b/hbase-client/src/test/java/org/apache/hadoop/hbase/client/TestInterfaceAlign.java
@@ -57,6 +57,8 @@ public class TestInterfaceAlign {
adminMethodNames.removeAll(getMethodNames(Abortable.class));
adminMethodNames.removeAll(getMethodNames(Closeable.class));
+ asyncAdminMethodNames.remove("coprocessorService");
+
adminMethodNames.forEach(method -> {
boolean contains = asyncAdminMethodNames.contains(method);
if (method.endsWith("Async")) {
diff --git
a/hbase-mapreduce/src/test/java/org/apache/hadoop/hbase/PerformanceEvaluation.java
b/hbase-mapreduce/src/test/java/org/apache/hadoop/hbase/PerformanceEvaluation.java
index 2dae0e8..7972da0 100644
---
a/hbase-mapreduce/src/test/java/org/apache/hadoop/hbase/PerformanceEvaluation.java
+++
b/hbase-mapreduce/src/test/java/org/apache/hadoop/hbase/PerformanceEvaluation.java
@@ -383,7 +383,11 @@ public class PerformanceEvaluation extends Configured
implements Tool {
}
}
}
- admin.createTable(desc, splits);
+ if (splits != null) {
+ admin.createTable(desc, splits);
+ } else {
+ admin.createTable(desc);
+ }
LOG.info("Table " + desc + " created");
}
return admin.tableExists(tableName);
diff --git
a/hbase-rest/src/test/java/org/apache/hadoop/hbase/rest/client/TestRemoteTable.java
b/hbase-rest/src/test/java/org/apache/hadoop/hbase/rest/client/TestRemoteTable.java
index 1d7a37c..d5247fb 100644
---
a/hbase-rest/src/test/java/org/apache/hadoop/hbase/rest/client/TestRemoteTable.java
+++
b/hbase-rest/src/test/java/org/apache/hadoop/hbase/rest/client/TestRemoteTable.java
@@ -600,8 +600,8 @@ public class TestRemoteTable {
REST_TEST_UTIL.startServletContainer(TEST_UTIL.getConfiguration());
// Truncate the test table for inserting test scenarios rows keys
- TEST_UTIL.getHBaseAdmin().disableTable(TABLE);
- TEST_UTIL.getHBaseAdmin().truncateTable(TABLE, false);
+ TEST_UTIL.getAdmin().disableTable(TABLE);
+ TEST_UTIL.getAdmin().truncateTable(TABLE, false);
remoteTable = new RemoteHTable(
new Client(new Cluster().add("localhost",
REST_TEST_UTIL.getServletPort())),
diff --git
a/hbase-server/src/test/java/org/apache/hadoop/hbase/HBaseTestingUtility.java
b/hbase-server/src/test/java/org/apache/hadoop/hbase/HBaseTestingUtility.java
index 58a3f10..afca997 100644
---
a/hbase-server/src/test/java/org/apache/hadoop/hbase/HBaseTestingUtility.java
+++
b/hbase-server/src/test/java/org/apache/hadoop/hbase/HBaseTestingUtility.java
@@ -74,7 +74,6 @@ import org.apache.hadoop.hbase.client.Consistency;
import org.apache.hadoop.hbase.client.Delete;
import org.apache.hadoop.hbase.client.Durability;
import org.apache.hadoop.hbase.client.Get;
-import org.apache.hadoop.hbase.client.HBaseAdmin;
import org.apache.hadoop.hbase.client.Hbck;
import org.apache.hadoop.hbase.client.ImmutableHRegionInfo;
import org.apache.hadoop.hbase.client.ImmutableHTableDescriptor;
@@ -1590,7 +1589,11 @@ public class HBaseTestingUtility extends
HBaseZKTestingUtility {
builder.setColumnFamily(cfdb.build());
}
TableDescriptor td = builder.build();
- getAdmin().createTable(td, splitKeys);
+ if (splitKeys != null) {
+ getAdmin().createTable(td, splitKeys);
+ } else {
+ getAdmin().createTable(td);
+ }
// HBaseAdmin only waits for regions to appear in hbase:meta
// we should wait until they are assigned
waitUntilAllRegionsAssigned(td.getTableName());
@@ -1613,7 +1616,11 @@ public class HBaseTestingUtility extends
HBaseZKTestingUtility {
.setNewVersionBehavior(true).build());
}
}
- getAdmin().createTable(builder.build(), splitRows);
+ if (splitRows != null) {
+ getAdmin().createTable(builder.build(), splitRows);
+ } else {
+ getAdmin().createTable(builder.build());
+ }
// HBaseAdmin only waits for regions to appear in hbase:meta
// we should wait until they are assigned
waitUntilAllRegionsAssigned(htd.getTableName());
@@ -1682,7 +1689,11 @@ public class HBaseTestingUtility extends
HBaseZKTestingUtility {
}
desc.addFamily(hcd);
}
- getAdmin().createTable(desc, splitKeys);
+ if (splitKeys != null) {
+ getAdmin().createTable(desc, splitKeys);
+ } else {
+ getAdmin().createTable(desc);
+ }
// HBaseAdmin only waits for regions to appear in hbase:meta we should
wait until they are
// assigned
waitUntilAllRegionsAssigned(tableName);
@@ -3031,36 +3042,17 @@ public class HBaseTestingUtility extends
HBaseZKTestingUtility {
}
/**
- * Returns a Admin instance.
- * This instance is shared between HBaseTestingUtility instance users.
Closing it has no effect,
- * it will be closed automatically when the cluster shutdowns
- *
- * @return HBaseAdmin instance which is guaranteed to support only {@link
Admin} interface.
- * Functions in HBaseAdmin not provided by {@link Admin} interface can be
changed/deleted
- * anytime.
- * @deprecated Since 2.0. Will be removed in 3.0. Use {@link #getAdmin()}
instead.
- */
- @Deprecated
- public synchronized HBaseAdmin getHBaseAdmin()
- throws IOException {
- if (hbaseAdmin == null){
- this.hbaseAdmin = (HBaseAdmin) getConnection().getAdmin();
- }
- return hbaseAdmin;
- }
-
- /**
* Returns an Admin instance which is shared between HBaseTestingUtility
instance users.
* Closing it has no effect, it will be closed automatically when the
cluster shutdowns
*/
public synchronized Admin getAdmin() throws IOException {
if (hbaseAdmin == null){
- this.hbaseAdmin = (HBaseAdmin) getConnection().getAdmin();
+ this.hbaseAdmin = getConnection().getAdmin();
}
return hbaseAdmin;
}
- private HBaseAdmin hbaseAdmin = null;
+ private Admin hbaseAdmin = null;
/**
* Returns an {@link Hbck} instance. Needs be closed when done.
diff --git
a/hbase-server/src/test/java/org/apache/hadoop/hbase/client/TestAdmin1.java
b/hbase-server/src/test/java/org/apache/hadoop/hbase/client/TestAdmin1.java
index e2aad9d..d08c5d4 100644
--- a/hbase-server/src/test/java/org/apache/hadoop/hbase/client/TestAdmin1.java
+++ b/hbase-server/src/test/java/org/apache/hadoop/hbase/client/TestAdmin1.java
@@ -45,6 +45,7 @@ import org.apache.hadoop.hbase.testclassification.ClientTests;
import org.apache.hadoop.hbase.testclassification.LargeTests;
import org.apache.hadoop.hbase.util.Bytes;
import org.apache.hadoop.hbase.util.FSUtils;
+import org.apache.hadoop.hbase.util.FutureUtils;
import org.apache.hadoop.hbase.util.Pair;
import org.apache.hadoop.hbase.util.Threads;
import org.junit.ClassRule;
@@ -273,7 +274,11 @@ public class TestAdmin1 extends TestAdminBase {
// Split the table
if (async) {
- ADMIN.split(tableName, splitPoint);
+ if (splitPoint != null) {
+ ADMIN.split(tableName, splitPoint);
+ } else {
+ ADMIN.split(tableName);
+ }
final AtomicInteger count = new AtomicInteger(0);
Thread t = new Thread("CheckForSplit") {
@Override
@@ -391,7 +396,8 @@ public class TestAdmin1 extends TestAdminBase {
// the element at index 1 would be a replica (since the metareader gives
us ordered
// regions). Try splitting that region via the split API . Should fail
try {
-
TEST_UTIL.getAdmin().splitRegionAsync(regions.get(1).getFirst().getRegionName()).get();
+ FutureUtils.get(
+
TEST_UTIL.getAdmin().splitRegionAsync(regions.get(1).getFirst().getRegionName()));
} catch (IllegalArgumentException ex) {
gotException = true;
}
@@ -401,9 +407,9 @@ public class TestAdmin1 extends TestAdminBase {
// regions). Try splitting that region via a different split API (the
difference is
// this API goes direct to the regionserver skipping any checks in the
admin). Should fail
try {
- TEST_UTIL.getHBaseAdmin().splitRegionAsync(regions.get(1).getFirst(),
- new byte[] { (byte) '1' });
- } catch (IOException ex) {
+ FutureUtils.get(TEST_UTIL.getAdmin().splitRegionAsync(
+ regions.get(1).getFirst().getEncodedNameAsBytes(), new byte[] { (byte)
'1' }));
+ } catch (IllegalArgumentException ex) {
gotException = true;
}
assertTrue(gotException);
@@ -411,9 +417,8 @@ public class TestAdmin1 extends TestAdminBase {
gotException = false;
// testing Sync split operation
try {
- TEST_UTIL.getAdmin()
- .splitRegionAsync(regions.get(1).getFirst().getRegionName(), new
byte[] { (byte) '1' })
- .get();
+ FutureUtils.get(TEST_UTIL.getAdmin()
+ .splitRegionAsync(regions.get(1).getFirst().getRegionName(), new
byte[] { (byte) '1' }));
} catch (IllegalArgumentException ex) {
gotException = true;
}
@@ -422,8 +427,10 @@ public class TestAdmin1 extends TestAdminBase {
gotException = false;
// Try merging a replica with another. Should fail.
try {
-
TEST_UTIL.getAdmin().mergeRegionsAsync(regions.get(1).getFirst().getEncodedNameAsBytes(),
- regions.get(2).getFirst().getEncodedNameAsBytes(), true).get();
+ FutureUtils.get(TEST_UTIL.getAdmin().mergeRegionsAsync(
+ regions.get(1).getFirst().getEncodedNameAsBytes(),
+ regions.get(2).getFirst().getEncodedNameAsBytes(),
+ true));
} catch (IllegalArgumentException m) {
gotException = true;
}
@@ -435,8 +442,8 @@ public class TestAdmin1 extends TestAdminBase {
nameofRegionsToMerge[1] =
regions.get(2).getFirst().getEncodedNameAsBytes();
MergeTableRegionsRequest request =
RequestConverter.buildMergeTableRegionsRequest(
nameofRegionsToMerge, true, HConstants.NO_NONCE, HConstants.NO_NONCE);
- ((ConnectionImplementation)
TEST_UTIL.getAdmin().getConnection()).getMaster()
- .mergeTableRegions(null, request);
+
TEST_UTIL.getMiniHBaseCluster().getMaster().getMasterRpcServices().mergeTableRegions(null,
+ request);
} catch (org.apache.hbase.thirdparty.com.google.protobuf.ServiceException
m) {
Throwable t = m.getCause();
do {
@@ -568,24 +575,24 @@ public class TestAdmin1 extends TestAdminBase {
List<RegionInfo> tableRegions = ADMIN.getRegions(tableName);
// 0
try {
- ADMIN.mergeRegionsAsync(new byte[0][0], false).get();
+ FutureUtils.get(ADMIN.mergeRegionsAsync(new byte[0][0], false));
fail();
} catch (IllegalArgumentException e) {
// expected
}
// 1
try {
- ADMIN.mergeRegionsAsync(new byte[][] {
tableRegions.get(0).getEncodedNameAsBytes() }, false)
- .get();
+ FutureUtils.get(ADMIN
+ .mergeRegionsAsync(new byte[][] {
tableRegions.get(0).getEncodedNameAsBytes() }, false));
fail();
} catch (IllegalArgumentException e) {
// expected
}
// 3
try {
- ADMIN.mergeRegionsAsync(
+ FutureUtils.get(ADMIN.mergeRegionsAsync(
tableRegions.stream().map(RegionInfo::getEncodedNameAsBytes).toArray(byte[][]::new),
- false).get();
+ false));
fail();
} catch (DoNotRetryIOException e) {
// expected
diff --git
a/hbase-server/src/test/java/org/apache/hadoop/hbase/client/TestAdmin2.java
b/hbase-server/src/test/java/org/apache/hadoop/hbase/client/TestAdmin2.java
index 2210abf..59c4556 100644
--- a/hbase-server/src/test/java/org/apache/hadoop/hbase/client/TestAdmin2.java
+++ b/hbase-server/src/test/java/org/apache/hadoop/hbase/client/TestAdmin2.java
@@ -35,7 +35,6 @@ import org.apache.hadoop.hbase.ClusterMetrics.Option;
import org.apache.hadoop.hbase.HBaseClassTestRule;
import org.apache.hadoop.hbase.HColumnDescriptor;
import org.apache.hadoop.hbase.HConstants;
-import org.apache.hadoop.hbase.HRegionLocation;
import org.apache.hadoop.hbase.HTableDescriptor;
import org.apache.hadoop.hbase.MiniHBaseCluster;
import org.apache.hadoop.hbase.ServerName;
@@ -57,7 +56,6 @@ import org.apache.hadoop.hbase.regionserver.HStore;
import org.apache.hadoop.hbase.testclassification.ClientTests;
import org.apache.hadoop.hbase.testclassification.LargeTests;
import org.apache.hadoop.hbase.util.Bytes;
-import org.apache.hadoop.hbase.util.Pair;
import org.apache.hadoop.hbase.wal.AbstractFSWALProvider;
import org.junit.Assert;
import org.junit.ClassRule;
@@ -169,7 +167,7 @@ public class TestAdmin2 extends TestAdminBase {
// Use 80 bit numbers to make sure we aren't limited
byte [] startKey = { 1, 1, 1, 1, 1, 1, 1, 1, 1, 1 };
byte [] endKey = { 9, 9, 9, 9, 9, 9, 9, 9, 9, 9 };
- Admin hbaseadmin = TEST_UTIL.getHBaseAdmin();
+ Admin hbaseadmin = TEST_UTIL.getAdmin();
HTableDescriptor htd = new HTableDescriptor(TableName.valueOf(name));
htd.addFamily(new HColumnDescriptor(HConstants.CATALOG_FAMILY));
hbaseadmin.createTable(htd, startKey, endKey, expectedRegions);
@@ -349,14 +347,14 @@ public class TestAdmin2 extends TestAdminBase {
isInList);
}
- private HBaseAdmin createTable(TableName tableName) throws IOException {
- HBaseAdmin admin = TEST_UTIL.getHBaseAdmin();
+ private Admin createTable(TableName tableName) throws IOException {
+ Admin admin = TEST_UTIL.getAdmin();
HTableDescriptor htd = new HTableDescriptor(tableName);
HColumnDescriptor hcd = new HColumnDescriptor("value");
htd.addFamily(hcd);
- admin.createTable(htd, null);
+ admin.createTable(htd);
return admin;
}
@@ -369,7 +367,7 @@ public class TestAdmin2 extends TestAdminBase {
HColumnDescriptor hcd = new HColumnDescriptor("value");
htd.addFamily(hcd);
- ADMIN.createTable(htd, null);
+ ADMIN.createTable(htd);
}
/**
@@ -545,7 +543,7 @@ public class TestAdmin2 extends TestAdminBase {
new
HTableDescriptor(TableName.valueOf(Bytes.toBytes(name.getMethodName())));
HColumnDescriptor hcd = new HColumnDescriptor(Bytes.toBytes("cf1"));
htd.addFamily(hcd);
- TEST_UTIL.getHBaseAdmin().createTable(htd);
+ TEST_UTIL.getAdmin().createTable(htd);
}
@Test
@@ -564,27 +562,6 @@ public class TestAdmin2 extends TestAdminBase {
}
@Test
- public void testGetRegion() throws Exception {
- // We use actual HBaseAdmin instance instead of going via Admin interface
in
- // here because makes use of an internal HBA method (TODO: Fix.).
- HBaseAdmin rawAdmin = TEST_UTIL.getHBaseAdmin();
-
- final TableName tableName = TableName.valueOf(name.getMethodName());
- LOG.info("Started " + tableName);
- Table t = TEST_UTIL.createMultiRegionTable(tableName,
HConstants.CATALOG_FAMILY);
-
- try (RegionLocator locator =
TEST_UTIL.getConnection().getRegionLocator(tableName)) {
- HRegionLocation regionLocation =
locator.getRegionLocation(Bytes.toBytes("mmm"));
- RegionInfo region = regionLocation.getRegionInfo();
- byte[] regionName = region.getRegionName();
- Pair<RegionInfo, ServerName> pair = rawAdmin.getRegion(regionName);
- assertTrue(Bytes.equals(regionName, pair.getFirst().getRegionName()));
- pair = rawAdmin.getRegion(region.getEncodedNameAsBytes());
- assertTrue(Bytes.equals(regionName, pair.getFirst().getRegionName()));
- }
- }
-
- @Test
public void testBalancer() throws Exception {
boolean initialState = ADMIN.isBalancerEnabled();
diff --git
a/hbase-server/src/test/java/org/apache/hadoop/hbase/client/TestFromClientSide.java
b/hbase-server/src/test/java/org/apache/hadoop/hbase/client/TestFromClientSide.java
index 6d27044..46bd729 100644
---
a/hbase-server/src/test/java/org/apache/hadoop/hbase/client/TestFromClientSide.java
+++
b/hbase-server/src/test/java/org/apache/hadoop/hbase/client/TestFromClientSide.java
@@ -4249,8 +4249,7 @@ public class TestFromClientSide {
final TableName tableName = TableName.valueOf(name.getMethodName());
TEST_UTIL.createTable(tableName, HConstants.CATALOG_FAMILY);
try (Connection conn =
ConnectionFactory.createConnection(TEST_UTIL.getConfiguration())) {
- try (Table t = conn.getTable(tableName);
- Admin admin = conn.getAdmin()) {
+ try (Table t = conn.getTable(tableName); Admin admin = conn.getAdmin()) {
assertTrue(admin.tableExists(tableName));
assertTrue(t.get(new Get(ROW)).isEmpty());
}
@@ -4269,8 +4268,8 @@ public class TestFromClientSide {
boolean tablesOnMaster =
LoadBalancer.isTablesOnMaster(TEST_UTIL.getConfiguration());
try (Admin admin = conn.getAdmin()) {
assertTrue(admin.tableExists(tableName));
- assertTrue(admin.getClusterMetrics(EnumSet.of(Option.LIVE_SERVERS))
- .getLiveServerMetrics().size() == SLAVES + (tablesOnMaster ? 1
: 0));
+
assertTrue(admin.getClusterMetrics(EnumSet.of(Option.LIVE_SERVERS)).getLiveServerMetrics()
+ .size() == SLAVES + (tablesOnMaster ? 1 : 0));
}
}
}
diff --git
a/hbase-server/src/test/java/org/apache/hadoop/hbase/client/TestFromClientSide3.java
b/hbase-server/src/test/java/org/apache/hadoop/hbase/client/TestFromClientSide3.java
index 83becbc..3b3f636 100644
---
a/hbase-server/src/test/java/org/apache/hadoop/hbase/client/TestFromClientSide3.java
+++
b/hbase-server/src/test/java/org/apache/hadoop/hbase/client/TestFromClientSide3.java
@@ -272,13 +272,13 @@ public class TestFromClientSide3 {
TEST_UTIL.getConfiguration().setInt("hbase.hstore.compaction.min", 3);
final TableName tableName = TableName.valueOf(name.getMethodName());
- try (Table hTable = TEST_UTIL.createTable(tableName, FAMILY, 10)) {
+ try (Table table = TEST_UTIL.createTable(tableName, FAMILY, 10)) {
TEST_UTIL.waitTableAvailable(tableName, WAITTABLE_MILLIS);
Admin admin = TEST_UTIL.getAdmin();
// Create 3 store files.
byte[] row = Bytes.toBytes(random.nextInt());
- performMultiplePutAndFlush(admin, hTable, row, FAMILY, 3, 100);
+ performMultiplePutAndFlush(admin, table, row, FAMILY, 3, 100);
try (RegionLocator locator =
TEST_UTIL.getConnection().getRegionLocator(tableName)) {
// Verify we have multiple store files.
@@ -304,13 +304,13 @@ public class TestFromClientSide3 {
// change the compaction.min config option for this table to 5
LOG.info("hbase.hstore.compaction.min should now be 5");
- HTableDescriptor htd = new HTableDescriptor(hTable.getDescriptor());
+ HTableDescriptor htd = new HTableDescriptor(table.getDescriptor());
htd.setValue("hbase.hstore.compaction.min", String.valueOf(5));
admin.modifyTable(htd);
LOG.info("alter status finished");
// Create 3 more store files.
- performMultiplePutAndFlush(admin, hTable, row, FAMILY, 3, 10);
+ performMultiplePutAndFlush(admin, table, row, FAMILY, 3, 10);
// Issue a compaction request
admin.compact(tableName);
@@ -357,7 +357,7 @@ public class TestFromClientSide3 {
htd.modifyFamily(hcd);
admin.modifyTable(htd);
LOG.info("alter status finished");
- assertNull(hTable.getDescriptor().getColumnFamily(FAMILY)
+ assertNull(table.getDescriptor().getColumnFamily(FAMILY)
.getValue(Bytes.toBytes("hbase.hstore.compaction.min")));
}
}
diff --git
a/hbase-server/src/test/java/org/apache/hadoop/hbase/client/TestSnapshotDFSTemporaryDirectory.java
b/hbase-server/src/test/java/org/apache/hadoop/hbase/client/TestSnapshotDFSTemporaryDirectory.java
index b4cef33..7501867 100644
---
a/hbase-server/src/test/java/org/apache/hadoop/hbase/client/TestSnapshotDFSTemporaryDirectory.java
+++
b/hbase-server/src/test/java/org/apache/hadoop/hbase/client/TestSnapshotDFSTemporaryDirectory.java
@@ -50,10 +50,11 @@ public class TestSnapshotDFSTemporaryDirectory
*
* @throws Exception on failure
*/
- @BeforeClass public static void setupCluster() throws Exception {
+ @BeforeClass
+ public static void setupCluster() throws Exception {
setupConf(UTIL.getConfiguration());
UTIL.startMiniCluster(NUM_RS);
- admin = UTIL.getHBaseAdmin();
+ admin = UTIL.getAdmin();
}
private static void setupConf(Configuration conf) throws IOException {
diff --git
a/hbase-server/src/test/java/org/apache/hadoop/hbase/client/TestSnapshotTemporaryDirectory.java
b/hbase-server/src/test/java/org/apache/hadoop/hbase/client/TestSnapshotTemporaryDirectory.java
index b1def75..face3a2 100644
---
a/hbase-server/src/test/java/org/apache/hadoop/hbase/client/TestSnapshotTemporaryDirectory.java
+++
b/hbase-server/src/test/java/org/apache/hadoop/hbase/client/TestSnapshotTemporaryDirectory.java
@@ -104,7 +104,7 @@ public class TestSnapshotTemporaryDirectory {
public static void setupCluster() throws Exception {
setupConf(UTIL.getConfiguration());
UTIL.startMiniCluster(NUM_RS);
- admin = UTIL.getHBaseAdmin();
+ admin = UTIL.getAdmin();
}
private static void setupConf(Configuration conf) {
@@ -139,7 +139,7 @@ public class TestSnapshotTemporaryDirectory {
@After
public void tearDown() throws Exception {
UTIL.deleteTable(TABLE_NAME);
- SnapshotTestingUtils.deleteAllSnapshots(UTIL.getHBaseAdmin());
+ SnapshotTestingUtils.deleteAllSnapshots(UTIL.getAdmin());
SnapshotTestingUtils.deleteArchiveDirectory(UTIL);
}
@@ -290,7 +290,7 @@ public class TestSnapshotTemporaryDirectory {
*/
@Test
public void testOfflineTableSnapshot() throws Exception {
- Admin admin = UTIL.getHBaseAdmin();
+ Admin admin = UTIL.getAdmin();
// make sure we don't fail on listing snapshots
SnapshotTestingUtils.assertNoSnapshots(admin);
diff --git
a/hbase-server/src/test/java/org/apache/hadoop/hbase/client/TestSplitOrMergeStatus.java
b/hbase-server/src/test/java/org/apache/hadoop/hbase/client/TestSplitOrMergeStatus.java
index 3e40b6f..9a55838 100644
---
a/hbase-server/src/test/java/org/apache/hadoop/hbase/client/TestSplitOrMergeStatus.java
+++
b/hbase-server/src/test/java/org/apache/hadoop/hbase/client/TestSplitOrMergeStatus.java
@@ -55,17 +55,11 @@ public class TestSplitOrMergeStatus {
@Rule
public TestName name = new TestName();
- /**
- * @throws java.lang.Exception
- */
@BeforeClass
public static void setUpBeforeClass() throws Exception {
TEST_UTIL.startMiniCluster(2);
}
- /**
- * @throws java.lang.Exception
- */
@AfterClass
public static void tearDownAfterClass() throws Exception {
TEST_UTIL.shutdownMiniCluster();
@@ -84,7 +78,12 @@ public class TestSplitOrMergeStatus {
initSwitchStatus(admin);
boolean result = admin.splitSwitch(false, false);
assertTrue(result);
- admin.split(t.getName());
+ try {
+ admin.split(t.getName());
+ fail();
+ } catch (IOException e) {
+ // expected
+ }
int count = admin.getRegions(tableName).size();
assertTrue(originalCount == count);
result = admin.splitSwitch(true, false);
diff --git
a/hbase-server/src/test/java/org/apache/hadoop/hbase/coprocessor/TestMasterObserver.java
b/hbase-server/src/test/java/org/apache/hadoop/hbase/coprocessor/TestMasterObserver.java
index 1bc3996..76618a5 100644
---
a/hbase-server/src/test/java/org/apache/hadoop/hbase/coprocessor/TestMasterObserver.java
+++
b/hbase-server/src/test/java/org/apache/hadoop/hbase/coprocessor/TestMasterObserver.java
@@ -1342,7 +1342,7 @@ public class TestMasterObserver {
List<HRegionLocation> regions = regionLocator.getAllRegionLocations();
admin.mergeRegionsAsync(regions.get(0).getRegionInfo().getEncodedNameAsBytes(),
- regions.get(1).getRegionInfo().getEncodedNameAsBytes(), true);
+ regions.get(1).getRegionInfo().getEncodedNameAsBytes(), true).get();
assertTrue("Coprocessor should have been called on region merge",
cp.wasMergeRegionsCalled());
diff --git
a/hbase-server/src/test/java/org/apache/hadoop/hbase/master/TestMaster.java
b/hbase-server/src/test/java/org/apache/hadoop/hbase/master/TestMaster.java
index 7c396c7..fa23d38 100644
--- a/hbase-server/src/test/java/org/apache/hadoop/hbase/master/TestMaster.java
+++ b/hbase-server/src/test/java/org/apache/hadoop/hbase/master/TestMaster.java
@@ -190,7 +190,7 @@ public class TestMaster {
HColumnDescriptor hcd = new HColumnDescriptor("value");
htd.addFamily(hcd);
- admin.createTable(htd, null);
+ admin.createTable(htd);
try {
RegionInfo hri = RegionInfoBuilder.newBuilder(tableName)
.setStartKey(Bytes.toBytes("A"))
@@ -213,7 +213,7 @@ public class TestMaster {
HColumnDescriptor hcd = new HColumnDescriptor("value");
htd.addFamily(hcd);
- admin.createTable(htd, null);
+ admin.createTable(htd);
try {
List<RegionInfo> tableRegions = admin.getRegions(tableName);
diff --git
a/hbase-server/src/test/java/org/apache/hadoop/hbase/master/TestMasterMetricsWrapper.java
b/hbase-server/src/test/java/org/apache/hadoop/hbase/master/TestMasterMetricsWrapper.java
index c11386a..04cf13b 100644
---
a/hbase-server/src/test/java/org/apache/hadoop/hbase/master/TestMasterMetricsWrapper.java
+++
b/hbase-server/src/test/java/org/apache/hadoop/hbase/master/TestMasterMetricsWrapper.java
@@ -126,7 +126,7 @@ public class TestMasterMetricsWrapper {
HTableDescriptor desc = new HTableDescriptor(table);
byte[] FAMILY = Bytes.toBytes("FAMILY");
desc.addFamily(new HColumnDescriptor(FAMILY));
- TEST_UTIL.getHBaseAdmin().createTable(desc, Bytes.toBytes("A"),
Bytes.toBytes("Z"), 5);
+ TEST_UTIL.getAdmin().createTable(desc, Bytes.toBytes("A"),
Bytes.toBytes("Z"), 5);
// wait till the table is assigned
long timeoutTime = System.currentTimeMillis() + 1000;
@@ -148,7 +148,7 @@ public class TestMasterMetricsWrapper {
assertEquals(5, regionNumberPair.getFirst().intValue());
assertEquals(0, regionNumberPair.getSecond().intValue());
- TEST_UTIL.getHBaseAdmin().offline(hri.getRegionName());
+ TEST_UTIL.getAdmin().offline(hri.getRegionName());
timeoutTime = System.currentTimeMillis() + 800;
RegionStates regionStates =
master.getAssignmentManager().getRegionStates();
diff --git
a/hbase-server/src/test/java/org/apache/hadoop/hbase/master/TestMergeTableRegionsWhileRSCrash.java
b/hbase-server/src/test/java/org/apache/hadoop/hbase/master/TestMergeTableRegionsWhileRSCrash.java
index 7cf794a..182695c 100644
---
a/hbase-server/src/test/java/org/apache/hadoop/hbase/master/TestMergeTableRegionsWhileRSCrash.java
+++
b/hbase-server/src/test/java/org/apache/hadoop/hbase/master/TestMergeTableRegionsWhileRSCrash.java
@@ -69,7 +69,7 @@ public class TestMergeTableRegionsWhileRSCrash {
@BeforeClass
public static void setupCluster() throws Exception {
UTIL.startMiniCluster(1);
- admin = UTIL.getHBaseAdmin();
+ admin = UTIL.getAdmin();
byte[][] splitKeys = new byte[1][];
splitKeys[0] = SPLITKEY;
TABLE = UTIL.createTable(TABLE_NAME, CF, splitKeys);
diff --git
a/hbase-server/src/test/java/org/apache/hadoop/hbase/master/TestSplitRegionWhileRSCrash.java
b/hbase-server/src/test/java/org/apache/hadoop/hbase/master/TestSplitRegionWhileRSCrash.java
index fe5d1a2..a55deb0 100644
---
a/hbase-server/src/test/java/org/apache/hadoop/hbase/master/TestSplitRegionWhileRSCrash.java
+++
b/hbase-server/src/test/java/org/apache/hadoop/hbase/master/TestSplitRegionWhileRSCrash.java
@@ -66,7 +66,7 @@ public class TestSplitRegionWhileRSCrash {
@BeforeClass
public static void setupCluster() throws Exception {
UTIL.startMiniCluster(1);
- admin = UTIL.getHBaseAdmin();
+ admin = UTIL.getAdmin();
TABLE = UTIL.createTable(TABLE_NAME, CF);
UTIL.waitTableAvailable(TABLE_NAME);
}
diff --git
a/hbase-server/src/test/java/org/apache/hadoop/hbase/master/assignment/TestAssignmentOnRSCrash.java
b/hbase-server/src/test/java/org/apache/hadoop/hbase/master/assignment/TestAssignmentOnRSCrash.java
index 839d611..5673ed8 100644
---
a/hbase-server/src/test/java/org/apache/hadoop/hbase/master/assignment/TestAssignmentOnRSCrash.java
+++
b/hbase-server/src/test/java/org/apache/hadoop/hbase/master/assignment/TestAssignmentOnRSCrash.java
@@ -106,7 +106,7 @@ public class TestAssignmentOnRSCrash {
throws Exception {
final int NROWS = 100;
int nkilled = 0;
- for (RegionInfo hri: UTIL.getHBaseAdmin().getRegions(TEST_TABLE)) {
+ for (RegionInfo hri: UTIL.getAdmin().getRegions(TEST_TABLE)) {
ServerName serverName =
AssignmentTestingUtil.getServerHoldingRegion(UTIL, hri);
if (AssignmentTestingUtil.isServerHoldingMeta(UTIL, serverName))
continue;
diff --git
a/hbase-server/src/test/java/org/apache/hadoop/hbase/master/assignment/TestMasterAbortWhileMergingTable.java
b/hbase-server/src/test/java/org/apache/hadoop/hbase/master/assignment/TestMasterAbortWhileMergingTable.java
index 1af9bd0..6fcdb39 100644
---
a/hbase-server/src/test/java/org/apache/hadoop/hbase/master/assignment/TestMasterAbortWhileMergingTable.java
+++
b/hbase-server/src/test/java/org/apache/hadoop/hbase/master/assignment/TestMasterAbortWhileMergingTable.java
@@ -68,7 +68,7 @@ public class TestMasterAbortWhileMergingTable {
UTIL.getConfiguration().set(CoprocessorHost.MASTER_COPROCESSOR_CONF_KEY,
MergeRegionObserver.class.getName());
UTIL.startMiniCluster(3);
- admin = UTIL.getHBaseAdmin();
+ admin = UTIL.getAdmin();
byte[][] splitKeys = new byte[1][];
splitKeys[0] = SPLITKEY;
UTIL.createTable(TABLE_NAME, CF, splitKeys);
diff --git
a/hbase-server/src/test/java/org/apache/hadoop/hbase/master/assignment/TestModifyTableWhileMerging.java
b/hbase-server/src/test/java/org/apache/hadoop/hbase/master/assignment/TestModifyTableWhileMerging.java
index 16ad373..0d77608 100644
---
a/hbase-server/src/test/java/org/apache/hadoop/hbase/master/assignment/TestModifyTableWhileMerging.java
+++
b/hbase-server/src/test/java/org/apache/hadoop/hbase/master/assignment/TestModifyTableWhileMerging.java
@@ -67,7 +67,7 @@ public class TestModifyTableWhileMerging {
//Set procedure executor thread to 1, making reproducing this issue of
HBASE-20921 easier
UTIL.getConfiguration().setInt(MasterProcedureConstants.MASTER_PROCEDURE_THREADS,
1);
UTIL.startMiniCluster(1);
- admin = UTIL.getHBaseAdmin();
+ admin = UTIL.getAdmin();
byte[][] splitKeys = new byte[1][];
splitKeys[0] = SPLITKEY;
client = UTIL.createTable(TABLE_NAME, CF, splitKeys);
diff --git
a/hbase-server/src/test/java/org/apache/hadoop/hbase/regionserver/TestCleanupCompactedFileOnRegionClose.java
b/hbase-server/src/test/java/org/apache/hadoop/hbase/regionserver/TestCleanupCompactedFileOnRegionClose.java
index 6ae68f8..0bf4e78 100644
---
a/hbase-server/src/test/java/org/apache/hadoop/hbase/regionserver/TestCleanupCompactedFileOnRegionClose.java
+++
b/hbase-server/src/test/java/org/apache/hadoop/hbase/regionserver/TestCleanupCompactedFileOnRegionClose.java
@@ -24,13 +24,12 @@ import static org.junit.Assert.assertNotNull;
import static org.junit.Assert.assertTrue;
import java.util.Collection;
-
import org.apache.hadoop.hbase.HBaseClassTestRule;
import org.apache.hadoop.hbase.HBaseTestingUtility;
import org.apache.hadoop.hbase.TableName;
+import org.apache.hadoop.hbase.client.Admin;
import org.apache.hadoop.hbase.client.Delete;
import org.apache.hadoop.hbase.client.Get;
-import org.apache.hadoop.hbase.client.HBaseAdmin;
import org.apache.hadoop.hbase.client.Put;
import org.apache.hadoop.hbase.client.Result;
import org.apache.hadoop.hbase.client.ResultScanner;
@@ -40,7 +39,6 @@ import
org.apache.hadoop.hbase.master.cleaner.TimeToLiveHFileCleaner;
import
org.apache.hadoop.hbase.regionserver.compactions.CompactionConfiguration;
import org.apache.hadoop.hbase.testclassification.MediumTests;
import org.apache.hadoop.hbase.util.Bytes;
-
import org.junit.AfterClass;
import org.junit.BeforeClass;
import org.junit.ClassRule;
@@ -78,7 +76,7 @@ public class TestCleanupCompactedFileOnRegionClose {
byte[] familyNameBytes = Bytes.toBytes(familyName);
util.createTable(tableName, familyName);
- HBaseAdmin hBaseAdmin = util.getHBaseAdmin();
+ Admin hBaseAdmin = util.getAdmin();
Table table = util.getConnection().getTable(tableName);
HRegionServer rs = util.getRSForFirstRegionInTable(tableName);
diff --git
a/hbase-server/src/test/java/org/apache/hadoop/hbase/regionserver/TestNewVersionBehaviorFromClientSide.java
b/hbase-server/src/test/java/org/apache/hadoop/hbase/regionserver/TestNewVersionBehaviorFromClientSide.java
index 3c3dadf..805decf 100644
---
a/hbase-server/src/test/java/org/apache/hadoop/hbase/regionserver/TestNewVersionBehaviorFromClientSide.java
+++
b/hbase-server/src/test/java/org/apache/hadoop/hbase/regionserver/TestNewVersionBehaviorFromClientSide.java
@@ -82,7 +82,7 @@ public class TestNewVersionBehaviorFromClientSide {
fam.setNewVersionBehavior(true);
fam.setMaxVersions(3);
table.addFamily(fam);
- TEST_UTIL.getHBaseAdmin().createTable(table);
+ TEST_UTIL.getAdmin().createTable(table);
return TEST_UTIL.getConnection().getTable(tableName);
}
diff --git
a/hbase-server/src/test/java/org/apache/hadoop/hbase/regionserver/TestRegionServerAbort.java
b/hbase-server/src/test/java/org/apache/hadoop/hbase/regionserver/TestRegionServerAbort.java
index 878ca75..2b8953e 100644
---
a/hbase-server/src/test/java/org/apache/hadoop/hbase/regionserver/TestRegionServerAbort.java
+++
b/hbase-server/src/test/java/org/apache/hadoop/hbase/regionserver/TestRegionServerAbort.java
@@ -162,7 +162,7 @@ public class TestRegionServerAbort {
*/
@Test
public void testStopOverrideFromCoprocessor() throws Exception {
- Admin admin = testUtil.getHBaseAdmin();
+ Admin admin = testUtil.getAdmin();
HRegionServer regionserver = cluster.getRegionServer(0);
admin.stopRegionServer(regionserver.getServerName().getHostAndPort());
diff --git
a/hbase-server/src/test/java/org/apache/hadoop/hbase/replication/regionserver/TestReplicator.java
b/hbase-server/src/test/java/org/apache/hadoop/hbase/replication/regionserver/TestReplicator.java
index bff363f..90aef8d 100644
---
a/hbase-server/src/test/java/org/apache/hadoop/hbase/replication/regionserver/TestReplicator.java
+++
b/hbase-server/src/test/java/org/apache/hadoop/hbase/replication/regionserver/TestReplicator.java
@@ -28,7 +28,7 @@ import org.apache.hadoop.hbase.HBaseClassTestRule;
import org.apache.hadoop.hbase.HBaseTestingUtility;
import org.apache.hadoop.hbase.TableName;
import org.apache.hadoop.hbase.Waiter;
-import org.apache.hadoop.hbase.client.HBaseAdmin;
+import org.apache.hadoop.hbase.client.Admin;
import org.apache.hadoop.hbase.client.Put;
import org.apache.hadoop.hbase.ipc.RpcServer;
import org.apache.hadoop.hbase.replication.ReplicationPeerConfig;
@@ -167,7 +167,7 @@ public class TestReplicator extends TestReplicationBase {
}
private void truncateTable(HBaseTestingUtility util, TableName tablename)
throws IOException {
- HBaseAdmin admin = util.getHBaseAdmin();
+ Admin admin = util.getAdmin();
admin.disableTable(tableName);
admin.truncateTable(tablename, false);
}
diff --git
a/hbase-server/src/test/java/org/apache/hadoop/hbase/snapshot/SnapshotTestingUtils.java
b/hbase-server/src/test/java/org/apache/hadoop/hbase/snapshot/SnapshotTestingUtils.java
index d39c0e6..f9ca754 100644
---
a/hbase-server/src/test/java/org/apache/hadoop/hbase/snapshot/SnapshotTestingUtils.java
+++
b/hbase-server/src/test/java/org/apache/hadoop/hbase/snapshot/SnapshotTestingUtils.java
@@ -21,7 +21,6 @@ import static org.junit.Assert.assertEquals;
import static org.junit.Assert.assertFalse;
import static org.junit.Assert.assertTrue;
-import com.google.protobuf.ServiceException;
import java.io.IOException;
import java.util.ArrayList;
import java.util.Collections;
@@ -74,7 +73,6 @@ import org.slf4j.LoggerFactory;
import org.apache.hadoop.hbase.shaded.protobuf.ProtobufUtil;
import
org.apache.hadoop.hbase.shaded.protobuf.generated.MasterProtos.IsSnapshotDoneRequest;
-import
org.apache.hadoop.hbase.shaded.protobuf.generated.MasterProtos.IsSnapshotDoneResponse;
import org.apache.hadoop.hbase.shaded.protobuf.generated.SnapshotProtos;
import
org.apache.hadoop.hbase.shaded.protobuf.generated.SnapshotProtos.SnapshotRegionManifest;
@@ -270,33 +268,6 @@ public final class SnapshotTestingUtils {
}
}
- /**
- * Helper method for testing async snapshot operations. Just waits for the
- * given snapshot to complete on the server by repeatedly checking the
master.
- *
- * @param master the master running the snapshot
- * @param snapshot the snapshot to check
- * @param sleep amount to sleep between checks to see if the snapshot is done
- * @throws ServiceException if the snapshot fails
- * @throws org.apache.hbase.thirdparty.com.google.protobuf.ServiceException
- */
- public static void waitForSnapshotToComplete(HMaster master,
- SnapshotProtos.SnapshotDescription snapshot, long sleep)
- throws
org.apache.hbase.thirdparty.com.google.protobuf.ServiceException {
- final IsSnapshotDoneRequest request = IsSnapshotDoneRequest.newBuilder()
- .setSnapshot(snapshot).build();
- IsSnapshotDoneResponse done = IsSnapshotDoneResponse.newBuilder()
- .buildPartial();
- while (!done.getDone()) {
- done = master.getMasterRpcServices().isSnapshotDone(null, request);
- try {
- Thread.sleep(sleep);
- } catch (InterruptedException e) {
- throw new
org.apache.hbase.thirdparty.com.google.protobuf.ServiceException(e);
- }
- }
- }
-
/*
* Take snapshot with maximum of numTries attempts, ignoring
CorruptedSnapshotException
* except for the last CorruptedSnapshotException
diff --git
a/hbase-server/src/test/java/org/apache/hadoop/hbase/snapshot/TestFlushSnapshotFromClient.java
b/hbase-server/src/test/java/org/apache/hadoop/hbase/snapshot/TestFlushSnapshotFromClient.java
index e24d445..1d81dd7 100644
---
a/hbase-server/src/test/java/org/apache/hadoop/hbase/snapshot/TestFlushSnapshotFromClient.java
+++
b/hbase-server/src/test/java/org/apache/hadoop/hbase/snapshot/TestFlushSnapshotFromClient.java
@@ -28,6 +28,8 @@ import java.util.HashMap;
import java.util.List;
import java.util.Map;
import java.util.concurrent.CountDownLatch;
+import java.util.concurrent.TimeUnit;
+import java.util.concurrent.TimeoutException;
import org.apache.hadoop.conf.Configuration;
import org.apache.hadoop.fs.FileSystem;
import org.apache.hadoop.fs.Path;
@@ -57,7 +59,11 @@ import org.junit.experimental.categories.Category;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
+import org.apache.hbase.thirdparty.com.google.protobuf.ServiceException;
+
import org.apache.hadoop.hbase.shaded.protobuf.ProtobufUtil;
+import
org.apache.hadoop.hbase.shaded.protobuf.generated.MasterProtos.IsSnapshotDoneRequest;
+import
org.apache.hadoop.hbase.shaded.protobuf.generated.MasterProtos.IsSnapshotDoneResponse;
import org.apache.hadoop.hbase.shaded.protobuf.generated.SnapshotProtos;
/**
@@ -273,6 +279,38 @@ public class TestFlushSnapshotFromClient {
}
}
+ /**
+ * Helper method for testing async snapshot operations. Just waits for the
given snapshot to
+ * complete on the server by repeatedly checking the master.
+ * @param master the master running the snapshot
+ * @param snapshot the snapshot to check
+ * @param sleep amount to sleep between checks to see if the snapshot is done
+ */
+ private static void waitForSnapshotToComplete(HMaster master,
+ SnapshotProtos.SnapshotDescription snapshot, long timeoutNanos) throws
Exception {
+ final IsSnapshotDoneRequest request =
+ IsSnapshotDoneRequest.newBuilder().setSnapshot(snapshot).build();
+ long start = System.nanoTime();
+ while (System.nanoTime() - start < timeoutNanos) {
+ try {
+ IsSnapshotDoneResponse done =
master.getMasterRpcServices().isSnapshotDone(null, request);
+ if (done.getDone()) {
+ return;
+ }
+ } catch (ServiceException e) {
+ // ignore UnknownSnapshotException, this is possible as for
AsyncAdmin, the method will
+ // return immediately after sending out the request, no matter whether
the master has
+ // processed the request or not.
+ if (!(e.getCause() instanceof UnknownSnapshotException)) {
+ throw e;
+ }
+ }
+
+ Thread.sleep(200);
+ }
+ throw new TimeoutException("Timeout waiting for snapshot " + snapshot + "
to complete");
+ }
+
@Test
public void testAsyncFlushSnapshot() throws Exception {
SnapshotProtos.SnapshotDescription snapshot =
SnapshotProtos.SnapshotDescription.newBuilder()
@@ -285,7 +323,7 @@ public class TestFlushSnapshotFromClient {
// constantly loop, looking for the snapshot to complete
HMaster master = UTIL.getMiniHBaseCluster().getMaster();
- SnapshotTestingUtils.waitForSnapshotToComplete(master, snapshot, 200);
+ waitForSnapshotToComplete(master, snapshot, TimeUnit.MINUTES.toNanos(1));
LOG.info(" === Async Snapshot Completed ===");
UTIL.getHBaseCluster().getMaster().getMasterFileSystem().logFileSystemState(LOG);
@@ -524,7 +562,6 @@ public class TestFlushSnapshotFromClient {
SnapshotTestingUtils.waitForTableToBeOnline(UTIL, TABLE_NAME);
}
-
protected void verifyRowCount(final HBaseTestingUtility util, final
TableName tableName,
long expectedRows) throws IOException {
SnapshotTestingUtils.verifyRowCount(util, tableName, expectedRows);
diff --git
a/hbase-server/src/test/java/org/apache/hadoop/hbase/tool/TestBulkLoadHFiles.java
b/hbase-server/src/test/java/org/apache/hadoop/hbase/tool/TestBulkLoadHFiles.java
index e85fc1a..5122464 100644
---
a/hbase-server/src/test/java/org/apache/hadoop/hbase/tool/TestBulkLoadHFiles.java
+++
b/hbase-server/src/test/java/org/apache/hadoop/hbase/tool/TestBulkLoadHFiles.java
@@ -335,7 +335,11 @@ public class TestBulkLoadHFiles {
TableName tableName = htd.getTableName();
if (!util.getAdmin().tableExists(tableName) && (preCreateTable || map !=
null)) {
- util.getAdmin().createTable(htd, tableSplitKeys);
+ if (tableSplitKeys != null) {
+ util.getAdmin().createTable(htd, tableSplitKeys);
+ } else {
+ util.getAdmin().createTable(htd);
+ }
}
Configuration conf = util.getConfiguration();
diff --git
a/hbase-thrift/src/main/java/org/apache/hadoop/hbase/thrift2/ThriftHBaseServiceHandler.java
b/hbase-thrift/src/main/java/org/apache/hadoop/hbase/thrift2/ThriftHBaseServiceHandler.java
index 565a9c7..2ebbb11 100644
---
a/hbase-thrift/src/main/java/org/apache/hadoop/hbase/thrift2/ThriftHBaseServiceHandler.java
+++
b/hbase-thrift/src/main/java/org/apache/hadoop/hbase/thrift2/ThriftHBaseServiceHandler.java
@@ -626,7 +626,11 @@ public class ThriftHBaseServiceHandler extends
HBaseServiceHandler implements TH
try {
TableDescriptor descriptor = tableDescriptorFromThrift(desc);
byte[][] split = splitKeyFromThrift(splitKeys);
- connectionCache.getAdmin().createTable(descriptor, split);
+ if (split != null) {
+ connectionCache.getAdmin().createTable(descriptor, split);
+ } else {
+ connectionCache.getAdmin().createTable(descriptor);
+ }
} catch (IOException e) {
throw getTIOError(e);
}
diff --git
a/hbase-thrift/src/main/java/org/apache/hadoop/hbase/thrift2/client/ThriftAdmin.java
b/hbase-thrift/src/main/java/org/apache/hadoop/hbase/thrift2/client/ThriftAdmin.java
index 1884fb0..d7aea33 100644
---
a/hbase-thrift/src/main/java/org/apache/hadoop/hbase/thrift2/client/ThriftAdmin.java
+++
b/hbase-thrift/src/main/java/org/apache/hadoop/hbase/thrift2/client/ThriftAdmin.java
@@ -720,6 +720,11 @@ public class ThriftAdmin implements Admin {
}
@Override
+ public List<RegionMetrics> getRegionMetrics(ServerName serverName) {
+ throw new NotImplementedException("getRegionMetrics not supported in
ThriftAdmin");
+ }
+
+ @Override
public List<RegionMetrics> getRegionMetrics(ServerName serverName, TableName
tableName) {
throw new NotImplementedException("getRegionMetrics not supported in
ThriftAdmin");
}
@@ -1127,8 +1132,8 @@ public class ThriftAdmin implements Admin {
}
@Override
- public List<UserPermission>
- getUserPermissions(GetUserPermissionsRequest getUserPermissionsRequest) {
+ public List<UserPermission> getUserPermissions(
+ GetUserPermissionsRequest getUserPermissionsRequest) {
throw new NotImplementedException("getUserPermissions not supported in
ThriftAdmin");
}
