Uses of Class
org.apache.hadoop.yarn.server.federation.store.records.SubClusterInfo
Packages that use SubClusterInfo
Package
Description
Licensed to the Apache Software Foundation (ASF) under one or more
contributor license agreements.
Federation Policies.
Router policies.
Licensed to the Apache Software Foundation (ASF) under one or more
contributor license agreements.
Licensed to the Apache Software Foundation (ASF) under one or more
contributor license agreements.
Licensed to the Apache Software Foundation (ASF) under one or more
contributor license agreements.
Licensed to the Apache Software Foundation (ASF) under one or more
contributor license agreements.
Licensed to the Apache Software Foundation (ASF) under one or more
contributor license agreements.
-
Uses of SubClusterInfo in org.apache.hadoop.yarn.server.federation.cache
Methods in org.apache.hadoop.yarn.server.federation.cache that return SubClusterInfoMethods in org.apache.hadoop.yarn.server.federation.cache that return types with arguments of type SubClusterInfoModifier and TypeMethodDescriptionFederationCache.buildGetSubClustersCacheRequest(String cacheKey, boolean filterInactiveSubClusters) Build GetSubClusters CacheRequest.static Map<SubClusterId,SubClusterInfo> FederationCache.buildSubClusterInfoMap(FederationCache.CacheRequest<String, ?> cacheRequest) According to the cacheRequest, build SubClusterInfoMap.static Map<SubClusterId,SubClusterInfo> FederationCache.buildSubClusterInfoMap(GetSubClustersInfoResponse response) According to the response, build SubClusterInfoMap.FederationCache.SubClusterInfoCacheResponse.getList()abstract Map<SubClusterId,SubClusterInfo> FederationCache.getSubClusters(boolean filterInactiveSubClusters) Returns theSubClusterInfoof all active sub cluster(s).FederationCaffeineCache.getSubClusters(boolean filterInactiveSubClusters) FederationGuavaCache.getSubClusters(boolean filterInactiveSubClusters) FederationJCache.getSubClusters(boolean filterInactiveSubClusters) Methods in org.apache.hadoop.yarn.server.federation.cache with parameters of type SubClusterInfoModifier and TypeMethodDescriptionvoidFederationCache.SubClusterInfoCacheResponse.setItem(SubClusterInfo item) Method parameters in org.apache.hadoop.yarn.server.federation.cache with type arguments of type SubClusterInfoModifier and TypeMethodDescriptionvoidFederationCache.SubClusterInfoCacheResponse.setList(List<SubClusterInfo> list) -
Uses of SubClusterInfo in org.apache.hadoop.yarn.server.federation.policies
Methods in org.apache.hadoop.yarn.server.federation.policies that return types with arguments of type SubClusterInfoModifier and TypeMethodDescriptionprotected Map<SubClusterId,SubClusterInfo> AbstractConfigurableFederationPolicy.getActiveSubclusters()This methods gets active subclusters map from theFederationStateStoreFacadeand validate it not being null/empty. -
Uses of SubClusterInfo in org.apache.hadoop.yarn.server.federation.policies.router
Methods in org.apache.hadoop.yarn.server.federation.policies.router that return types with arguments of type SubClusterInfoModifier and TypeMethodDescriptionprotected Map<SubClusterId,SubClusterInfo> AbstractRouterPolicy.prefilterSubClusters(org.apache.hadoop.yarn.api.records.ReservationId reservationId, Map<SubClusterId, SubClusterInfo> activeSubClusters) Filter chosen SubCluster based on reservationId.Method parameters in org.apache.hadoop.yarn.server.federation.policies.router with type arguments of type SubClusterInfoModifier and TypeMethodDescriptionprotected abstract SubClusterIdAbstractRouterPolicy.chooseSubCluster(String queue, Map<SubClusterId, SubClusterInfo> preSelectSubClusters) This method is implemented by the specific policy, and it is used to route both reservations, and applications among a given set of sub-clusters.protected SubClusterIdHashBasedRouterPolicy.chooseSubCluster(String queue, Map<SubClusterId, SubClusterInfo> preSelectSubclusters) protected SubClusterIdLoadBasedRouterPolicy.chooseSubCluster(String queue, Map<SubClusterId, SubClusterInfo> preSelectSubclusters) protected SubClusterIdPriorityRouterPolicy.chooseSubCluster(String queue, Map<SubClusterId, SubClusterInfo> preSelectSubclusters) protected SubClusterIdRejectRouterPolicy.chooseSubCluster(String queue, Map<SubClusterId, SubClusterInfo> preSelectSubclusters) protected SubClusterIdUniformRandomRouterPolicy.chooseSubCluster(String queue, Map<SubClusterId, SubClusterInfo> preSelectSubclusters) protected SubClusterIdWeightedRandomRouterPolicy.chooseSubCluster(String queue, Map<SubClusterId, SubClusterInfo> preSelectSubclusters) protected Map<SubClusterId,SubClusterInfo> AbstractRouterPolicy.prefilterSubClusters(org.apache.hadoop.yarn.api.records.ReservationId reservationId, Map<SubClusterId, SubClusterInfo> activeSubClusters) Filter chosen SubCluster based on reservationId. -
Uses of SubClusterInfo in org.apache.hadoop.yarn.server.federation.store.impl
Methods in org.apache.hadoop.yarn.server.federation.store.impl that return types with arguments of type SubClusterInfoMethod parameters in org.apache.hadoop.yarn.server.federation.store.impl with type arguments of type SubClusterInfoModifier and TypeMethodDescriptionvoidMemoryFederationStateStore.setMembership(Map<SubClusterId, SubClusterInfo> membership) -
Uses of SubClusterInfo in org.apache.hadoop.yarn.server.federation.store.records
Methods in org.apache.hadoop.yarn.server.federation.store.records that return SubClusterInfoModifier and TypeMethodDescriptionabstract SubClusterInfoGetSubClusterInfoResponse.getSubClusterInfo()Get theSubClusterInfoencapsulating the information about the sub-cluster.abstract SubClusterInfoSubClusterRegisterRequest.getSubClusterInfo()Get theSubClusterInfoencapsulating the information about the sub-cluster.static SubClusterInfoSubClusterInfo.newInstance(SubClusterId subClusterId, String amRMServiceAddress, String clientRMServiceAddress, String rmAdminServiceAddress, String rmWebServiceAddress, long lastHeartBeat, SubClusterState state, long lastStartTime, String capability) static SubClusterInfoSubClusterInfo.newInstance(SubClusterId subClusterId, String amRMServiceAddress, String clientRMServiceAddress, String rmAdminServiceAddress, String rmWebServiceAddress, SubClusterState state, long lastStartTime, String capability) static SubClusterInfoSubClusterInfo.newInstance(SubClusterId subClusterId, String rmWebServiceAddress, SubClusterState state, long lastStartTime, long lastHeartBeat, String capability) Methods in org.apache.hadoop.yarn.server.federation.store.records that return types with arguments of type SubClusterInfoModifier and TypeMethodDescriptionabstract List<SubClusterInfo>GetSubClustersInfoResponse.getSubClusters()Get the list ofSubClusterInforepresenting the information about all sub-clusters that are currently participating in Federation.Methods in org.apache.hadoop.yarn.server.federation.store.records with parameters of type SubClusterInfoModifier and TypeMethodDescriptionstatic GetSubClusterInfoResponseGetSubClusterInfoResponse.newInstance(SubClusterInfo subClusterInfo) static SubClusterRegisterRequestSubClusterRegisterRequest.newInstance(SubClusterInfo subClusterInfo) abstract voidGetSubClusterInfoResponse.setSubClusterInfo(SubClusterInfo subClusterInfo) Set theSubClusterInfoencapsulating the information about the sub-cluster.abstract voidSubClusterRegisterRequest.setSubClusterInfo(SubClusterInfo subClusterInfo) Set theSubClusterInfoencapsulating the information about the sub-cluster.Method parameters in org.apache.hadoop.yarn.server.federation.store.records with type arguments of type SubClusterInfoModifier and TypeMethodDescriptionstatic GetSubClustersInfoResponseGetSubClustersInfoResponse.newInstance(Collection<SubClusterInfo> subClusters) abstract voidGetSubClustersInfoResponse.setSubClusters(Collection<SubClusterInfo> subClusters) Set the list ofSubClusterInforepresenting the information about all sub-clusters that are currently participating in Federation. -
Uses of SubClusterInfo in org.apache.hadoop.yarn.server.federation.store.records.impl.pb
Methods in org.apache.hadoop.yarn.server.federation.store.records.impl.pb that return SubClusterInfoModifier and TypeMethodDescriptionGetSubClusterInfoResponsePBImpl.getSubClusterInfo()SubClusterRegisterRequestPBImpl.getSubClusterInfo()Methods in org.apache.hadoop.yarn.server.federation.store.records.impl.pb that return types with arguments of type SubClusterInfoMethods in org.apache.hadoop.yarn.server.federation.store.records.impl.pb with parameters of type SubClusterInfoModifier and TypeMethodDescriptionvoidGetSubClusterInfoResponsePBImpl.setSubClusterInfo(SubClusterInfo paramSubClusterInfo) voidSubClusterRegisterRequestPBImpl.setSubClusterInfo(SubClusterInfo subClusterInfo) Method parameters in org.apache.hadoop.yarn.server.federation.store.records.impl.pb with type arguments of type SubClusterInfoModifier and TypeMethodDescriptionvoidGetSubClustersInfoResponsePBImpl.setSubClusters(Collection<SubClusterInfo> subClusters) -
Uses of SubClusterInfo in org.apache.hadoop.yarn.server.federation.store.utils
Methods in org.apache.hadoop.yarn.server.federation.store.utils with parameters of type SubClusterInfoModifier and TypeMethodDescriptionstatic voidFederationMembershipStateStoreInputValidator.checkSubClusterInfo(SubClusterInfo subClusterInfo) Validate if all the required fields onSubClusterInfoare present or not. -
Uses of SubClusterInfo in org.apache.hadoop.yarn.server.federation.utils
Methods in org.apache.hadoop.yarn.server.federation.utils that return SubClusterInfoModifier and TypeMethodDescriptionFederationStateStoreFacade.getSubCluster(SubClusterId subClusterId) Returns theSubClusterInfofor the specifiedSubClusterId.FederationStateStoreFacade.getSubCluster(SubClusterId subClusterId, boolean flushCache) Updates the cache with the centralFederationStateStoreand returns theSubClusterInfofor the specifiedSubClusterId.Methods in org.apache.hadoop.yarn.server.federation.utils that return types with arguments of type SubClusterInfoModifier and TypeMethodDescriptionFederationStateStoreFacade.getActiveSubClusters()Get active subclusters.FederationStateStoreFacade.getSubClusters(boolean filterInactiveSubClusters) Returns theSubClusterInfoof all active sub cluster(s).FederationStateStoreFacade.getSubClusters(boolean filterInactiveSubClusters, boolean flushCache) Updates the cache with the centralFederationStateStoreand returns theSubClusterInfoof all active sub cluster(s).Method parameters in org.apache.hadoop.yarn.server.federation.utils with type arguments of type SubClusterInfoModifier and TypeMethodDescriptionstatic SubClusterIdFederationStateStoreFacade.getRandomActiveSubCluster(Map<SubClusterId, SubClusterInfo> activeSubClusters, List<SubClusterId> blackList) Randomly pick ActiveSubCluster.