recover(Map) |  | 0% |  | 0% | 12 | 12 | 92 | 92 | 1 | 1 |
splitAllocateRequest(AllocateRequest) |  | 0% |  | 0% | 17 | 17 | 55 | 55 | 1 | 1 |
mergeAllocateResponse(AllocateResponse, AllocateResponse, SubClusterId) |  | 0% |  | 0% | 28 | 28 | 57 | 57 | 1 | 1 |
init(AMRMProxyApplicationContext) |  | 0% |  | 0% | 6 | 6 | 54 | 54 | 1 | 1 |
allocate(AllocateRequest) |  | 0% |  | 0% | 7 | 7 | 52 | 52 | 1 | 1 |
cacheAllocatedContainers(List, SubClusterId) |  | 0% |  | 0% | 6 | 6 | 29 | 29 | 1 | 1 |
lambda$registerAndAllocateWithNewSubClusters$4(SubClusterId, Map) |  | 0% |  | 0% | 3 | 3 | 27 | 27 | 1 | 1 |
registerApplicationMaster(RegisterApplicationMasterRequest) |  | 0% |  | 0% | 8 | 8 | 35 | 35 | 1 | 1 |
reAttachUAMAndMergeRegisterResponse(RegisterApplicationMasterResponse, ApplicationId) |  | 0% |  | 0% | 6 | 6 | 31 | 31 | 1 | 1 |
lambda$reAttachUAMAndMergeRegisterResponse$1(SubClusterId, ApplicationId, Token) |  | 0% |  | 0% | 3 | 3 | 21 | 21 | 1 | 1 |
mergeAllocateResponses(AllocateResponse) |  | 0% |  | 0% | 6 | 6 | 21 | 21 | 1 | 1 |
finishApplicationMaster(FinishApplicationMasterRequest) |  | 0% |  | 0% | 7 | 7 | 22 | 22 | 1 | 1 |
sendRequestsToResourceManagers(Map) |  | 0% |  | 0% | 5 | 5 | 13 | 13 | 1 | 1 |
FederationInterceptor() |  | 0% | | n/a | 1 | 1 | 19 | 19 | 1 | 1 |
getTimedOutSCs(boolean) |  | 0% |  | 0% | 5 | 5 | 13 | 13 | 1 | 1 |
registerAndAllocateWithNewSubClusters(Map) |  | 0% |  | 0% | 5 | 5 | 15 | 15 | 1 | 1 |
mergeRegistrationResponses(AllocateResponse, Map) |  | 0% |  | 0% | 6 | 6 | 21 | 21 | 1 | 1 |
generateBaseAllocationResponse() |  | 0% |  | 0% | 4 | 4 | 18 | 18 | 1 | 1 |
recoverSubClusterAMRMTokenIdentifierMapFromNMSS(Map) |  | 0% |  | 0% | 3 | 3 | 12 | 12 | 1 | 1 |
launchUAMAndRegisterApplicationMaster(YarnConfiguration, String, ApplicationId) |  | 0% | | n/a | 1 | 1 | 10 | 10 | 1 | 1 |
mergeRegisterResponse(RegisterApplicationMasterResponse, RegisterApplicationMasterResponse) |  | 0% |  | 0% | 5 | 5 | 13 | 13 | 1 | 1 |
createAllocateRequest() |  | 0% | | n/a | 1 | 1 | 11 | 11 | 1 | 1 |
shutdown() |  | 0% |  | 0% | 2 | 2 | 15 | 15 | 1 | 1 |
recoverSubClusterAMRMTokenIdentifierMap(Map) |  | 0% |  | 0% | 2 | 2 | 9 | 9 | 1 | 1 |
storeAMRMProxyAppContextEntry(String, byte[]) |  | 0% |  | 0% | 2 | 2 | 7 | 7 | 1 | 1 |
getSubClusterForNode(String) |  | 0% |  | 0% | 2 | 2 | 9 | 9 | 1 | 1 |
lambda$registerAndAllocateWithNewSubClusters$2(List, SubClusterId) |  | 0% |  | 0% | 3 | 3 | 5 | 5 | 1 | 1 |
findOrCreateAllocateRequestForSubCluster(SubClusterId, AllocateRequest, Map) |  | 0% |  | 0% | 2 | 2 | 7 | 7 | 1 | 1 |
isSCHealth(SubClusterId) |  | 0% |  | 0% | 4 | 4 | 6 | 6 | 1 | 1 |
removeFinishedContainersFromCache(List) |  | 0% |  | 0% | 2 | 2 | 5 | 5 | 1 | 1 |
removeAppFromRegistry() |  | 0% |  | 0% | 4 | 4 | 5 | 5 | 1 | 1 |
createHomeRMProxy(AMRMProxyApplicationContext, Class, UserGroupInformation) |  | 0% | | n/a | 1 | 1 | 4 | 4 | 1 | 1 |
warnIfNotExists(ContainerId, String) |  | 0% |  | 0% | 2 | 2 | 5 | 5 | 1 | 1 |
checkRequestFinalApplicationStatusSuccess(FinishApplicationMasterRequest) |  | 0% |  | 0% | 3 | 3 | 3 | 3 | 1 | 1 |
isNullOrEmpty(Collection) |  | 0% |  | 0% | 3 | 3 | 1 | 1 | 1 | 1 |
isNullOrEmpty(Map) |  | 0% |  | 0% | 3 | 3 | 1 | 1 | 1 | 1 |
splitResourceRequests(List) |  | 0% | | n/a | 1 | 1 | 2 | 2 | 1 | 1 |
cleanupRegistry() |  | 0% |  | 0% | 2 | 2 | 3 | 3 | 1 | 1 |
createHomeHeartbeatHandler(Configuration, ApplicationId, AMRMClientRelayer) |  | 0% | | n/a | 1 | 1 | 1 | 1 | 1 | 1 |
static {...} |  | 0% | | n/a | 1 | 1 | 4 | 4 | 1 | 1 |
lambda$registerAndAllocateWithNewSubClusters$3(YarnConfiguration, String, ApplicationId, int) |  | 0% | | n/a | 1 | 1 | 1 | 1 | 1 | 1 |
lambda$recover$0(SubClusterId, Map.Entry) |  | 0% | | n/a | 1 | 1 | 1 | 1 | 1 | 1 |
setNextInterceptor(RequestInterceptor) |  | 0% | | n/a | 1 | 1 | 1 | 1 | 1 | 1 |
createUnmanagedAMPoolManager(ExecutorService) |  | 0% | | n/a | 1 | 1 | 1 | 1 | 1 | 1 |
getUnmanagedAMPoolSize() |  | 0% | | n/a | 1 | 1 | 1 | 1 | 1 | 1 |
cacheAllocatedContainersForSubClusterId(List, SubClusterId) |  | 0% | | n/a | 1 | 1 | 2 | 2 | 1 | 1 |
getRegistryClient() | | 0% | | n/a | 1 | 1 | 1 | 1 | 1 | 1 |
getAttemptId() | | 0% | | n/a | 1 | 1 | 1 | 1 | 1 | 1 |
getHomeHeartbeatHandler() | | 0% | | n/a | 1 | 1 | 1 | 1 | 1 | 1 |
getUnmanagedAMPool() | | 0% | | n/a | 1 | 1 | 1 | 1 | 1 | 1 |
getUamRegisterFutures() | | 0% | | n/a | 1 | 1 | 1 | 1 | 1 | 1 |
getAsyncResponseSink() | | 0% | | n/a | 1 | 1 | 1 | 1 | 1 | 1 |
getContainerIdToSubClusterIdMap() | | 0% | | n/a | 1 | 1 | 1 | 1 | 1 | 1 |