添加Put异步请求失败回调的内容

AlionSSS · May 9, 2019 · 92874a6 · 92874a6
1 parent a9d642d
commit 92874a6
Show file tree

Hide file tree

Showing 4 changed files with 10 additions and 4 deletions.
diff --git a/README.md b/README.md
@@ -188,8 +188,9 @@ client.putAsync("tb_test", putList, new PutCallback() {
     }
 
     @Override
-    public void onFailed(Exception e) {
+    public void onFailed(Exception e, List<Put> puts) {
         System.out.println("GetTest.onFailed 提交Put失败!");
+        System.out.println("失败的 puts = " + puts);
     }
 });
 ```

diff --git a/src/com/skey/evehbase/client/EveHBase.java b/src/com/skey/evehbase/client/EveHBase.java
@@ -206,7 +206,7 @@ public void putAsync(@Nonnull String tableName, @Nonnull List<Put> putList, PutC
                 put(tableName, putList);
                 if (callback != null) callback.onSuccessful();
             } catch (IOException e) {
-                if (callback != null) callback.onFailed(e);
+                if (callback != null) callback.onFailed(e, putList);
             }
         });
     }

diff --git a/src/com/skey/evehbase/request/PutCallback.java b/src/com/skey/evehbase/request/PutCallback.java
@@ -1,6 +1,10 @@
 package com.skey.evehbase.request;
 
 
+import org.apache.hadoop.hbase.client.Put;
+
+import java.util.List;
+
 /**
  * HBase Put 回调接口
  * <p>
@@ -12,6 +16,6 @@ public interface PutCallback {
 
     void onSuccessful();
 
-    void onFailed(Exception e);
+    void onFailed(Exception e, List<Put> puts);
 
 }
diff --git a/test/com/skey/evehbase/GetTest.java b/test/com/skey/evehbase/GetTest.java
@@ -176,8 +176,9 @@ public void onFailed(Exception e) {
 //            }
 //
 //            @Override
-//            public void onFailed(Exception e) {
+//            public void onFailed(Exception e, List<Put> puts) {
 //                System.out.println("GetTest.onFailed 提交Put失败!");
+//                System.out.println("失败的 puts = " + puts);
 //            }
 //        });
 //        client.putAsync("tb_test", putList, null);