invokeMethod(UserGroupInformation, List, boolean, Class, Method, Object[]) |  | 0% |  | 0% | 31 | 31 | 101 | 101 | 1 | 1 |
invokeConcurrent(Collection, RemoteMethod, boolean, long, Class) |  | 0% |  | 0% | 15 | 15 | 96 | 96 | 1 | 1 |
RouterRpcClient(Configuration, Router, ActiveNamenodeResolver, RouterRpcMonitor, RouterStateIdContext) |  | 0% |  | 0% | 7 | 7 | 42 | 42 | 1 | 1 |
invokeSequential(RemoteMethod, List, Class, Object) |  | 0% |  | 0% | 8 | 8 | 40 | 40 | 1 | 1 |
getCleanException(IOException) |  | 0% |  | 0% | 6 | 6 | 36 | 36 | 1 | 1 |
addClientInfoToCallerContext(UserGroupInformation) |  | 0% |  | 0% | 8 | 8 | 26 | 26 | 1 | 1 |
invoke(String, FederationNamenodeContext, Boolean, int, Method, Object, Object[]) |  | 0% |  | 0% | 7 | 7 | 21 | 21 | 1 | 1 |
processException(IOException, RemoteLocationContext) |  | 0% |  | 0% | 4 | 4 | 21 | 21 | 1 | 1 |
invokeConcurrent(Collection, RemoteMethod, boolean, boolean, long, Class) |  | 0% |  | 0% | 9 | 9 | 19 | 19 | 1 | 1 |
getConnection(UserGroupInformation, String, String, Class) |  | 0% |  | 0% | 4 | 4 | 15 | 15 | 1 | 1 |
processExceptionMsg(String, String, String) |  | 0% |  | 0% | 6 | 6 | 9 | 9 | 1 | 1 |
invokeSingle(String, RemoteMethod) |  | 0% | | n/a | 1 | 1 | 11 | 11 | 1 | 1 |
acquirePermit(String, UserGroupInformation, RemoteMethod, RouterRpcFairnessPolicyController) |  | 0% |  | 0% | 5 | 5 | 14 | 14 | 1 | 1 |
getOrderedNamenodes(String, boolean) |  | 0% |  | 0% | 7 | 7 | 10 | 10 | 1 | 1 |
shouldRetry(IOException, int, String, FederationNamenodeContext, boolean) |  | 0% |  | 0% | 3 | 3 | 10 | 10 | 1 | 1 |
isClusterUnAvailable(String, FederationNamenodeContext, boolean) |  | 0% |  | 0% | 6 | 6 | 10 | 10 | 1 | 1 |
getLocationWithBPID(List, String) |  | 0% |  | 0% | 3 | 3 | 7 | 7 | 1 | 1 |
getClientConfiguration(Configuration) |  | 0% |  | 0% | 3 | 3 | 8 | 8 | 1 | 1 |
getAsyncCallerPoolJson() |  | 0% | | n/a | 1 | 1 | 5 | 5 | 1 | 1 |
getNamenodesForBlockPoolId(String) |  | 0% |  | 0% | 3 | 3 | 6 | 6 | 1 | 1 |
isUnavailableException(IOException) |  | 0% |  | 0% | 7 | 7 | 7 | 7 | 1 | 1 |
refreshFairnessPolicyController(Configuration) |  | 0% |  | 0% | 3 | 3 | 10 | 10 | 1 | 1 |
isNamespaceStateIdFresh(String) |  | 0% |  | 0% | 3 | 3 | 4 | 4 | 1 | 1 |
isReadCall(Method) |  | 0% |  | 0% | 4 | 4 | 5 | 5 | 1 | 1 |
shutdown() |  | 0% |  | 0% | 4 | 4 | 7 | 7 | 1 | 1 |
shouldRotateCache(IOException) |  | 0% |  | 0% | 3 | 3 | 7 | 7 | 1 | 1 |
toIOException(Exception) |  | 0% |  | 0% | 3 | 3 | 5 | 5 | 1 | 1 |
getRejectedPermitForNs(String) |  | 0% |  | 0% | 2 | 2 | 2 | 2 | 1 | 1 |
getAcceptedPermitForNs(String) |  | 0% |  | 0% | 2 | 2 | 2 | 2 | 1 | 1 |
invokeAll(Collection, RemoteMethod) |  | 0% | | n/a | 1 | 1 | 3 | 3 | 1 | 1 |
lambda$invokeConcurrent$1(Server.Call, CallerContext, UserGroupInformation, List, boolean, Class, Method, Object[]) |  | 0% | | n/a | 1 | 1 | 2 | 2 | 1 | 1 |
lambda$invokeConcurrent$0(Server.Call, CallerContext, UserGroupInformation, List, boolean, Class, Method, Object[]) |  | 0% | | n/a | 1 | 1 | 2 | 2 | 1 | 1 |
invokeSingle(ExtendedBlock, RemoteMethod, List, Class) |  | 0% | | n/a | 1 | 1 | 2 | 2 | 1 | 1 |
invokeSingle(ExtendedBlock, RemoteMethod, Class) |  | 0% | | n/a | 1 | 1 | 3 | 3 | 1 | 1 |
isExpectedClass(Class, Object) |  | 0% |  | 0% | 3 | 3 | 5 | 5 | 1 | 1 |
isExpectedValue(Object, Object) |  | 0% |  | 0% | 3 | 3 | 5 | 5 | 1 | 1 |
getNameserviceForBlockPoolId(String) |  | 0% | | n/a | 1 | 1 | 4 | 4 | 1 | 1 |
releasePermit(String, UserGroupInformation, RemoteMethod, RouterRpcFairnessPolicyController) |  | 0% |  | 0% | 2 | 2 | 5 | 5 | 1 | 1 |
isObserverReadEligible(String, Method) |  | 0% |  | 0% | 3 | 3 | 1 | 1 | 1 | 1 |
isNamespaceObserverReadEligible(String) |  | 0% |  | 0% | 2 | 2 | 1 | 1 | 1 | 1 |
invokeSingle(RemoteLocationContext, RemoteMethod, Class) |  | 0% | | n/a | 1 | 1 | 3 | 3 | 1 | 1 |
getCurrentFairnessPolicyControllerClassName() |  | 0% |  | 0% | 2 | 2 | 3 | 3 | 1 | 1 |
invokeSingleBlockPool(String, RemoteMethod) |  | 0% | | n/a | 1 | 1 | 2 | 2 | 1 | 1 |
invokeConcurrent(Collection, RemoteMethod, boolean, boolean) |  | 0% | | n/a | 1 | 1 | 2 | 2 | 1 | 1 |
invokeConcurrent(Collection, RemoteMethod, boolean, boolean, Class) |  | 0% | | n/a | 1 | 1 | 1 | 1 | 1 | 1 |
invokeSequential(List, RemoteMethod, Class, Object) |  | 0% | | n/a | 1 | 1 | 2 | 2 | 1 | 1 |
invokeConcurrent(Collection, RemoteMethod, Class) |  | 0% | | n/a | 1 | 1 | 1 | 1 | 1 | 1 |
incrRejectedPermitForNs(String) |  | 0% | | n/a | 1 | 1 | 2 | 2 | 1 | 1 |
incrAcceptedPermitForNs(String) |  | 0% | | n/a | 1 | 1 | 2 | 2 | 1 | 1 |
invokeSingle(String, RemoteMethod, Class) |  | 0% | | n/a | 1 | 1 | 2 | 2 | 1 | 1 |
invokeSequential(List, RemoteMethod) |  | 0% | | n/a | 1 | 1 | 1 | 1 | 1 | 1 |
invokeConcurrent(Collection, RemoteMethod) |  | 0% | | n/a | 1 | 1 | 2 | 2 | 1 | 1 |
getTimeOfLastCallToActive(String) |  | 0% | | n/a | 1 | 1 | 2 | 2 | 1 | 1 |
static {...} |  | 0% | | n/a | 1 | 1 | 4 | 4 | 1 | 1 |
transferThreadLocalContext(Server.Call, CallerContext) |  | 0% | | n/a | 1 | 1 | 3 | 3 | 1 | 1 |
lambda$getTimeOfLastCallToActive$4(String) |  | 0% | | n/a | 1 | 1 | 1 | 1 | 1 | 1 |
getNumConnections() |  | 0% | | n/a | 1 | 1 | 1 | 1 | 1 | 1 |
getNumActiveConnections() |  | 0% | | n/a | 1 | 1 | 1 | 1 | 1 | 1 |
getNumIdleConnections() |  | 0% | | n/a | 1 | 1 | 1 | 1 | 1 | 1 |
getNumActiveConnectionsRecently() |  | 0% | | n/a | 1 | 1 | 1 | 1 | 1 | 1 |
getNumConnectionPools() |  | 0% | | n/a | 1 | 1 | 1 | 1 | 1 | 1 |
getNumCreatingConnections() |  | 0% | | n/a | 1 | 1 | 1 | 1 | 1 | 1 |
getJSON() |  | 0% | | n/a | 1 | 1 | 1 | 1 | 1 | 1 |
getRejectedPermitsPerNsJSON() |  | 0% | | n/a | 1 | 1 | 1 | 1 | 1 | 1 |
getAcceptedPermitsPerNsJSON() |  | 0% | | n/a | 1 | 1 | 1 | 1 | 1 | 1 |
lambda$incrAcceptedPermitForNs$3(String) |  | 0% | | n/a | 1 | 1 | 1 | 1 | 1 | 1 |
lambda$incrRejectedPermitForNs$2(String) |  | 0% | | n/a | 1 | 1 | 1 | 1 | 1 | 1 |
getNamenodeResolver() | | 0% | | n/a | 1 | 1 | 1 | 1 | 1 | 1 |
getRouterRpcFairnessPolicyController() | | 0% | | n/a | 1 | 1 | 1 | 1 | 1 | 1 |