HBASE-23087 Remove the deprecated bulkload method in AsyncClusterConn…

…ection (#670) Signed-off-by: Wellington Chevreuil <[email protected]>
apache · Sep 29, 2019 · c1a476c · c1a476c
1 parent 8363681
commit c1a476c
Show file tree

Hide file tree

Showing 3 changed files with 10 additions and 32 deletions.
diff --git a/hbase-server/src/main/java/org/apache/hadoop/hbase/client/AsyncClusterConnection.java b/hbase-server/src/main/java/org/apache/hadoop/hbase/client/AsyncClusterConnection.java
@@ -75,22 +75,11 @@ CompletableFuture<RegionLocations> getRegionLocations(TableName tableName, byte[
   CompletableFuture<String> prepareBulkLoad(TableName tableName);
 
   /**
-   * @deprecated Use bulkLoad(TableName tableName, List<Pair<byte[], String>> familyPaths,
-   * byte[] row, boolean assignSeqNum, Token<?> userToken, String bulkToken,
-   *       boolean copyFiles, List<String> clusterIds)
-   */
-  @Deprecated
-  CompletableFuture<Boolean> bulkLoad(TableName tableName, List<Pair<byte[], String>> familyPaths,
-      byte[] row, boolean assignSeqNum, Token<?> userToken, String bulkToken, boolean copyFiles);
-
-  /**
-   * Securely bulk load a list of HFiles, passing additional list of clusters ids tracking
-   * clusters where the given bulk load has already been processed
-   * (important for bulk loading replication).
-   *
-   * Defined as default here to avoid breaking callers who rely on the bulkLoad version that
-   * does not expect additional clusterIds param.
-   *
+   * Securely bulk load a list of HFiles, passing additional list of clusters ids tracking clusters
+   * where the given bulk load has already been processed (important for bulk loading replication).
+   * <p/>
+   * Defined as default here to avoid breaking callers who rely on the bulkLoad version that does
+   * not expect additional clusterIds param.
    * @param tableName the target table
    * @param familyPaths hdfs path for the the table family dirs containg files to be loaded
    * @param row row key
@@ -99,13 +88,10 @@ CompletableFuture<Boolean> bulkLoad(TableName tableName, List<Pair<byte[], Strin
    * @param bulkToken bulk load token
    * @param copyFiles flag for copying the loaded hfiles
    * @param clusterIds list of cluster ids where the given bulk load has already been processed.
-   * @return
    */
-  default CompletableFuture<Boolean> bulkLoad(TableName tableName, List<Pair<byte[],
-    String>> familyPaths, byte[] row, boolean assignSeqNum, Token<?> userToken, String bulkToken,
-      boolean copyFiles, List<String> clusterIds) {
-    return null;
-  }
+  CompletableFuture<Boolean> bulkLoad(TableName tableName, List<Pair<byte[], String>> familyPaths,
+    byte[] row, boolean assignSeqNum, Token<?> userToken, String bulkToken, boolean copyFiles,
+    List<String> clusterIds);
 
   /**
    * Clean up after finishing bulk load, no matter success or not.

diff --git a/hbase-server/src/main/java/org/apache/hadoop/hbase/client/AsyncClusterConnectionImpl.java b/hbase-server/src/main/java/org/apache/hadoop/hbase/client/AsyncClusterConnectionImpl.java
@@ -106,14 +106,6 @@ public CompletableFuture<String> prepareBulkLoad(TableName tableName) {
       .call();
   }
 
-  @Override
-  public CompletableFuture<Boolean> bulkLoad(TableName tableName,
-    List<Pair<byte[], String>> familyPaths, byte[] row, boolean assignSeqNum, Token<?> userToken,
-    String bulkToken, boolean copyFiles) {
-    return bulkLoad(tableName, familyPaths, row, assignSeqNum,
-      userToken, bulkToken, copyFiles, null);
-  }
-
   @Override
   public CompletableFuture<Boolean> bulkLoad(TableName tableName,
     List<Pair<byte[], String>> familyPaths, byte[] row, boolean assignSeqNum, Token<?> userToken,

diff --git a/hbase-server/src/test/java/org/apache/hadoop/hbase/client/DummyAsyncClusterConnection.java b/hbase-server/src/test/java/org/apache/hadoop/hbase/client/DummyAsyncClusterConnection.java
@@ -143,8 +143,8 @@ public CompletableFuture<String> prepareBulkLoad(TableName tableName) {
 
   @Override
   public CompletableFuture<Boolean> bulkLoad(TableName tableName,
-      List<Pair<byte[], String>> familyPaths, byte[] row, boolean assignSeqNum, Token<?> userToken,
-      String bulkToken, boolean copyFiles) {
+    List<Pair<byte[], String>> familyPaths, byte[] row, boolean assignSeqNum, Token<?> userToken,
+    String bulkToken, boolean copyFiles, List<String> clusterIds) {
     return null;
   }