You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@hbase.apache.org by st...@apache.org on 2021/04/08 20:42:19 UTC
[hbase] branch branch-2.4 updated: HBASE-25735 Add target Region to
connection exceptions Restore API for Phoenix (though it shouldn't be using
Private classes).
This is an automated email from the ASF dual-hosted git repository.
stack pushed a commit to branch branch-2.4
in repository https://gitbox.apache.org/repos/asf/hbase.git
The following commit(s) were added to refs/heads/branch-2.4 by this push:
new 1df7595 HBASE-25735 Add target Region to connection exceptions Restore API for Phoenix (though it shouldn't be using Private classes).
1df7595 is described below
commit 1df7595c49fd211f46c832a1450102d6a1d4c22b
Author: stack <st...@apache.org>
AuthorDate: Thu Apr 8 13:24:29 2021 -0700
HBASE-25735 Add target Region to connection exceptions
Restore API for Phoenix (though it shouldn't be using
Private classes).
---
.../org/apache/hadoop/hbase/ipc/RpcControllerFactory.java | 12 +++++++++---
1 file changed, 9 insertions(+), 3 deletions(-)
diff --git a/hbase-client/src/main/java/org/apache/hadoop/hbase/ipc/RpcControllerFactory.java b/hbase-client/src/main/java/org/apache/hadoop/hbase/ipc/RpcControllerFactory.java
index 0dcb22f..e6d63fa 100644
--- a/hbase-client/src/main/java/org/apache/hadoop/hbase/ipc/RpcControllerFactory.java
+++ b/hbase-client/src/main/java/org/apache/hadoop/hbase/ipc/RpcControllerFactory.java
@@ -18,15 +18,14 @@
package org.apache.hadoop.hbase.ipc;
import java.util.List;
-
import org.apache.hadoop.conf.Configuration;
import org.apache.hadoop.hbase.CellScannable;
import org.apache.hadoop.hbase.CellScanner;
import org.apache.hadoop.hbase.client.RegionInfo;
+import org.apache.hadoop.hbase.util.ReflectionUtils;
import org.apache.yetus.audience.InterfaceAudience;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
-import org.apache.hadoop.hbase.util.ReflectionUtils;
/**
* Factory to create a {@link HBaseRpcController}
@@ -52,16 +51,23 @@ public class RpcControllerFactory {
return new HBaseRpcControllerImpl();
}
+ public HBaseRpcController newController(CellScanner cellScanner) {
+ return new HBaseRpcControllerImpl(null, cellScanner);
+ }
+
public HBaseRpcController newController(RegionInfo regionInfo, CellScanner cellScanner) {
return new HBaseRpcControllerImpl(regionInfo, cellScanner);
}
+ public HBaseRpcController newController(final List<CellScannable> cellIterables) {
+ return new HBaseRpcControllerImpl(null, cellIterables);
+ }
+
public HBaseRpcController newController(RegionInfo regionInfo,
final List<CellScannable> cellIterables) {
return new HBaseRpcControllerImpl(regionInfo, cellIterables);
}
-
public static RpcControllerFactory instantiate(Configuration configuration) {
String rpcControllerFactoryClazz =
configuration.get(CUSTOM_CONTROLLER_CONF_KEY,