Apache
/
hbase
1
0
Fork 0
Code Issues Pull Requests Packages Projects Releases Wiki Activity

HBASE-25735 Add target Region to connection exceptions 

Restore API for Phoenix (though it shouldn't be using
Private classes).
This commit is contained in:
stack 2021-04-08 13:24:29 -07:00
parent e2dedf9ef1
commit 1df7595c49
1 changed files with 9 additions and 3 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

12
hbase-client/src/main/java/org/apache/hadoop/hbase/ipc/RpcControllerFactory.java
View File

@ -18,15 +18,14 @@
package org.apache.hadoop.hbase.ipc; package org.apache.hadoop.hbase.ipc;
import java.util.List; import java.util.List;
import org.apache.hadoop.conf.Configuration; import org.apache.hadoop.conf.Configuration;
import org.apache.hadoop.hbase.CellScannable; import org.apache.hadoop.hbase.CellScannable;
import org.apache.hadoop.hbase.CellScanner; import org.apache.hadoop.hbase.CellScanner;
import org.apache.hadoop.hbase.client.RegionInfo; import org.apache.hadoop.hbase.client.RegionInfo;
import org.apache.hadoop.hbase.util.ReflectionUtils;
import org.apache.yetus.audience.InterfaceAudience; import org.apache.yetus.audience.InterfaceAudience;
import org.slf4j.Logger; import org.slf4j.Logger;
import org.slf4j.LoggerFactory; import org.slf4j.LoggerFactory;
import org.apache.hadoop.hbase.util.ReflectionUtils;
/** /**
* Factory to create a {@link HBaseRpcController} * Factory to create a {@link HBaseRpcController}
@ -52,16 +51,23 @@ public class RpcControllerFactory {
return new HBaseRpcControllerImpl(); return new HBaseRpcControllerImpl();
} }
public HBaseRpcController newController(CellScanner cellScanner) {
return new HBaseRpcControllerImpl(null, cellScanner);
}
public HBaseRpcController newController(RegionInfo regionInfo, CellScanner cellScanner) { public HBaseRpcController newController(RegionInfo regionInfo, CellScanner cellScanner) {
return new HBaseRpcControllerImpl(regionInfo, cellScanner); return new HBaseRpcControllerImpl(regionInfo, cellScanner);
} }
public HBaseRpcController newController(final List<CellScannable> cellIterables) {
return new HBaseRpcControllerImpl(null, cellIterables);
}
public HBaseRpcController newController(RegionInfo regionInfo, public HBaseRpcController newController(RegionInfo regionInfo,
final List<CellScannable> cellIterables) { final List<CellScannable> cellIterables) {
return new HBaseRpcControllerImpl(regionInfo, cellIterables); return new HBaseRpcControllerImpl(regionInfo, cellIterables);
} }
public static RpcControllerFactory instantiate(Configuration configuration) { public static RpcControllerFactory instantiate(Configuration configuration) {
String rpcControllerFactoryClazz = String rpcControllerFactoryClazz =
configuration.get(CUSTOM_CONTROLLER_CONF_KEY, configuration.get(CUSTOM_CONTROLLER_CONF_KEY,