Skip to content

Commit

Permalink
HBASE-22296 Remove TestFromClientSide.testGetStartEndKeysWithRegionRe…
Browse files Browse the repository at this point in the history
…plicas
  • Loading branch information
Apache9 committed Apr 24, 2019
1 parent fe7cf10 commit d77e90c
Showing 1 changed file with 0 additions and 37 deletions.
Original file line number Diff line number Diff line change
Expand Up @@ -6353,43 +6353,6 @@ private static Pair<byte[][], byte[][]> getStartEndKeys(List<RegionLocations> re
return new Pair<>(startKeyList, endKeyList);
}

@Test
public void testGetStartEndKeysWithRegionReplicas() throws IOException {
HTableDescriptor htd = new HTableDescriptor(TableName.valueOf(name.getMethodName()));
HColumnDescriptor fam = new HColumnDescriptor(FAMILY);
htd.addFamily(fam);
byte[][] KEYS = HBaseTestingUtility.KEYS_FOR_HBA_CREATE_TABLE;
Admin admin = TEST_UTIL.getAdmin();
admin.createTable(htd, KEYS);
List<RegionInfo> regions = admin.getRegions(htd.getTableName());

HRegionLocator locator =
(HRegionLocator) admin.getConnection().getRegionLocator(htd.getTableName());
for (int regionReplication = 1; regionReplication < 4; regionReplication++) {
List<RegionLocations> regionLocations = new ArrayList<>();

// mock region locations coming from meta with multiple replicas
for (RegionInfo region : regions) {
HRegionLocation[] arr = new HRegionLocation[regionReplication];
for (int i = 0; i < arr.length; i++) {
arr[i] = new HRegionLocation(RegionReplicaUtil.getRegionInfoForReplica(region, i), null);
}
regionLocations.add(new RegionLocations(arr));
}

Pair<byte[][], byte[][]> startEndKeys = getStartEndKeys(regionLocations);

assertEquals(KEYS.length + 1, startEndKeys.getFirst().length);

for (int i = 0; i < KEYS.length + 1; i++) {
byte[] startKey = i == 0 ? HConstants.EMPTY_START_ROW : KEYS[i - 1];
byte[] endKey = i == KEYS.length ? HConstants.EMPTY_END_ROW : KEYS[i];
assertArrayEquals(startKey, startEndKeys.getFirst()[i]);
assertArrayEquals(endKey, startEndKeys.getSecond()[i]);
}
}
}

@Test
public void testFilterAllRecords() throws IOException {
Scan scan = new Scan();
Expand Down

0 comments on commit d77e90c

Please sign in to comment.