Apache
/
hbase
1
0
Fork 0
Code Issues Pull Requests Packages Projects Releases Wiki Activity

HBASE-18343 (addendum) Track the remaining unimplemented methods for async admin

This commit is contained in:
Guanghao Zhang 2017-07-11 18:00:54 +08:00
parent f9f1a3a9fb
commit 45cabfb406
1 changed files with 5 additions and 7 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

12
hbase-server/src/test/java/org/apache/hadoop/hbase/client/TestAsyncRegionAdminApi.java
View File

@ -27,7 +27,6 @@ import java.io.IOException;
import java.util.ArrayList; import java.util.ArrayList;
import java.util.List; import java.util.List;
import java.util.Optional; import java.util.Optional;
import java.util.Random;
import java.util.concurrent.ExecutionException; import java.util.concurrent.ExecutionException;
import java.util.concurrent.atomic.AtomicInteger; import java.util.concurrent.atomic.AtomicInteger;
import java.util.stream.Collectors; import java.util.stream.Collectors;
@ -66,8 +65,6 @@ import org.junit.runners.Parameterized;
@Category({ LargeTests.class, ClientTests.class }) @Category({ LargeTests.class, ClientTests.class })
public class TestAsyncRegionAdminApi extends TestAsyncAdminBase { public class TestAsyncRegionAdminApi extends TestAsyncAdminBase {
public static Random RANDOM = new Random(System.currentTimeMillis());
@Test @Test
public void testCloseRegion() throws Exception { public void testCloseRegion() throws Exception {
createTableWithDefaultConf(tableName); createTableWithDefaultConf(tableName);
@ -358,7 +355,8 @@ public class TestAsyncRegionAdminApi extends TestAsyncAdminBase {
public void testSplitSwitch() throws Exception { public void testSplitSwitch() throws Exception {
createTableWithDefaultConf(tableName); createTableWithDefaultConf(tableName);
byte[][] families = { FAMILY }; byte[][] families = { FAMILY };
loadData(tableName, families, 1000); final int rows = 10000;
loadData(tableName, families, rows);
RawAsyncTable metaTable = ASYNC_CONN.getRawTable(META_TABLE_NAME); RawAsyncTable metaTable = ASYNC_CONN.getRawTable(META_TABLE_NAME);
List<HRegionLocation> regionLocations = List<HRegionLocation> regionLocations =
@ -367,12 +365,12 @@ public class TestAsyncRegionAdminApi extends TestAsyncAdminBase {
initSplitMergeSwitch(); initSplitMergeSwitch();
assertTrue(admin.setSplitOn(false).get()); assertTrue(admin.setSplitOn(false).get());
admin.split(tableName).join(); admin.split(tableName, Bytes.toBytes(rows / 2)).join();
int count = admin.getTableRegions(tableName).get().size(); int count = admin.getTableRegions(tableName).get().size();
assertTrue(originalCount == count); assertTrue(originalCount == count);
assertFalse(admin.setSplitOn(true).get()); assertFalse(admin.setSplitOn(true).get());
admin.split(tableName).join(); admin.split(tableName, Bytes.toBytes(rows / 2)).join();
while ((count = admin.getTableRegions(tableName).get().size()) == originalCount) { while ((count = admin.getTableRegions(tableName).get().size()) == originalCount) {
Threads.sleep(100); Threads.sleep(100);
} }
@ -654,7 +652,7 @@ public class TestAsyncRegionAdminApi extends TestAsyncAdminBase {
byte[] qualifier = Bytes.toBytes("val"); byte[] qualifier = Bytes.toBytes("val");
for (int i = 0; i < flushes; i++) { for (int i = 0; i < flushes; i++) {
for (int k = 0; k < rows; k++) { for (int k = 0; k < rows; k++) {
byte[] row = Bytes.toBytes(RANDOM.nextLong()); byte[] row = Bytes.add(Bytes.toBytes(k), Bytes.toBytes(i));
Put p = new Put(row); Put p = new Put(row);
for (int j = 0; j < families.length; ++j) { for (int j = 0; j < families.length; ++j) {
p.addColumn(families[j], qualifier, row); p.addColumn(families[j], qualifier, row);