Index
All Classes and Interfaces|All Packages|Constant Field Values
A
- ApplicationCleaner - Class in org.apache.hadoop.yarn.server.globalpolicygenerator.applicationcleaner
-
The ApplicationCleaner is a runnable that cleans up old applications from table applicationsHomeSubCluster in FederationStateStore.
- ApplicationCleaner() - Constructor for class org.apache.hadoop.yarn.server.globalpolicygenerator.applicationcleaner.ApplicationCleaner
C
- commonPreHead(Hamlet.HTML<HtmlPage.__>) - Method in class org.apache.hadoop.yarn.server.globalpolicygenerator.webapp.GPGOverviewPage
- commonPreHead(Hamlet.HTML<HtmlPage.__>) - Method in class org.apache.hadoop.yarn.server.globalpolicygenerator.webapp.GPGPoliciesPage
- content() - Method in class org.apache.hadoop.yarn.server.globalpolicygenerator.webapp.GPGOverviewPage
- content() - Method in class org.apache.hadoop.yarn.server.globalpolicygenerator.webapp.GPGPoliciesPage
- createJerseyClient(Configuration) - Static method in class org.apache.hadoop.yarn.server.globalpolicygenerator.GPGUtils
-
Create JerseyClient based on configuration file.
- createUniformWeights(Set<SubClusterId>) - Static method in class org.apache.hadoop.yarn.server.globalpolicygenerator.GPGUtils
-
Creates a uniform weighting of 1.0 for each sub cluster.
D
- DefaultApplicationCleaner - Class in org.apache.hadoop.yarn.server.globalpolicygenerator.applicationcleaner
-
The default ApplicationCleaner that cleans up old applications from table applicationsHomeSubCluster in FederationStateStore.
- DefaultApplicationCleaner() - Constructor for class org.apache.hadoop.yarn.server.globalpolicygenerator.applicationcleaner.DefaultApplicationCleaner
- doSecureLogin() - Method in class org.apache.hadoop.yarn.server.globalpolicygenerator.GlobalPolicyGenerator
G
- get() - Method in class org.apache.hadoop.yarn.server.globalpolicygenerator.webapp.GPGWebServices
- getAppsFromRouter() - Method in class org.apache.hadoop.yarn.server.globalpolicygenerator.applicationcleaner.ApplicationCleaner
-
Query router for applications.
- getConf() - Method in class org.apache.hadoop.yarn.server.globalpolicygenerator.policygenerator.GlobalPolicy
- getConf() - Method in class org.apache.hadoop.yarn.server.globalpolicygenerator.policygenerator.PolicyGenerator
- getGpgBuildVersion() - Method in class org.apache.hadoop.yarn.server.globalpolicygenerator.webapp.dao.GpgInfo
- getGPGContext() - Method in class org.apache.hadoop.yarn.server.globalpolicygenerator.applicationcleaner.ApplicationCleaner
- getGPGContext() - Method in class org.apache.hadoop.yarn.server.globalpolicygenerator.GlobalPolicyGenerator
- getGPGInfo() - Method in class org.apache.hadoop.yarn.server.globalpolicygenerator.webapp.GPGWebServices
- getGpgStartupTime() - Method in class org.apache.hadoop.yarn.server.globalpolicygenerator.webapp.dao.GpgInfo
- getGPGStartupTime() - Static method in class org.apache.hadoop.yarn.server.globalpolicygenerator.GlobalPolicyGenerator
- getGpgVersion() - Method in class org.apache.hadoop.yarn.server.globalpolicygenerator.webapp.dao.GpgInfo
- getGpgVersionBuiltOn() - Method in class org.apache.hadoop.yarn.server.globalpolicygenerator.webapp.dao.GpgInfo
- getHadoopBuildVersion() - Method in class org.apache.hadoop.yarn.server.globalpolicygenerator.webapp.dao.GpgInfo
- getHadoopVersion() - Method in class org.apache.hadoop.yarn.server.globalpolicygenerator.webapp.dao.GpgInfo
- getHadoopVersionBuiltOn() - Method in class org.apache.hadoop.yarn.server.globalpolicygenerator.webapp.dao.GpgInfo
- getInfos(Map<SubClusterId, SubClusterInfo>) - Method in class org.apache.hadoop.yarn.server.globalpolicygenerator.policygenerator.PolicyGenerator
-
Helper to retrieve metrics from the RM REST endpoints.
- getName() - Method in class org.apache.hadoop.yarn.server.globalpolicygenerator.GlobalPolicyGenerator
- getPolicy() - Method in class org.apache.hadoop.yarn.server.globalpolicygenerator.policygenerator.PolicyGenerator
- getPolicyFacade() - Method in interface org.apache.hadoop.yarn.server.globalpolicygenerator.GPGContext
- getPolicyFacade() - Method in class org.apache.hadoop.yarn.server.globalpolicygenerator.GPGContextImpl
- getPolicyManager(String) - Method in class org.apache.hadoop.yarn.server.globalpolicygenerator.GPGPolicyFacade
-
Provides a utility for the policy generator to read the policy manager from the FederationStateStore.
- getRegistryClient() - Method in class org.apache.hadoop.yarn.server.globalpolicygenerator.applicationcleaner.ApplicationCleaner
- getRegistryClient() - Method in interface org.apache.hadoop.yarn.server.globalpolicygenerator.GPGContext
- getRegistryClient() - Method in class org.apache.hadoop.yarn.server.globalpolicygenerator.GPGContextImpl
- getRouterKnownApplications() - Method in class org.apache.hadoop.yarn.server.globalpolicygenerator.applicationcleaner.ApplicationCleaner
-
Get the list of known applications in the cluster from Router.
- getSchedulerInfo(Map<SubClusterId, SubClusterInfo>) - Method in class org.apache.hadoop.yarn.server.globalpolicygenerator.policygenerator.PolicyGenerator
-
Helper to retrieve SchedulerInfos.
- getStateStoreFacade() - Method in interface org.apache.hadoop.yarn.server.globalpolicygenerator.GPGContext
- getStateStoreFacade() - Method in class org.apache.hadoop.yarn.server.globalpolicygenerator.GPGContextImpl
- getSubClustersMetricsInfo(Map<SubClusterId, Map<Class, Object>>) - Method in class org.apache.hadoop.yarn.server.globalpolicygenerator.policygenerator.LoadBasedGlobalPolicy
-
Get the ClusterMetric information of the subCluster.
- getTargetWeights(Map<SubClusterId, ClusterMetricsInfo>) - Method in class org.apache.hadoop.yarn.server.globalpolicygenerator.policygenerator.LoadBasedGlobalPolicy
-
Get subCluster target weight.
- getWebApp() - Method in class org.apache.hadoop.yarn.server.globalpolicygenerator.GlobalPolicyGenerator
- getWeightByScaling(int, int) - Method in class org.apache.hadoop.yarn.server.globalpolicygenerator.policygenerator.LoadBasedGlobalPolicy
-
Get weight information.
- getWeightedLocalityPolicyManager(String, Map<SubClusterId, Map<Class, Object>>) - Method in class org.apache.hadoop.yarn.server.globalpolicygenerator.policygenerator.LoadBasedGlobalPolicy
-
GPG can help update the policy of the queue.
- GlobalPolicy - Class in org.apache.hadoop.yarn.server.globalpolicygenerator.policygenerator
-
This interface defines the plug-able policy that the PolicyGenerator uses to update policies into the state store.
- GlobalPolicy() - Constructor for class org.apache.hadoop.yarn.server.globalpolicygenerator.policygenerator.GlobalPolicy
- GlobalPolicyGenerator - Class in org.apache.hadoop.yarn.server.globalpolicygenerator
-
Global Policy Generator (GPG) is a Yarn Federation component.
- GlobalPolicyGenerator() - Constructor for class org.apache.hadoop.yarn.server.globalpolicygenerator.GlobalPolicyGenerator
- GPGContext - Interface in org.apache.hadoop.yarn.server.globalpolicygenerator
-
Context for Global Policy Generator.
- GPGContextImpl - Class in org.apache.hadoop.yarn.server.globalpolicygenerator
-
Context implementation for Global Policy Generator.
- GPGContextImpl() - Constructor for class org.apache.hadoop.yarn.server.globalpolicygenerator.GPGContextImpl
- GPGController - Class in org.apache.hadoop.yarn.server.globalpolicygenerator.webapp
-
Controller for the GPG Web UI.
- GpgInfo - Class in org.apache.hadoop.yarn.server.globalpolicygenerator.webapp.dao
- GpgInfo() - Constructor for class org.apache.hadoop.yarn.server.globalpolicygenerator.webapp.dao.GpgInfo
- GpgInfo(GPGContext) - Constructor for class org.apache.hadoop.yarn.server.globalpolicygenerator.webapp.dao.GpgInfo
- GPGOverviewBlock - Class in org.apache.hadoop.yarn.server.globalpolicygenerator.webapp
-
Overview block for the GPG Web UI.
- GPGOverviewPage - Class in org.apache.hadoop.yarn.server.globalpolicygenerator.webapp
-
Overview page for the GPG Web UI.
- GPGOverviewPage() - Constructor for class org.apache.hadoop.yarn.server.globalpolicygenerator.webapp.GPGOverviewPage
- GPGPoliciesBlock - Class in org.apache.hadoop.yarn.server.globalpolicygenerator.webapp
-
Overview block for the GPG Policies Web UI.
- GPGPoliciesPage - Class in org.apache.hadoop.yarn.server.globalpolicygenerator.webapp
-
Overview page for the GPG Policies Web UI.
- GPGPoliciesPage() - Constructor for class org.apache.hadoop.yarn.server.globalpolicygenerator.webapp.GPGPoliciesPage
- GPGPolicyFacade - Class in org.apache.hadoop.yarn.server.globalpolicygenerator
-
A utility class for the GPG Policy Generator to read and write policies into the FederationStateStore.
- GPGPolicyFacade(FederationStateStoreFacade, Configuration) - Constructor for class org.apache.hadoop.yarn.server.globalpolicygenerator.GPGPolicyFacade
- GPGUtils - Class in org.apache.hadoop.yarn.server.globalpolicygenerator
-
GPGUtils contains utility functions for the GPG.
- GPGWebApp - Class in org.apache.hadoop.yarn.server.globalpolicygenerator.webapp
-
The GPG webapp.
- GPGWebApp(GlobalPolicyGenerator) - Constructor for class org.apache.hadoop.yarn.server.globalpolicygenerator.webapp.GPGWebApp
- GPGWebServices - Class in org.apache.hadoop.yarn.server.globalpolicygenerator.webapp
- GPGWebServices(GlobalPolicyGenerator) - Constructor for class org.apache.hadoop.yarn.server.globalpolicygenerator.webapp.GPGWebServices
I
- index() - Method in class org.apache.hadoop.yarn.server.globalpolicygenerator.webapp.GPGController
- init(Configuration, GPGContext) - Method in class org.apache.hadoop.yarn.server.globalpolicygenerator.applicationcleaner.ApplicationCleaner
- initAndStart(Configuration, boolean) - Method in class org.apache.hadoop.yarn.server.globalpolicygenerator.GlobalPolicyGenerator
- invokeRMWebService(String, String, Class<T>, Configuration) - Static method in class org.apache.hadoop.yarn.server.globalpolicygenerator.GPGUtils
-
Performs an invocation of the remote RMWebService.
- invokeRMWebService(String, String, Class<T>, Configuration, String) - Static method in class org.apache.hadoop.yarn.server.globalpolicygenerator.GPGUtils
-
Performs an invocation of the remote RMWebService.
L
- LINEAR - Enum constant in enum class org.apache.hadoop.yarn.server.globalpolicygenerator.policygenerator.LoadBasedGlobalPolicy.Scaling
- LoadBasedGlobalPolicy - Class in org.apache.hadoop.yarn.server.globalpolicygenerator.policygenerator
-
Load based policy that generates weighted policies by scaling the cluster load (based on pending) to a weight from 0.0 to 1.0.
- LoadBasedGlobalPolicy() - Constructor for class org.apache.hadoop.yarn.server.globalpolicygenerator.policygenerator.LoadBasedGlobalPolicy
- LoadBasedGlobalPolicy.Scaling - Enum Class in org.apache.hadoop.yarn.server.globalpolicygenerator.policygenerator
- LOG - Enum constant in enum class org.apache.hadoop.yarn.server.globalpolicygenerator.policygenerator.LoadBasedGlobalPolicy.Scaling
- LOG - Static variable in class org.apache.hadoop.yarn.server.globalpolicygenerator.GlobalPolicyGenerator
M
- main(String[]) - Static method in class org.apache.hadoop.yarn.server.globalpolicygenerator.GlobalPolicyGenerator
N
- nav() - Method in class org.apache.hadoop.yarn.server.globalpolicygenerator.webapp.GPGOverviewPage
- nav() - Method in class org.apache.hadoop.yarn.server.globalpolicygenerator.webapp.GPGPoliciesPage
- NavBlock - Class in org.apache.hadoop.yarn.server.globalpolicygenerator.webapp
-
Navigation block for the GPG Web UI.
- NavBlock() - Constructor for class org.apache.hadoop.yarn.server.globalpolicygenerator.webapp.NavBlock
- NONE - Enum constant in enum class org.apache.hadoop.yarn.server.globalpolicygenerator.policygenerator.LoadBasedGlobalPolicy.Scaling
- NoOpGlobalPolicy - Class in org.apache.hadoop.yarn.server.globalpolicygenerator.policygenerator
-
Default policy that does not update any policy configurations.
- NoOpGlobalPolicy() - Constructor for class org.apache.hadoop.yarn.server.globalpolicygenerator.policygenerator.NoOpGlobalPolicy
O
- org.apache.hadoop.yarn.server.globalpolicygenerator - package org.apache.hadoop.yarn.server.globalpolicygenerator
-
Licensed to the Apache Software Foundation (ASF) under one or more contributor license agreements.
- org.apache.hadoop.yarn.server.globalpolicygenerator.applicationcleaner - package org.apache.hadoop.yarn.server.globalpolicygenerator.applicationcleaner
-
Licensed to the Apache Software Foundation (ASF) under one or more contributor license agreements.
- org.apache.hadoop.yarn.server.globalpolicygenerator.policygenerator - package org.apache.hadoop.yarn.server.globalpolicygenerator.policygenerator
-
Classes comprising the policy generator for the GPG.
- org.apache.hadoop.yarn.server.globalpolicygenerator.subclustercleaner - package org.apache.hadoop.yarn.server.globalpolicygenerator.subclustercleaner
-
Licensed to the Apache Software Foundation (ASF) under one or more contributor license agreements.
- org.apache.hadoop.yarn.server.globalpolicygenerator.webapp - package org.apache.hadoop.yarn.server.globalpolicygenerator.webapp
-
Classes comprising the policy generator for the GPG.
- org.apache.hadoop.yarn.server.globalpolicygenerator.webapp.dao - package org.apache.hadoop.yarn.server.globalpolicygenerator.webapp.dao
-
Licensed to the Apache Software Foundation (ASF) under one or more contributor license agreements.
- overview() - Method in class org.apache.hadoop.yarn.server.globalpolicygenerator.webapp.GPGController
P
- policies() - Method in class org.apache.hadoop.yarn.server.globalpolicygenerator.webapp.GPGController
- PolicyGenerator - Class in org.apache.hadoop.yarn.server.globalpolicygenerator.policygenerator
-
The PolicyGenerator runs periodically and updates the policy configuration for each queue into the FederationStateStore.
- PolicyGenerator(Configuration, GPGContext) - Constructor for class org.apache.hadoop.yarn.server.globalpolicygenerator.policygenerator.PolicyGenerator
-
The PolicyGenerator periodically reads SubCluster load and updates policies into the FederationStateStore.
- preHead(Hamlet.HTML<HtmlPage.__>) - Method in class org.apache.hadoop.yarn.server.globalpolicygenerator.webapp.GPGOverviewPage
- preHead(Hamlet.HTML<HtmlPage.__>) - Method in class org.apache.hadoop.yarn.server.globalpolicygenerator.webapp.GPGPoliciesPage
Q
- QUADRATIC - Enum constant in enum class org.apache.hadoop.yarn.server.globalpolicygenerator.policygenerator.LoadBasedGlobalPolicy.Scaling
R
- registerPaths() - Method in class org.apache.hadoop.yarn.server.globalpolicygenerator.policygenerator.GlobalPolicy
-
Return a map of the object type and RM path to request it from - the framework will query these paths and provide the objects to the policy.
- registerPaths() - Method in class org.apache.hadoop.yarn.server.globalpolicygenerator.policygenerator.LoadBasedGlobalPolicy
- render(HtmlBlock.Block) - Method in class org.apache.hadoop.yarn.server.globalpolicygenerator.webapp.GPGOverviewBlock
- render(HtmlBlock.Block) - Method in class org.apache.hadoop.yarn.server.globalpolicygenerator.webapp.GPGPoliciesBlock
- render(HtmlBlock.Block) - Method in class org.apache.hadoop.yarn.server.globalpolicygenerator.webapp.NavBlock
- resourceConfig() - Method in class org.apache.hadoop.yarn.server.globalpolicygenerator.webapp.GPGWebApp
- run() - Method in class org.apache.hadoop.yarn.server.globalpolicygenerator.applicationcleaner.ApplicationCleaner
- run() - Method in class org.apache.hadoop.yarn.server.globalpolicygenerator.applicationcleaner.DefaultApplicationCleaner
- run() - Method in class org.apache.hadoop.yarn.server.globalpolicygenerator.policygenerator.PolicyGenerator
- run() - Method in class org.apache.hadoop.yarn.server.globalpolicygenerator.subclustercleaner.SubClusterCleaner
S
- serviceInit(Configuration) - Method in class org.apache.hadoop.yarn.server.globalpolicygenerator.GlobalPolicyGenerator
- serviceStart() - Method in class org.apache.hadoop.yarn.server.globalpolicygenerator.GlobalPolicyGenerator
- serviceStop() - Method in class org.apache.hadoop.yarn.server.globalpolicygenerator.GlobalPolicyGenerator
- setConf(Configuration) - Method in class org.apache.hadoop.yarn.server.globalpolicygenerator.policygenerator.GlobalPolicy
- setConf(Configuration) - Method in class org.apache.hadoop.yarn.server.globalpolicygenerator.policygenerator.LoadBasedGlobalPolicy
- setConf(Configuration) - Method in class org.apache.hadoop.yarn.server.globalpolicygenerator.policygenerator.PolicyGenerator
- setConfig(Configuration) - Method in class org.apache.hadoop.yarn.server.globalpolicygenerator.GlobalPolicyGenerator
- setPolicy(GlobalPolicy) - Method in class org.apache.hadoop.yarn.server.globalpolicygenerator.policygenerator.PolicyGenerator
- setPolicyFacade(GPGPolicyFacade) - Method in interface org.apache.hadoop.yarn.server.globalpolicygenerator.GPGContext
- setPolicyFacade(GPGPolicyFacade) - Method in class org.apache.hadoop.yarn.server.globalpolicygenerator.GPGContextImpl
- setPolicyManager(FederationPolicyManager) - Method in class org.apache.hadoop.yarn.server.globalpolicygenerator.GPGPolicyFacade
-
Provides a utility for the policy generator to write a policy manager into the FederationStateStore.
- setRegistryClient(FederationRegistryClient) - Method in interface org.apache.hadoop.yarn.server.globalpolicygenerator.GPGContext
- setRegistryClient(FederationRegistryClient) - Method in class org.apache.hadoop.yarn.server.globalpolicygenerator.GPGContextImpl
- setStateStoreFacade(FederationStateStoreFacade) - Method in interface org.apache.hadoop.yarn.server.globalpolicygenerator.GPGContext
- setStateStoreFacade(FederationStateStoreFacade) - Method in class org.apache.hadoop.yarn.server.globalpolicygenerator.GPGContextImpl
- setup() - Method in class org.apache.hadoop.yarn.server.globalpolicygenerator.webapp.GPGWebApp
- SHUTDOWN_HOOK_PRIORITY - Static variable in class org.apache.hadoop.yarn.server.globalpolicygenerator.GlobalPolicyGenerator
- startGPG(String[], Configuration) - Static method in class org.apache.hadoop.yarn.server.globalpolicygenerator.GlobalPolicyGenerator
- startWepApp() - Method in class org.apache.hadoop.yarn.server.globalpolicygenerator.GlobalPolicyGenerator
- SubClusterCleaner - Class in org.apache.hadoop.yarn.server.globalpolicygenerator.subclustercleaner
-
The sub-cluster cleaner is one of the GPG's services that periodically checks the membership table in FederationStateStore and mark sub-clusters that have not sent a heartbeat in certain amount of time as LOST.
- SubClusterCleaner(Configuration, GPGContext) - Constructor for class org.apache.hadoop.yarn.server.globalpolicygenerator.subclustercleaner.SubClusterCleaner
-
The sub-cluster cleaner runnable is invoked by the sub cluster cleaner service to check the membership table and remove sub clusters that have not sent a heart beat in some amount of time.
U
- UniformWeightedLocalityGlobalPolicy - Class in org.apache.hadoop.yarn.server.globalpolicygenerator.policygenerator
-
Simple policy that generates and updates uniform weighted locality policies.
- UniformWeightedLocalityGlobalPolicy() - Constructor for class org.apache.hadoop.yarn.server.globalpolicygenerator.policygenerator.UniformWeightedLocalityGlobalPolicy
- updatePolicy(String, Map<SubClusterId, Map<Class, Object>>, FederationPolicyManager) - Method in class org.apache.hadoop.yarn.server.globalpolicygenerator.policygenerator.GlobalPolicy
-
Given a queue, cluster metrics, and policy manager, update the policy to account for the cluster status.
- updatePolicy(String, Map<SubClusterId, Map<Class, Object>>, FederationPolicyManager) - Method in class org.apache.hadoop.yarn.server.globalpolicygenerator.policygenerator.LoadBasedGlobalPolicy
-
Update the policy of the queue.
- updatePolicy(String, Map<SubClusterId, Map<Class, Object>>, FederationPolicyManager) - Method in class org.apache.hadoop.yarn.server.globalpolicygenerator.policygenerator.NoOpGlobalPolicy
- updatePolicy(String, Map<SubClusterId, Map<Class, Object>>, FederationPolicyManager) - Method in class org.apache.hadoop.yarn.server.globalpolicygenerator.policygenerator.UniformWeightedLocalityGlobalPolicy
V
- valueOf(String) - Static method in enum class org.apache.hadoop.yarn.server.globalpolicygenerator.policygenerator.LoadBasedGlobalPolicy.Scaling
-
Returns the enum constant of this class with the specified name.
- values() - Static method in enum class org.apache.hadoop.yarn.server.globalpolicygenerator.policygenerator.LoadBasedGlobalPolicy.Scaling
-
Returns an array containing the constants of this enum class, in the order they are declared.
All Classes and Interfaces|All Packages|Constant Field Values