[hbase] branch master updated: HBASE-24966 The methods in AsyncTableRegionLocator should not throw IOException directly (#2495)

[zh...@apache.org]

This is an automated email from the ASF dual-hosted git repository.

zhangduo pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/hbase.git


The following commit(s) were added to refs/heads/master by this push:
     new 8634428  HBASE-24966 The methods in AsyncTableRegionLocator should not throw IOException directly (#2495)
8634428 is described below

commit 8634428724e12263869746fdea4214d21f7b8ce8
Author: SteNicholas <pr...@163.com>
AuthorDate: Fri Dec 4 10:56:53 2020 +0800

    HBASE-24966 The methods in AsyncTableRegionLocator should not throw IOException directly (#2495)
    
    Signed-off-by: Duo Zhang <zh...@apache.org>
---
 .../apache/hadoop/hbase/client/AsyncTableRegionLocator.java  | 12 +++---------
 1 file changed, 3 insertions(+), 9 deletions(-)

diff --git a/hbase-client/src/main/java/org/apache/hadoop/hbase/client/AsyncTableRegionLocator.java b/hbase-client/src/main/java/org/apache/hadoop/hbase/client/AsyncTableRegionLocator.java
index 321f44e..96e3ec4 100644
--- a/hbase-client/src/main/java/org/apache/hadoop/hbase/client/AsyncTableRegionLocator.java
+++ b/hbase-client/src/main/java/org/apache/hadoop/hbase/client/AsyncTableRegionLocator.java
@@ -17,7 +17,6 @@
  */
 package org.apache.hadoop.hbase.client;
 
-import java.io.IOException;
 import java.util.List;
 import java.util.concurrent.CompletableFuture;
 import java.util.stream.Collectors;
@@ -89,7 +88,6 @@ public interface AsyncTableRegionLocator {
    * Find all the replicas for the region on which the given row is being served.
    * @param row Row to find.
    * @return Locations for all the replicas of the row.
-   * @throws IOException if a remote or network exception occurs
    */
   default CompletableFuture<List<HRegionLocation>> getRegionLocations(byte[] row) {
     return getRegionLocations(row, false);
@@ -100,7 +98,6 @@ public interface AsyncTableRegionLocator {
    * @param row Row to find.
    * @param reload true to reload information or false to use cached information
    * @return Locations for all the replicas of the row.
-   * @throws IOException if a remote or network exception occurs
    */
   CompletableFuture<List<HRegionLocation>> getRegionLocations(byte[] row, boolean reload);
 
@@ -120,9 +117,8 @@ public interface AsyncTableRegionLocator {
    * <p>
    * This is mainly useful for the MapReduce integration.
    * @return Array of region starting row keys
-   * @throws IOException if a remote or network exception occurs
    */
-  default CompletableFuture<List<byte[]>> getStartKeys() throws IOException {
+  default CompletableFuture<List<byte[]>> getStartKeys() {
     return getStartEndKeys().thenApply(
       startEndKeys -> startEndKeys.stream().map(Pair::getFirst).collect(Collectors.toList()));
   }
@@ -132,9 +128,8 @@ public interface AsyncTableRegionLocator {
    * <p>
    * This is mainly useful for the MapReduce integration.
    * @return Array of region ending row keys
-   * @throws IOException if a remote or network exception occurs
    */
-  default CompletableFuture<List<byte[]>> getEndKeys() throws IOException {
+  default CompletableFuture<List<byte[]>> getEndKeys() {
     return getStartEndKeys().thenApply(
       startEndKeys -> startEndKeys.stream().map(Pair::getSecond).collect(Collectors.toList()));
   }
@@ -144,9 +139,8 @@ public interface AsyncTableRegionLocator {
    * <p>
    * This is mainly useful for the MapReduce integration.
    * @return Pair of arrays of region starting and ending row keys
-   * @throws IOException if a remote or network exception occurs
    */
-  default CompletableFuture<List<Pair<byte[], byte[]>>> getStartEndKeys() throws IOException {
+  default CompletableFuture<List<Pair<byte[], byte[]>>> getStartEndKeys() {
     return getAllRegionLocations().thenApply(
       locs -> locs.stream().filter(loc -> RegionReplicaUtil.isDefaultReplica(loc.getRegion()))
         .map(HRegionLocation::getRegion).map(r -> Pair.newPair(r.getStartKey(), r.getEndKey()))