A B C D E F G H I L M N O P Q R S T U V W Y Z

A

AbstractAMRMProxyPolicy - Class in org.apache.hadoop.yarn.server.federation.policies.amrmproxy

Base abstract class for FederationAMRMProxyPolicy implementations, that provides common validation for reinitialization.

AbstractAMRMProxyPolicy() - Constructor for class org.apache.hadoop.yarn.server.federation.policies.amrmproxy.AbstractAMRMProxyPolicy

AbstractConfigurableFederationPolicy - Class in org.apache.hadoop.yarn.server.federation.policies

Base abstract class for a weighted ConfigurableFederationPolicy.

AbstractConfigurableFederationPolicy() - Constructor for class org.apache.hadoop.yarn.server.federation.policies.AbstractConfigurableFederationPolicy

AbstractPolicyManager - Class in org.apache.hadoop.yarn.server.federation.policies.manager

This class provides basic implementation for common methods that multiple policies will need to implement.

AbstractPolicyManager() - Constructor for class org.apache.hadoop.yarn.server.federation.policies.manager.AbstractPolicyManager

AbstractRouterPolicy - Class in org.apache.hadoop.yarn.server.federation.policies.router

Base abstract class for FederationRouterPolicy implementations, that provides common validation for reinitialization.

AbstractRouterPolicy() - Constructor for class org.apache.hadoop.yarn.server.federation.policies.router.AbstractRouterPolicy

AbstractSubClusterResolver - Class in org.apache.hadoop.yarn.server.federation.resolver

Partial implementation of SubClusterResolver, containing basic implementations of the read methods.

AbstractSubClusterResolver() - Constructor for class org.apache.hadoop.yarn.server.federation.resolver.AbstractSubClusterResolver

ACLS_UPDATED_EVENT_TYPE - Static variable in class org.apache.hadoop.yarn.server.metrics.ApplicationMetricsConstants

add(AppAttemptInfo) - Method in class org.apache.hadoop.yarn.server.webapp.dao.AppAttemptsInfo

add(AppInfo) - Method in class org.apache.hadoop.yarn.server.webapp.dao.AppsInfo

add(ContainerInfo) - Method in class org.apache.hadoop.yarn.server.webapp.dao.ContainersInfo

addAllApplicationsToCleanup(List<ApplicationId>) - Method in class org.apache.hadoop.yarn.server.api.protocolrecords.impl.pb.NodeHeartbeatResponsePBImpl

addAllApplicationsToCleanup(List<ApplicationId>) - Method in class org.apache.hadoop.yarn.server.api.protocolrecords.NodeHeartbeatResponse

addAllContainersToCleanup(List<ContainerId>) - Method in class org.apache.hadoop.yarn.server.api.protocolrecords.impl.pb.NodeHeartbeatResponsePBImpl

addAllContainersToCleanup(List<ContainerId>) - Method in class org.apache.hadoop.yarn.server.api.protocolrecords.NodeHeartbeatResponse

addAllContainersToDecrease(Collection<Container>) - Method in class org.apache.hadoop.yarn.server.api.protocolrecords.impl.pb.NodeHeartbeatResponsePBImpl

addAllContainersToDecrease(Collection<Container>) - Method in class org.apache.hadoop.yarn.server.api.protocolrecords.NodeHeartbeatResponse

addAllContainersToSignal(List<SignalContainerRequest>) - Method in class org.apache.hadoop.yarn.server.api.protocolrecords.impl.pb.NodeHeartbeatResponsePBImpl

addAllContainersToSignal(List<SignalContainerRequest>) - Method in class org.apache.hadoop.yarn.server.api.protocolrecords.NodeHeartbeatResponse

addAllContainersToUpdate(Collection<Container>) - Method in class org.apache.hadoop.yarn.server.api.protocolrecords.impl.pb.NodeHeartbeatResponsePBImpl

addAllContainersToUpdate(Collection<Container>) - Method in class org.apache.hadoop.yarn.server.api.protocolrecords.NodeHeartbeatResponse

addApplicationHomeSubCluster(AddApplicationHomeSubClusterRequest) - Method in interface org.apache.hadoop.yarn.server.federation.store.FederationApplicationHomeSubClusterStore

Register the home SubClusterId of the newly submitted ApplicationId.

addApplicationHomeSubCluster(AddApplicationHomeSubClusterRequest) - Method in class org.apache.hadoop.yarn.server.federation.store.impl.MemoryFederationStateStore

addApplicationHomeSubCluster(AddApplicationHomeSubClusterRequest) - Method in class org.apache.hadoop.yarn.server.federation.store.impl.SQLFederationStateStore

addApplicationHomeSubCluster(AddApplicationHomeSubClusterRequest) - Method in class org.apache.hadoop.yarn.server.federation.store.impl.ZookeeperFederationStateStore

addApplicationHomeSubCluster(ApplicationHomeSubCluster) - Method in class org.apache.hadoop.yarn.server.federation.utils.FederationStateStoreFacade

Adds the home SubClusterId for the specified ApplicationId.

AddApplicationHomeSubClusterRequest - Class in org.apache.hadoop.yarn.server.federation.store.records

The request sent by the Router to Federation state store to map the home subcluster of a newly submitted application.

AddApplicationHomeSubClusterRequest() - Constructor for class org.apache.hadoop.yarn.server.federation.store.records.AddApplicationHomeSubClusterRequest

AddApplicationHomeSubClusterRequestPBImpl - Class in org.apache.hadoop.yarn.server.federation.store.records.impl.pb

Protocol buffer based implementation of AddApplicationHomeSubClusterRequest.

AddApplicationHomeSubClusterRequestPBImpl() - Constructor for class org.apache.hadoop.yarn.server.federation.store.records.impl.pb.AddApplicationHomeSubClusterRequestPBImpl

AddApplicationHomeSubClusterRequestPBImpl(YarnServerFederationProtos.AddApplicationHomeSubClusterRequestProto) - Constructor for class org.apache.hadoop.yarn.server.federation.store.records.impl.pb.AddApplicationHomeSubClusterRequestPBImpl

AddApplicationHomeSubClusterResponse - Class in org.apache.hadoop.yarn.server.federation.store.records

AddApplicationHomeSubClusterResponse contains the answer from the FederationApplicationHomeSubClusterStore to a request to insert a newly generated applicationId and its owner.

AddApplicationHomeSubClusterResponse() - Constructor for class org.apache.hadoop.yarn.server.federation.store.records.AddApplicationHomeSubClusterResponse

AddApplicationHomeSubClusterResponsePBImpl - Class in org.apache.hadoop.yarn.server.federation.store.records.impl.pb

Protocol buffer based implementation of AddApplicationHomeSubClusterResponse.

AddApplicationHomeSubClusterResponsePBImpl() - Constructor for class org.apache.hadoop.yarn.server.federation.store.records.impl.pb.AddApplicationHomeSubClusterResponsePBImpl

AddApplicationHomeSubClusterResponsePBImpl(YarnServerFederationProtos.AddApplicationHomeSubClusterResponseProto) - Constructor for class org.apache.hadoop.yarn.server.federation.store.records.impl.pb.AddApplicationHomeSubClusterResponsePBImpl

addContainersToBeRemovedFromNM(List<ContainerId>) - Method in class org.apache.hadoop.yarn.server.api.protocolrecords.impl.pb.NodeHeartbeatResponsePBImpl

addContainersToBeRemovedFromNM(List<ContainerId>) - Method in class org.apache.hadoop.yarn.server.api.protocolrecords.NodeHeartbeatResponse

addTimelineAuthFilter(String, Set<String>, TimelineDelgationTokenSecretManagerService) - Static method in class org.apache.hadoop.yarn.server.util.timeline.TimelineServerUtils

Adds timeline authentication filter to the set of default filter initializers and assigns the delegation token manager service to it.

addToOutstandingReqs(List<ResourceRequest>) - Method in class org.apache.hadoop.yarn.server.scheduler.OpportunisticContainerContext

Takes a list of ResourceRequests (asks), extracts the key information viz.

allocate(AllocateRequest) - Method in class org.apache.hadoop.yarn.server.api.impl.pb.client.DistributedSchedulingAMProtocolPBClientImpl

allocate(RpcController, YarnServiceProtos.AllocateRequestProto) - Method in class org.apache.hadoop.yarn.server.api.impl.pb.service.DistributedSchedulingAMProtocolPBServiceImpl

allocateAsync(String, AllocateRequest, AsyncCallback<AllocateResponse>) - Method in class org.apache.hadoop.yarn.server.uam.UnmanagedAMPoolManager

AllocateAsync to an UAM.

allocateAsync(AllocateRequest, AsyncCallback<AllocateResponse>) - Method in class org.apache.hadoop.yarn.server.uam.UnmanagedApplicationManager

Sends the specified heart beat request to the resource manager and invokes the callback asynchronously with the response.

allocateContainers(ResourceBlacklistRequest, List<ResourceRequest>, ApplicationAttemptId, OpportunisticContainerContext, long, String) - Method in class org.apache.hadoop.yarn.server.scheduler.OpportunisticContainerAllocator

Allocate OPPORTUNISTIC containers.

ALLOCATED_HOST_HTTP_ADDRESS_INFO - Static variable in class org.apache.hadoop.yarn.server.metrics.ContainerMetricsConstants

ALLOCATED_HOST_INFO - Static variable in class org.apache.hadoop.yarn.server.metrics.ContainerMetricsConstants

ALLOCATED_MEMORY_INFO - Static variable in class org.apache.hadoop.yarn.server.metrics.ContainerMetricsConstants

ALLOCATED_PORT_INFO - Static variable in class org.apache.hadoop.yarn.server.metrics.ContainerMetricsConstants

ALLOCATED_PRIORITY_INFO - Static variable in class org.apache.hadoop.yarn.server.metrics.ContainerMetricsConstants

ALLOCATED_VCORE_INFO - Static variable in class org.apache.hadoop.yarn.server.metrics.ContainerMetricsConstants

allocatedMB - Variable in class org.apache.hadoop.yarn.server.webapp.dao.ContainerInfo

allocatedResources - Variable in class org.apache.hadoop.yarn.server.webapp.dao.ContainerInfo

allocatedVCores - Variable in class org.apache.hadoop.yarn.server.webapp.dao.ContainerInfo

allocateForDistributedScheduling(DistributedSchedulingAllocateRequest) - Method in interface org.apache.hadoop.yarn.server.api.DistributedSchedulingAMProtocol

Extends the allocate to wrap the response with additional metadata.

allocateForDistributedScheduling(DistributedSchedulingAllocateRequest) - Method in class org.apache.hadoop.yarn.server.api.impl.pb.client.DistributedSchedulingAMProtocolPBClientImpl

allocateForDistributedScheduling(RpcController, YarnServerCommonServiceProtos.DistributedSchedulingAllocateRequestProto) - Method in class org.apache.hadoop.yarn.server.api.impl.pb.service.DistributedSchedulingAMProtocolPBServiceImpl

allocateWithReRegister(AllocateRequest, ApplicationMasterProtocol, RegisterApplicationMasterRequest, ApplicationId) - Static method in class org.apache.hadoop.yarn.server.utils.AMRMClientUtils

Helper method for client calling ApplicationMasterProtocol.allocate that handles re-register if RM fails over.

AllocationParams() - Constructor for class org.apache.hadoop.yarn.server.scheduler.OpportunisticContainerAllocator.AllocationParams

AM_CONTAINER_LAUNCH_COMMAND - Static variable in class org.apache.hadoop.yarn.server.metrics.ApplicationMetricsConstants

AM_NODE_LABEL_EXPRESSION - Static variable in class org.apache.hadoop.yarn.server.metrics.ApplicationMetricsConstants

amContainerId - Variable in class org.apache.hadoop.yarn.server.webapp.dao.AppAttemptInfo

AMRequestHandlerThread() - Constructor for class org.apache.hadoop.yarn.server.uam.UnmanagedApplicationManager.AMRequestHandlerThread

AMRMClientUtils - Class in org.apache.hadoop.yarn.server.utils

Utility class for AMRMClient.

amrmProxyFederationPolicy - Variable in class org.apache.hadoop.yarn.server.federation.policies.manager.AbstractPolicyManager

app - Variable in class org.apache.hadoop.yarn.server.webapp.dao.AppsInfo

APP_ALREADY_REGISTERED_MESSAGE - Static variable in class org.apache.hadoop.yarn.server.utils.AMRMClientUtils

APP_AM_CONTAINER_PREEMPTED - Static variable in class org.apache.hadoop.yarn.server.metrics.ApplicationMetricsConstants

APP_CPU_METRICS - Static variable in class org.apache.hadoop.yarn.server.metrics.ApplicationMetricsConstants

APP_CPU_PREEMPT_METRICS - Static variable in class org.apache.hadoop.yarn.server.metrics.ApplicationMetricsConstants

APP_MEM_METRICS - Static variable in class org.apache.hadoop.yarn.server.metrics.ApplicationMetricsConstants

APP_MEM_PREEMPT_METRICS - Static variable in class org.apache.hadoop.yarn.server.metrics.ApplicationMetricsConstants

APP_NAME - Static variable in class org.apache.hadoop.yarn.server.uam.UnmanagedApplicationManager

APP_NODE_LABEL_EXPRESSION - Static variable in class org.apache.hadoop.yarn.server.metrics.ApplicationMetricsConstants

APP_NON_AM_CONTAINER_PREEMPTED - Static variable in class org.apache.hadoop.yarn.server.metrics.ApplicationMetricsConstants

APP_RESOURCE_PREEMPTED_CPU - Static variable in class org.apache.hadoop.yarn.server.metrics.ApplicationMetricsConstants

APP_RESOURCE_PREEMPTED_MEM - Static variable in class org.apache.hadoop.yarn.server.metrics.ApplicationMetricsConstants

APP_TAGS_INFO - Static variable in class org.apache.hadoop.yarn.server.metrics.ApplicationMetricsConstants

APP_VIEW_ACLS_ENTITY_INFO - Static variable in class org.apache.hadoop.yarn.server.metrics.ApplicationMetricsConstants

AppAttemptBlock - Class in org.apache.hadoop.yarn.server.webapp

AppAttemptBlock(ApplicationBaseProtocol, View.ViewContext) - Constructor for class org.apache.hadoop.yarn.server.webapp.AppAttemptBlock

appAttemptId - Variable in class org.apache.hadoop.yarn.server.webapp.AppAttemptBlock

appAttemptId - Variable in class org.apache.hadoop.yarn.server.webapp.dao.AppAttemptInfo

AppAttemptInfo - Class in org.apache.hadoop.yarn.server.webapp.dao

AppAttemptInfo() - Constructor for class org.apache.hadoop.yarn.server.webapp.dao.AppAttemptInfo

AppAttemptInfo(ApplicationAttemptReport) - Constructor for class org.apache.hadoop.yarn.server.webapp.dao.AppAttemptInfo

AppAttemptMetricsConstants - Class in org.apache.hadoop.yarn.server.metrics

AppAttemptMetricsConstants() - Constructor for class org.apache.hadoop.yarn.server.metrics.AppAttemptMetricsConstants

AppAttemptsInfo - Class in org.apache.hadoop.yarn.server.webapp.dao

AppAttemptsInfo() - Constructor for class org.apache.hadoop.yarn.server.webapp.dao.AppAttemptsInfo

appAttemptState - Variable in class org.apache.hadoop.yarn.server.webapp.dao.AppAttemptInfo

appBaseProt - Variable in class org.apache.hadoop.yarn.server.webapp.AppAttemptBlock

appBaseProt - Variable in class org.apache.hadoop.yarn.server.webapp.AppBlock

appBaseProt - Variable in class org.apache.hadoop.yarn.server.webapp.AppsBlock

appBaseProt - Variable in class org.apache.hadoop.yarn.server.webapp.ContainerBlock

appBaseProt - Variable in class org.apache.hadoop.yarn.server.webapp.WebServices

AppBlock - Class in org.apache.hadoop.yarn.server.webapp

AppBlock(ApplicationBaseProtocol, View.ViewContext, Configuration) - Constructor for class org.apache.hadoop.yarn.server.webapp.AppBlock

AppCollectorData - Class in org.apache.hadoop.yarn.server.api.records

AppCollectorData() - Constructor for class org.apache.hadoop.yarn.server.api.records.AppCollectorData

AppCollectorDataPBImpl - Class in org.apache.hadoop.yarn.server.api.records.impl.pb

AppCollectorDataPBImpl() - Constructor for class org.apache.hadoop.yarn.server.api.records.impl.pb.AppCollectorDataPBImpl

AppCollectorDataPBImpl(YarnServerCommonServiceProtos.AppCollectorDataProto) - Constructor for class org.apache.hadoop.yarn.server.api.records.impl.pb.AppCollectorDataPBImpl

appID - Variable in class org.apache.hadoop.yarn.server.webapp.AppBlock

appId - Variable in class org.apache.hadoop.yarn.server.webapp.dao.AppInfo

AppInfo - Class in org.apache.hadoop.yarn.server.webapp.dao

AppInfo() - Constructor for class org.apache.hadoop.yarn.server.webapp.dao.AppInfo

AppInfo(ApplicationReport) - Constructor for class org.apache.hadoop.yarn.server.webapp.dao.AppInfo

APPLICATION_PRIORITY_INFO - Static variable in class org.apache.hadoop.yarn.server.metrics.ApplicationMetricsConstants

ApplicationHomeSubCluster - Class in org.apache.hadoop.yarn.server.federation.store.records

ApplicationHomeSubCluster is a report of the runtime information of the application that is running in the federated cluster.

ApplicationHomeSubCluster() - Constructor for class org.apache.hadoop.yarn.server.federation.store.records.ApplicationHomeSubCluster

ApplicationHomeSubClusterPBImpl - Class in org.apache.hadoop.yarn.server.federation.store.records.impl.pb

Protocol buffer based implementation of ApplicationHomeSubCluster.

ApplicationHomeSubClusterPBImpl() - Constructor for class org.apache.hadoop.yarn.server.federation.store.records.impl.pb.ApplicationHomeSubClusterPBImpl

ApplicationHomeSubClusterPBImpl(YarnServerFederationProtos.ApplicationHomeSubClusterProto) - Constructor for class org.apache.hadoop.yarn.server.federation.store.records.impl.pb.ApplicationHomeSubClusterPBImpl

ApplicationIdComparator() - Constructor for class org.apache.hadoop.yarn.server.utils.BuilderUtils.ApplicationIdComparator

ApplicationMetricsConstants - Class in org.apache.hadoop.yarn.server.metrics

ApplicationMetricsConstants() - Constructor for class org.apache.hadoop.yarn.server.metrics.ApplicationMetricsConstants

applicationTags - Variable in class org.apache.hadoop.yarn.server.webapp.dao.AppInfo

appReports - Variable in class org.apache.hadoop.yarn.server.webapp.AppsBlock

AppsBlock - Class in org.apache.hadoop.yarn.server.webapp

AppsBlock(ApplicationBaseProtocol, View.ViewContext) - Constructor for class org.apache.hadoop.yarn.server.webapp.AppsBlock

AppsInfo - Class in org.apache.hadoop.yarn.server.webapp.dao

AppsInfo() - Constructor for class org.apache.hadoop.yarn.server.webapp.dao.AppsInfo

appsTableInit() - Static method in class org.apache.hadoop.yarn.server.webapp.WebPageUtils

appsTableInit(boolean) - Static method in class org.apache.hadoop.yarn.server.webapp.WebPageUtils

appsTableInit(boolean, boolean) - Static method in class org.apache.hadoop.yarn.server.webapp.WebPageUtils

appState - Variable in class org.apache.hadoop.yarn.server.webapp.dao.AppInfo

assignedNodeId - Variable in class org.apache.hadoop.yarn.server.webapp.dao.ContainerInfo

AsyncAllocateRequestInfo(AllocateRequest, AsyncCallback<AllocateResponse>) - Constructor for class org.apache.hadoop.yarn.server.uam.UnmanagedApplicationManager.AsyncAllocateRequestInfo

attempt - Variable in class org.apache.hadoop.yarn.server.webapp.dao.AppAttemptsInfo

attemptsTableInit() - Static method in class org.apache.hadoop.yarn.server.webapp.WebPageUtils

authorizeRequest() - Static method in class org.apache.hadoop.yarn.server.utils.YarnServerSecurityUtils

Authorizes the current request and returns the AMRMTokenIdentifier for the current application.

B

BaseContainerTokenSecretManager - Class in org.apache.hadoop.yarn.server.security

SecretManager for ContainerTokens.

BaseContainerTokenSecretManager(Configuration) - Constructor for class org.apache.hadoop.yarn.server.security.BaseContainerTokenSecretManager

BaseNMTokenSecretManager - Class in org.apache.hadoop.yarn.server.security

BaseNMTokenSecretManager() - Constructor for class org.apache.hadoop.yarn.server.security.BaseNMTokenSecretManager

BroadcastAMRMProxyPolicy - Class in org.apache.hadoop.yarn.server.federation.policies.amrmproxy

An implementation of the FederationAMRMProxyPolicy that simply broadcasts each ResourceRequest to all the available sub-clusters.

BroadcastAMRMProxyPolicy() - Constructor for class org.apache.hadoop.yarn.server.federation.policies.amrmproxy.BroadcastAMRMProxyPolicy

buildCacheKey(String, String, String) - Method in class org.apache.hadoop.yarn.server.federation.utils.FederationStateStoreFacade

BuilderUtils - Class in org.apache.hadoop.yarn.server.utils

Builder utilities to construct various objects.

BuilderUtils() - Constructor for class org.apache.hadoop.yarn.server.utils.BuilderUtils

BuilderUtils.ApplicationIdComparator - Class in org.apache.hadoop.yarn.server.utils

BuilderUtils.ContainerIdComparator - Class in org.apache.hadoop.yarn.server.utils

C

callerUGI - Variable in class org.apache.hadoop.yarn.server.webapp.AppsBlock

canUpload(SCMUploaderCanUploadRequest) - Method in class org.apache.hadoop.yarn.server.api.impl.pb.client.SCMUploaderProtocolPBClientImpl

canUpload(RpcController, YarnServerCommonServiceProtos.SCMUploaderCanUploadRequestProto) - Method in class org.apache.hadoop.yarn.server.api.impl.pb.service.SCMUploaderProtocolPBServiceImpl

canUpload(SCMUploaderCanUploadRequest) - Method in interface org.apache.hadoop.yarn.server.api.SCMUploaderProtocol

The method used by the NodeManager's SharedCacheUploadService to request whether a resource can be uploaded.

checkAllowedProtocols(Class<?>) - Method in class org.apache.hadoop.yarn.server.api.ServerRMProxy

checkSubClusterId(SubClusterId) - Static method in class org.apache.hadoop.yarn.server.federation.store.utils.FederationMembershipStateStoreInputValidator

Validate if the SubCluster Id is present or not.

checkSubClusterInfo(SubClusterInfo) - Static method in class org.apache.hadoop.yarn.server.federation.store.utils.FederationMembershipStateStoreInputValidator

Validate if all the required fields on SubClusterInfo are present or not.

cleanAllApplications() - Method in class org.apache.hadoop.yarn.server.federation.utils.FederationRegistryClient

For testing, delete all application records in registry.

close() - Method in class org.apache.hadoop.yarn.server.api.impl.pb.client.CollectorNodemanagerProtocolPBClientImpl

close() - Method in class org.apache.hadoop.yarn.server.api.impl.pb.client.DistributedSchedulingAMProtocolPBClientImpl

close() - Method in class org.apache.hadoop.yarn.server.api.impl.pb.client.ResourceTrackerPBClientImpl

close() - Method in class org.apache.hadoop.yarn.server.api.impl.pb.client.SCMUploaderProtocolPBClientImpl

close() - Method in class org.apache.hadoop.yarn.server.federation.failover.FederationRMFailoverProxyProvider

Close all the proxy objects which have been opened over the lifetime of this proxy provider.

close() - Method in interface org.apache.hadoop.yarn.server.federation.store.FederationStateStore

Perform any cleanup operations of the StateStore.

close() - Method in class org.apache.hadoop.yarn.server.federation.store.impl.MemoryFederationStateStore

close() - Method in class org.apache.hadoop.yarn.server.federation.store.impl.SQLFederationStateStore

close() - Method in class org.apache.hadoop.yarn.server.federation.store.impl.ZookeeperFederationStateStore

close() - Method in class org.apache.hadoop.yarn.server.utils.LeveldbIterator

Closes the iterator.

CollectorNodemanagerProtocol - Interface in org.apache.hadoop.yarn.server.api

The protocol between an TimelineCollectorManager and a NodeManager to report a new application collector get launched.

CollectorNodemanagerProtocolPB - Interface in org.apache.hadoop.yarn.server.api

CollectorNodemanagerProtocolPBClientImpl - Class in org.apache.hadoop.yarn.server.api.impl.pb.client

CollectorNodemanagerProtocolPBClientImpl(long, InetSocketAddress, Configuration) - Constructor for class org.apache.hadoop.yarn.server.api.impl.pb.client.CollectorNodemanagerProtocolPBClientImpl

CollectorNodemanagerProtocolPBServiceImpl - Class in org.apache.hadoop.yarn.server.api.impl.pb.service

CollectorNodemanagerProtocolPBServiceImpl(CollectorNodemanagerProtocol) - Constructor for class org.apache.hadoop.yarn.server.api.impl.pb.service.CollectorNodemanagerProtocolPBServiceImpl

compare(ApplicationId, ApplicationId) - Method in class org.apache.hadoop.yarn.server.utils.BuilderUtils.ApplicationIdComparator

compare(ContainerId, ContainerId) - Method in class org.apache.hadoop.yarn.server.utils.BuilderUtils.ContainerIdComparator

compareTo(RemoteNode) - Method in class org.apache.hadoop.yarn.server.api.protocolrecords.RemoteNode

Use the underlying NodeId comparator.

compareTo(SubClusterId) - Method in class org.apache.hadoop.yarn.server.federation.store.records.SubClusterId

compareTo(SchedulerRequestKey) - Method in class org.apache.hadoop.yarn.server.scheduler.SchedulerRequestKey

computeIntegerAssignment(int, ArrayList<Float>) - Method in class org.apache.hadoop.yarn.server.federation.policies.amrmproxy.LocalityMulticastAMRMProxyPolicy

Split the integer into bins according to the weights.

conf - Variable in class org.apache.hadoop.yarn.server.webapp.AppBlock

ConfigurableFederationPolicy - Interface in org.apache.hadoop.yarn.server.federation.policies

This interface provides a general method to reinitialize a policy.

container - Variable in class org.apache.hadoop.yarn.server.webapp.dao.ContainersInfo

CONTAINER_FINISHED_TIME - Static variable in class org.apache.hadoop.yarn.server.metrics.ContainerMetricsConstants

CONTAINER_ID - Static variable in interface org.apache.hadoop.yarn.server.webapp.YarnWebServiceParams

CONTAINER_LOG_FILE_NAME - Static variable in interface org.apache.hadoop.yarn.server.webapp.YarnWebServiceParams

ContainerBlock - Class in org.apache.hadoop.yarn.server.webapp

ContainerBlock(ApplicationBaseProtocol, View.ViewContext) - Constructor for class org.apache.hadoop.yarn.server.webapp.ContainerBlock

containerExitStatus - Variable in class org.apache.hadoop.yarn.server.webapp.dao.ContainerInfo

containerId - Variable in class org.apache.hadoop.yarn.server.webapp.dao.ContainerInfo

containerId - Variable in class org.apache.hadoop.yarn.server.webapp.dao.ContainerLogsInfo

ContainerIdComparator() - Constructor for class org.apache.hadoop.yarn.server.utils.BuilderUtils.ContainerIdComparator

containerIdCounter - Variable in class org.apache.hadoop.yarn.server.scheduler.OpportunisticContainerAllocator.ContainerIdGenerator

ContainerIdGenerator() - Constructor for class org.apache.hadoop.yarn.server.scheduler.OpportunisticContainerAllocator.ContainerIdGenerator

ContainerInfo - Class in org.apache.hadoop.yarn.server.webapp.dao

ContainerInfo() - Constructor for class org.apache.hadoop.yarn.server.webapp.dao.ContainerInfo

ContainerInfo(ContainerReport) - Constructor for class org.apache.hadoop.yarn.server.webapp.dao.ContainerInfo

ContainerLogsInfo - Class in org.apache.hadoop.yarn.server.webapp.dao

ContainerLogsInfo includes the log meta-data of containers.

ContainerLogsInfo() - Constructor for class org.apache.hadoop.yarn.server.webapp.dao.ContainerLogsInfo

ContainerLogsInfo(ContainerLogMeta, ContainerLogAggregationType) - Constructor for class org.apache.hadoop.yarn.server.webapp.dao.ContainerLogsInfo

containerLogsInfo - Variable in class org.apache.hadoop.yarn.server.webapp.dao.ContainerLogsInfo

ContainerMetricsConstants - Class in org.apache.hadoop.yarn.server.metrics

ContainerMetricsConstants() - Constructor for class org.apache.hadoop.yarn.server.metrics.ContainerMetricsConstants

ContainerQueuingLimit - Class in org.apache.hadoop.yarn.server.api.records

Used to hold max wait time / queue length information to be passed back to the NodeManager.

ContainerQueuingLimit() - Constructor for class org.apache.hadoop.yarn.server.api.records.ContainerQueuingLimit

ContainerQueuingLimitPBImpl - Class in org.apache.hadoop.yarn.server.api.records.impl.pb

Implementation of ContainerQueuingLimit interface.

ContainerQueuingLimitPBImpl() - Constructor for class org.apache.hadoop.yarn.server.api.records.impl.pb.ContainerQueuingLimitPBImpl

ContainerQueuingLimitPBImpl(YarnServerCommonServiceProtos.ContainerQueuingLimitProto) - Constructor for class org.apache.hadoop.yarn.server.api.records.impl.pb.ContainerQueuingLimitPBImpl

ContainersInfo - Class in org.apache.hadoop.yarn.server.webapp.dao

ContainersInfo() - Constructor for class org.apache.hadoop.yarn.server.webapp.dao.ContainersInfo

containersTableInit() - Static method in class org.apache.hadoop.yarn.server.webapp.WebPageUtils

containerState - Variable in class org.apache.hadoop.yarn.server.webapp.dao.ContainerInfo

containerTokenExpiryInterval - Variable in class org.apache.hadoop.yarn.server.security.BaseContainerTokenSecretManager

convert(long, CharSequence) - Static method in class org.apache.hadoop.yarn.server.utils.BuilderUtils

create(ResourceRequest) - Static method in class org.apache.hadoop.yarn.server.scheduler.SchedulerRequestKey

Factory method to generate a SchedulerRequestKey from a ResourceRequest.

create(SchedulingRequest) - Static method in class org.apache.hadoop.yarn.server.scheduler.SchedulerRequestKey

Factory method to generate a SchedulerRequestKey from a SchedulingRequest.

create(UpdateContainerRequest, SchedulerRequestKey) - Static method in class org.apache.hadoop.yarn.server.scheduler.SchedulerRequestKey

createAndRegisterNewUAM(RegisterApplicationMasterRequest, Configuration, String, String, String, boolean) - Method in class org.apache.hadoop.yarn.server.uam.UnmanagedAMPoolManager

Create a new UAM and register the application, without specifying uamId and appId.

createApplicationMetricsTable(HtmlBlock.Block) - Method in class org.apache.hadoop.yarn.server.webapp.AppBlock

createAttemptHeadRoomTable(HtmlBlock.Block) - Method in class org.apache.hadoop.yarn.server.webapp.AppAttemptBlock

CREATED_EVENT_TYPE - Static variable in class org.apache.hadoop.yarn.server.metrics.ApplicationMetricsConstants

CREATED_EVENT_TYPE - Static variable in class org.apache.hadoop.yarn.server.metrics.ContainerMetricsConstants

CREATED_IN_RM_EVENT_TYPE - Static variable in class org.apache.hadoop.yarn.server.metrics.ContainerMetricsConstants

createFilterConfig(Configuration) - Method in class org.apache.hadoop.yarn.server.security.http.RMAuthenticationFilterInitializer

createIdentifier() - Method in class org.apache.hadoop.yarn.server.security.BaseContainerTokenSecretManager

Used by the RPC layer.

createIdentifier() - Method in class org.apache.hadoop.yarn.server.security.BaseNMTokenSecretManager

It is required for RPC

createInstance(Configuration, String, String, Class<T>) - Static method in class org.apache.hadoop.yarn.server.federation.utils.FederationStateStoreFacade

Helper method to create instances of Object using the class name specified in the configuration object.

createNewMasterKey() - Method in class org.apache.hadoop.yarn.server.security.BaseContainerTokenSecretManager

createNewMasterKey() - Method in class org.apache.hadoop.yarn.server.security.BaseNMTokenSecretManager

createNMToken(ApplicationAttemptId, NodeId, String) - Method in class org.apache.hadoop.yarn.server.security.BaseNMTokenSecretManager

Helper function for creating NMTokens.

createPassword(ContainerTokenIdentifier) - Method in class org.apache.hadoop.yarn.server.security.BaseContainerTokenSecretManager

createPassword(NMTokenIdentifier) - Method in class org.apache.hadoop.yarn.server.security.BaseNMTokenSecretManager

createRetryInstance(Configuration, String, String, Class<T>, RetryPolicy) - Static method in class org.apache.hadoop.yarn.server.federation.utils.FederationStateStoreFacade

Helper method to create instances of Object using the class name defined in the configuration object.

createRetryPolicy(Configuration) - Static method in class org.apache.hadoop.yarn.server.federation.utils.FederationStateStoreFacade

Create a RetryPolicy for FederationStateStoreFacade.

createRMProxy(Configuration, Class<T>) - Static method in class org.apache.hadoop.yarn.server.api.ServerRMProxy

Create a proxy to the ResourceManager for the specified protocol.

createRMProxy(Configuration, Class<T>, SubClusterId, UserGroupInformation) - Static method in class org.apache.hadoop.yarn.server.federation.failover.FederationProxyProviderUtil

Create a proxy for the specified protocol in the context of Federation.

createRMProxy(Configuration, Class<T>, SubClusterId, UserGroupInformation, Token<? extends TokenIdentifier>) - Static method in class org.apache.hadoop.yarn.server.federation.failover.FederationProxyProviderUtil

Create a proxy for the specified protocol in the context of Federation.

createRMProxy(InetSocketAddress) - Method in class org.apache.hadoop.yarn.server.federation.failover.FederationRMFailoverProxyProvider

createRMProxy(Class<T>, Configuration, UserGroupInformation, Token<AMRMTokenIdentifier>) - Method in class org.apache.hadoop.yarn.server.uam.UnmanagedApplicationManager

Returns RM proxy for the specified protocol type.

createRMProxy(Configuration, Class<T>, UserGroupInformation, Token<? extends TokenIdentifier>) - Static method in class org.apache.hadoop.yarn.server.utils.AMRMClientUtils

Create a proxy for the specified protocol.

createTablesForAttemptMetrics(HtmlBlock.Block) - Method in class org.apache.hadoop.yarn.server.webapp.AppAttemptBlock

createTimelineDelegationTokenSecretManager(long, long, long, long) - Method in class org.apache.hadoop.yarn.server.timeline.security.TimelineDelgationTokenSecretManagerService

createUAM(Configuration, ApplicationId, String, String, String, boolean) - Method in class org.apache.hadoop.yarn.server.uam.UnmanagedAMPoolManager

Creates the UAM instance.

createUAMProxy(Token<AMRMTokenIdentifier>) - Method in class org.apache.hadoop.yarn.server.uam.UnmanagedApplicationManager

currentAppAttemptId - Variable in class org.apache.hadoop.yarn.server.webapp.dao.AppInfo

currentMasterKey - Variable in class org.apache.hadoop.yarn.server.security.BaseContainerTokenSecretManager

THE masterKey.

currentMasterKey - Variable in class org.apache.hadoop.yarn.server.security.BaseNMTokenSecretManager

D

DEFAULT_TIMESTAMP_VALUE - Static variable in class org.apache.hadoop.yarn.server.api.records.AppCollectorData

DefaultSubClusterResolverImpl - Class in org.apache.hadoop.yarn.server.federation.resolver

Default simple sub-cluster and rack resolver class.

DefaultSubClusterResolverImpl() - Constructor for class org.apache.hadoop.yarn.server.federation.resolver.DefaultSubClusterResolverImpl

deleteApplicationHomeSubCluster(DeleteApplicationHomeSubClusterRequest) - Method in interface org.apache.hadoop.yarn.server.federation.store.FederationApplicationHomeSubClusterStore

Delete the mapping of home SubClusterId of a previously submitted ApplicationId.

deleteApplicationHomeSubCluster(DeleteApplicationHomeSubClusterRequest) - Method in class org.apache.hadoop.yarn.server.federation.store.impl.MemoryFederationStateStore

deleteApplicationHomeSubCluster(DeleteApplicationHomeSubClusterRequest) - Method in class org.apache.hadoop.yarn.server.federation.store.impl.SQLFederationStateStore

deleteApplicationHomeSubCluster(DeleteApplicationHomeSubClusterRequest) - Method in class org.apache.hadoop.yarn.server.federation.store.impl.ZookeeperFederationStateStore

DeleteApplicationHomeSubClusterRequest - Class in org.apache.hadoop.yarn.server.federation.store.records

The request to Federation state store to delete the mapping of home subcluster of a submitted application.

DeleteApplicationHomeSubClusterRequest() - Constructor for class org.apache.hadoop.yarn.server.federation.store.records.DeleteApplicationHomeSubClusterRequest

DeleteApplicationHomeSubClusterRequestPBImpl - Class in org.apache.hadoop.yarn.server.federation.store.records.impl.pb

Protocol buffer based implementation of DeleteApplicationHomeSubClusterRequest.

DeleteApplicationHomeSubClusterRequestPBImpl() - Constructor for class org.apache.hadoop.yarn.server.federation.store.records.impl.pb.DeleteApplicationHomeSubClusterRequestPBImpl

DeleteApplicationHomeSubClusterRequestPBImpl(YarnServerFederationProtos.DeleteApplicationHomeSubClusterRequestProto) - Constructor for class org.apache.hadoop.yarn.server.federation.store.records.impl.pb.DeleteApplicationHomeSubClusterRequestPBImpl

DeleteApplicationHomeSubClusterResponse - Class in org.apache.hadoop.yarn.server.federation.store.records

DeleteApplicationHomeSubClusterResponse contains the answer from the FederationApplicationHomeSubClusterStore to a request to delete the mapping of home subcluster of a submitted application.

DeleteApplicationHomeSubClusterResponse() - Constructor for class org.apache.hadoop.yarn.server.federation.store.records.DeleteApplicationHomeSubClusterResponse

DeleteApplicationHomeSubClusterResponsePBImpl - Class in org.apache.hadoop.yarn.server.federation.store.records.impl.pb

Protocol buffer based implementation of DeleteApplicationHomeSubClusterResponse.

DeleteApplicationHomeSubClusterResponsePBImpl() - Constructor for class org.apache.hadoop.yarn.server.federation.store.records.impl.pb.DeleteApplicationHomeSubClusterResponsePBImpl

DeleteApplicationHomeSubClusterResponsePBImpl(YarnServerFederationProtos.DeleteApplicationHomeSubClusterResponseProto) - Constructor for class org.apache.hadoop.yarn.server.federation.store.records.impl.pb.DeleteApplicationHomeSubClusterResponsePBImpl

deregisterSubCluster(SubClusterDeregisterRequest) - Method in interface org.apache.hadoop.yarn.server.federation.store.FederationMembershipStateStore

Deregister a subcluster identified by SubClusterId to change state in federation.

deregisterSubCluster(SubClusterDeregisterRequest) - Method in class org.apache.hadoop.yarn.server.federation.store.impl.MemoryFederationStateStore

deregisterSubCluster(SubClusterDeregisterRequest) - Method in class org.apache.hadoop.yarn.server.federation.store.impl.SQLFederationStateStore

deregisterSubCluster(SubClusterDeregisterRequest) - Method in class org.apache.hadoop.yarn.server.federation.store.impl.ZookeeperFederationStateStore

DIAGNOSTICS_INFO - Static variable in class org.apache.hadoop.yarn.server.metrics.AppAttemptMetricsConstants

DIAGNOSTICS_INFO - Static variable in class org.apache.hadoop.yarn.server.metrics.ContainerMetricsConstants

DIAGNOSTICS_INFO_EVENT_INFO - Static variable in class org.apache.hadoop.yarn.server.metrics.ApplicationMetricsConstants

diagnosticsInfo - Variable in class org.apache.hadoop.yarn.server.webapp.dao.AppAttemptInfo

diagnosticsInfo - Variable in class org.apache.hadoop.yarn.server.webapp.dao.AppInfo

diagnosticsInfo - Variable in class org.apache.hadoop.yarn.server.webapp.dao.ContainerInfo

DistributedSchedulingAllocateRequest - Class in org.apache.hadoop.yarn.server.api.protocolrecords

Object used by the Application Master when distributed scheduling is enabled, in order to forward the AllocateRequest for GUARANTEED containers to the Resource Manager, and to notify the Resource Manager about the allocation of OPPORTUNISTIC containers through the Distributed Scheduler.

DistributedSchedulingAllocateRequest() - Constructor for class org.apache.hadoop.yarn.server.api.protocolrecords.DistributedSchedulingAllocateRequest

DistributedSchedulingAllocateRequestPBImpl - Class in org.apache.hadoop.yarn.server.api.protocolrecords.impl.pb

Implementation of DistributedSchedulingAllocateRequest.

DistributedSchedulingAllocateRequestPBImpl() - Constructor for class org.apache.hadoop.yarn.server.api.protocolrecords.impl.pb.DistributedSchedulingAllocateRequestPBImpl

DistributedSchedulingAllocateRequestPBImpl(YarnServerCommonServiceProtos.DistributedSchedulingAllocateRequestProto) - Constructor for class org.apache.hadoop.yarn.server.api.protocolrecords.impl.pb.DistributedSchedulingAllocateRequestPBImpl

DistributedSchedulingAllocateResponse - Class in org.apache.hadoop.yarn.server.api.protocolrecords

This is the response of the Resource Manager to the DistributedSchedulingAllocateRequest, when distributed scheduling is enabled.

DistributedSchedulingAllocateResponse() - Constructor for class org.apache.hadoop.yarn.server.api.protocolrecords.DistributedSchedulingAllocateResponse

DistributedSchedulingAllocateResponsePBImpl - Class in org.apache.hadoop.yarn.server.api.protocolrecords.impl.pb

Implementation of DistributedSchedulingAllocateResponse.

DistributedSchedulingAllocateResponsePBImpl() - Constructor for class org.apache.hadoop.yarn.server.api.protocolrecords.impl.pb.DistributedSchedulingAllocateResponsePBImpl

DistributedSchedulingAllocateResponsePBImpl(YarnServerCommonServiceProtos.DistributedSchedulingAllocateResponseProto) - Constructor for class org.apache.hadoop.yarn.server.api.protocolrecords.impl.pb.DistributedSchedulingAllocateResponsePBImpl

DistributedSchedulingAMProtocol - Interface in org.apache.hadoop.yarn.server.api

This protocol extends the ApplicationMasterProtocol.

DistributedSchedulingAMProtocolPB - Interface in org.apache.hadoop.yarn.server.api

DistributedSchedulingAMProtocolPBClientImpl - Class in org.apache.hadoop.yarn.server.api.impl.pb.client

Implementation of DistributedSchedulingAMProtocol, used when distributed scheduling is enabled.

DistributedSchedulingAMProtocolPBClientImpl(long, InetSocketAddress, Configuration) - Constructor for class org.apache.hadoop.yarn.server.api.impl.pb.client.DistributedSchedulingAMProtocolPBClientImpl

DistributedSchedulingAMProtocolPBServiceImpl - Class in org.apache.hadoop.yarn.server.api.impl.pb.service

Implementation of DistributedSchedulingAMProtocolPB.

DistributedSchedulingAMProtocolPBServiceImpl(DistributedSchedulingAMProtocol) - Constructor for class org.apache.hadoop.yarn.server.api.impl.pb.service.DistributedSchedulingAMProtocolPBServiceImpl

doFilter(ServletRequest, ServletResponse, FilterChain) - Method in class org.apache.hadoop.yarn.server.security.http.RMAuthenticationFilter

E

elapsedTime - Variable in class org.apache.hadoop.yarn.server.webapp.dao.AppInfo

elapsedTime - Variable in class org.apache.hadoop.yarn.server.webapp.dao.ContainerInfo

ENTITY_TYPE - Static variable in class org.apache.hadoop.yarn.server.metrics.AppAttemptMetricsConstants

ENTITY_TYPE - Static variable in class org.apache.hadoop.yarn.server.metrics.ApplicationMetricsConstants

ENTITY_TYPE - Static variable in class org.apache.hadoop.yarn.server.metrics.ContainerMetricsConstants

equals(Object) - Method in class org.apache.hadoop.yarn.server.api.protocolrecords.impl.pb.GetTimelineCollectorContextRequestPBImpl

equals(Object) - Method in class org.apache.hadoop.yarn.server.api.protocolrecords.impl.pb.GetTimelineCollectorContextResponsePBImpl

equals(Object) - Method in class org.apache.hadoop.yarn.server.api.protocolrecords.impl.pb.LogAggregationReportPBImpl

equals(Object) - Method in class org.apache.hadoop.yarn.server.api.protocolrecords.impl.pb.NMContainerStatusPBImpl

equals(Object) - Method in class org.apache.hadoop.yarn.server.api.protocolrecords.impl.pb.NodeHeartbeatRequestPBImpl

equals(Object) - Method in class org.apache.hadoop.yarn.server.api.protocolrecords.impl.pb.RegisterNodeManagerRequestPBImpl

equals(Object) - Method in class org.apache.hadoop.yarn.server.api.protocolrecords.impl.pb.RemoteNodePBImpl

equals(Object) - Method in class org.apache.hadoop.yarn.server.api.protocolrecords.impl.pb.ReportNewCollectorInfoRequestPBImpl

equals(Object) - Method in class org.apache.hadoop.yarn.server.api.protocolrecords.impl.pb.ReportNewCollectorInfoResponsePBImpl

equals(Object) - Method in class org.apache.hadoop.yarn.server.api.records.impl.pb.AppCollectorDataPBImpl

equals(Object) - Method in class org.apache.hadoop.yarn.server.api.records.impl.pb.MasterKeyPBImpl

equals(Object) - Method in class org.apache.hadoop.yarn.server.api.records.impl.pb.NodeHealthStatusPBImpl

equals(Object) - Method in class org.apache.hadoop.yarn.server.api.records.impl.pb.NodeStatusPBImpl

equals(Object) - Method in class org.apache.hadoop.yarn.server.federation.policies.dao.WeightedPolicyInfo

equals(Object) - Method in class org.apache.hadoop.yarn.server.federation.store.records.ApplicationHomeSubCluster

equals(Object) - Method in class org.apache.hadoop.yarn.server.federation.store.records.impl.pb.AddApplicationHomeSubClusterRequestPBImpl

equals(Object) - Method in class org.apache.hadoop.yarn.server.federation.store.records.impl.pb.AddApplicationHomeSubClusterResponsePBImpl

equals(Object) - Method in class org.apache.hadoop.yarn.server.federation.store.records.impl.pb.ApplicationHomeSubClusterPBImpl

equals(Object) - Method in class org.apache.hadoop.yarn.server.federation.store.records.impl.pb.DeleteApplicationHomeSubClusterRequestPBImpl

equals(Object) - Method in class org.apache.hadoop.yarn.server.federation.store.records.impl.pb.DeleteApplicationHomeSubClusterResponsePBImpl

equals(Object) - Method in class org.apache.hadoop.yarn.server.federation.store.records.impl.pb.GetApplicationHomeSubClusterRequestPBImpl

equals(Object) - Method in class org.apache.hadoop.yarn.server.federation.store.records.impl.pb.GetApplicationHomeSubClusterResponsePBImpl

equals(Object) - Method in class org.apache.hadoop.yarn.server.federation.store.records.impl.pb.GetApplicationsHomeSubClusterRequestPBImpl

equals(Object) - Method in class org.apache.hadoop.yarn.server.federation.store.records.impl.pb.GetApplicationsHomeSubClusterResponsePBImpl

equals(Object) - Method in class org.apache.hadoop.yarn.server.federation.store.records.impl.pb.GetSubClusterInfoRequestPBImpl

equals(Object) - Method in class org.apache.hadoop.yarn.server.federation.store.records.impl.pb.GetSubClusterInfoResponsePBImpl

equals(Object) - Method in class org.apache.hadoop.yarn.server.federation.store.records.impl.pb.GetSubClusterPoliciesConfigurationsRequestPBImpl

equals(Object) - Method in class org.apache.hadoop.yarn.server.federation.store.records.impl.pb.GetSubClusterPoliciesConfigurationsResponsePBImpl

equals(Object) - Method in class org.apache.hadoop.yarn.server.federation.store.records.impl.pb.GetSubClusterPolicyConfigurationRequestPBImpl

equals(Object) - Method in class org.apache.hadoop.yarn.server.federation.store.records.impl.pb.GetSubClusterPolicyConfigurationResponsePBImpl

equals(Object) - Method in class org.apache.hadoop.yarn.server.federation.store.records.impl.pb.GetSubClustersInfoRequestPBImpl

equals(Object) - Method in class org.apache.hadoop.yarn.server.federation.store.records.impl.pb.GetSubClustersInfoResponsePBImpl

equals(Object) - Method in class org.apache.hadoop.yarn.server.federation.store.records.impl.pb.SetSubClusterPolicyConfigurationRequestPBImpl

equals(Object) - Method in class org.apache.hadoop.yarn.server.federation.store.records.impl.pb.SetSubClusterPolicyConfigurationResponsePBImpl

equals(Object) - Method in class org.apache.hadoop.yarn.server.federation.store.records.impl.pb.SubClusterDeregisterRequestPBImpl

equals(Object) - Method in class org.apache.hadoop.yarn.server.federation.store.records.impl.pb.SubClusterDeregisterResponsePBImpl

equals(Object) - Method in class org.apache.hadoop.yarn.server.federation.store.records.impl.pb.SubClusterHeartbeatRequestPBImpl

equals(Object) - Method in class org.apache.hadoop.yarn.server.federation.store.records.impl.pb.SubClusterHeartbeatResponsePBImpl

equals(Object) - Method in class org.apache.hadoop.yarn.server.federation.store.records.impl.pb.SubClusterPolicyConfigurationPBImpl

equals(Object) - Method in class org.apache.hadoop.yarn.server.federation.store.records.impl.pb.SubClusterRegisterRequestPBImpl

equals(Object) - Method in class org.apache.hadoop.yarn.server.federation.store.records.impl.pb.SubClusterRegisterResponsePBImpl

equals(Object) - Method in class org.apache.hadoop.yarn.server.federation.store.records.impl.pb.UpdateApplicationHomeSubClusterRequestPBImpl

equals(Object) - Method in class org.apache.hadoop.yarn.server.federation.store.records.impl.pb.UpdateApplicationHomeSubClusterResponsePBImpl

equals(Object) - Method in class org.apache.hadoop.yarn.server.federation.store.records.SubClusterId

equals(Object) - Method in class org.apache.hadoop.yarn.server.federation.store.records.SubClusterIdInfo

equals(Object) - Method in class org.apache.hadoop.yarn.server.federation.store.records.SubClusterInfo

equals(Object) - Method in class org.apache.hadoop.yarn.server.federation.store.records.SubClusterPolicyConfiguration

equals(Object) - Method in class org.apache.hadoop.yarn.server.records.Version

equals(Object) - Method in class org.apache.hadoop.yarn.server.scheduler.SchedulerRequestKey

ErrorsAndWarningsBlock - Class in org.apache.hadoop.yarn.server.webapp

ErrorsAndWarningsBlock.ErrorMetrics - Class in org.apache.hadoop.yarn.server.webapp

ErrorsAndWarningsBlock.MetricsBase - Class in org.apache.hadoop.yarn.server.webapp

ErrorsAndWarningsBlock.WarningMetrics - Class in org.apache.hadoop.yarn.server.webapp

EXIT_STATUS_INFO - Static variable in class org.apache.hadoop.yarn.server.metrics.ContainerMetricsConstants

extractFrom(Container) - Static method in class org.apache.hadoop.yarn.server.scheduler.SchedulerRequestKey

Convenience method to extract the SchedulerRequestKey used to schedule the Container.

F

failedStateStoreCall() - Static method in class org.apache.hadoop.yarn.server.federation.store.metrics.FederationStateStoreClientMetrics

FEDERATION_STORE_URL - Static variable in class org.apache.hadoop.yarn.server.federation.store.utils.FederationStateStoreUtils

FederationAMRMProxyPolicy - Interface in org.apache.hadoop.yarn.server.federation.policies.amrmproxy

Implementors of this interface provide logic to split the list of ResourceRequests received by the AM among various RMs.

FederationApplicationHomeSubClusterStore - Interface in org.apache.hadoop.yarn.server.federation.store

FederationApplicationHomeSubClusterStore maintains the state of all Applications that have been submitted to the federated cluster.

FederationApplicationHomeSubClusterStoreInputValidator - Class in org.apache.hadoop.yarn.server.federation.store.utils

Utility class to validate the inputs to FederationApplicationHomeSubClusterStore, allows a fail fast mechanism for invalid user inputs.

FederationMembershipStateStore - Interface in org.apache.hadoop.yarn.server.federation.store

FederationMembershipStateStore maintains the state of all subcluster(s) as encapsulated by SubClusterInfo for all the subcluster(s) that are participating in federation.

FederationMembershipStateStoreInputValidator - Class in org.apache.hadoop.yarn.server.federation.store.utils

Utility class to validate the inputs to FederationMembershipStateStore, allows a fail fast mechanism for invalid user inputs.

FederationPolicyException - Exception in org.apache.hadoop.yarn.server.federation.policies.exceptions

Generic policy exception.

FederationPolicyException(String) - Constructor for exception org.apache.hadoop.yarn.server.federation.policies.exceptions.FederationPolicyException

FederationPolicyException(Throwable) - Constructor for exception org.apache.hadoop.yarn.server.federation.policies.exceptions.FederationPolicyException

FederationPolicyInitializationContext - Class in org.apache.hadoop.yarn.server.federation.policies

Context to (re)initialize a FederationAMRMProxyPolicy and FederationRouterPolicy.

FederationPolicyInitializationContext() - Constructor for class org.apache.hadoop.yarn.server.federation.policies.FederationPolicyInitializationContext

FederationPolicyInitializationContext(SubClusterPolicyConfiguration, SubClusterResolver, FederationStateStoreFacade, SubClusterId) - Constructor for class org.apache.hadoop.yarn.server.federation.policies.FederationPolicyInitializationContext

FederationPolicyInitializationContextValidator - Class in org.apache.hadoop.yarn.server.federation.policies

Helper class used to factor out common validation steps for policies.

FederationPolicyInitializationException - Exception in org.apache.hadoop.yarn.server.federation.policies.exceptions

This exception is thrown when the initialization of a federation policy is not successful.

FederationPolicyInitializationException(String) - Constructor for exception org.apache.hadoop.yarn.server.federation.policies.exceptions.FederationPolicyInitializationException

FederationPolicyInitializationException(Throwable) - Constructor for exception org.apache.hadoop.yarn.server.federation.policies.exceptions.FederationPolicyInitializationException

FederationPolicyManager - Interface in org.apache.hadoop.yarn.server.federation.policies.manager

Implementors need to provide the ability to serliaze a policy and its configuration as a SubClusterPolicyConfiguration, as well as provide (re)initialization mechanics for the underlying FederationAMRMProxyPolicy and FederationRouterPolicy.

FederationPolicyStore - Interface in org.apache.hadoop.yarn.server.federation.store

The FederationPolicyStore provides a key-value interface to access the policies configured for the system.

FederationPolicyStoreInputValidator - Class in org.apache.hadoop.yarn.server.federation.store.utils

Utility class to validate the inputs to FederationPolicyStore, allows a fail fast mechanism for invalid user inputs.

FederationPolicyUtils - Class in org.apache.hadoop.yarn.server.federation.policies

Utility class for Federation policy.

FederationProxyProviderUtil - Class in org.apache.hadoop.yarn.server.federation.failover

Utility class that creates proxy for specified protocols when federation is enabled.

FederationRegistryClient - Class in org.apache.hadoop.yarn.server.federation.utils

Helper class that handles reads and writes to Yarn Registry to support UAM HA and second attempt.

FederationRegistryClient(Configuration, RegistryOperations, UserGroupInformation) - Constructor for class org.apache.hadoop.yarn.server.federation.utils.FederationRegistryClient

FederationRMFailoverProxyProvider<T> - Class in org.apache.hadoop.yarn.server.federation.failover

A FailoverProxyProvider implementation that uses the FederationStateStore to determine the ResourceManager to connect to.

FederationRMFailoverProxyProvider() - Constructor for class org.apache.hadoop.yarn.server.federation.failover.FederationRMFailoverProxyProvider

FederationRouterPolicy - Interface in org.apache.hadoop.yarn.server.federation.policies.router

Implements the logic for determining the routing of an application submission based on a policy.

FederationStateStore - Interface in org.apache.hadoop.yarn.server.federation.store

FederationStore extends the three interfaces used to coordinate the state of a federated cluster: FederationApplicationHomeSubClusterStore, FederationMembershipStateStore, and FederationPolicyStore.

FederationStateStoreClientMetrics - Class in org.apache.hadoop.yarn.server.federation.store.metrics

Performance metrics for FederationStateStore implementations.

FederationStateStoreException - Exception in org.apache.hadoop.yarn.server.federation.store.exception

Exception thrown by the FederationStateStore.

FederationStateStoreException() - Constructor for exception org.apache.hadoop.yarn.server.federation.store.exception.FederationStateStoreException

FederationStateStoreException(String) - Constructor for exception org.apache.hadoop.yarn.server.federation.store.exception.FederationStateStoreException

FederationStateStoreException(Throwable) - Constructor for exception org.apache.hadoop.yarn.server.federation.store.exception.FederationStateStoreException

FederationStateStoreException(String, Throwable) - Constructor for exception org.apache.hadoop.yarn.server.federation.store.exception.FederationStateStoreException

FederationStateStoreFacade - Class in org.apache.hadoop.yarn.server.federation.utils

The FederationStateStoreFacade is an utility wrapper that provides singleton access to the Federation state store.

FederationStateStoreFacade.Func<T,TResult> - Interface in org.apache.hadoop.yarn.server.federation.utils

Encapsulates a method that has one parameter and returns a value of the type specified by the TResult parameter.

FederationStateStoreInvalidInputException - Exception in org.apache.hadoop.yarn.server.federation.store.exception

Exception thrown by the FederationMembershipStateStoreInputValidator, FederationApplicationHomeSubClusterStoreInputValidator, FederationPolicyStoreInputValidator if the input is invalid.

FederationStateStoreInvalidInputException(Throwable) - Constructor for exception org.apache.hadoop.yarn.server.federation.store.exception.FederationStateStoreInvalidInputException

FederationStateStoreInvalidInputException(String) - Constructor for exception org.apache.hadoop.yarn.server.federation.store.exception.FederationStateStoreInvalidInputException

FederationStateStoreInvalidInputException(String, Throwable) - Constructor for exception org.apache.hadoop.yarn.server.federation.store.exception.FederationStateStoreInvalidInputException

FederationStateStoreRetriableException - Exception in org.apache.hadoop.yarn.server.federation.store.exception

Exception thrown by the FederationStateStore, if it is a retriable exception.

FederationStateStoreRetriableException(Throwable) - Constructor for exception org.apache.hadoop.yarn.server.federation.store.exception.FederationStateStoreRetriableException

FederationStateStoreRetriableException(String) - Constructor for exception org.apache.hadoop.yarn.server.federation.store.exception.FederationStateStoreRetriableException

FederationStateStoreRetriableException(String, Throwable) - Constructor for exception org.apache.hadoop.yarn.server.federation.store.exception.FederationStateStoreRetriableException

FederationStateStoreUtils - Class in org.apache.hadoop.yarn.server.federation.store.utils

Common utility methods used by the store implementations.

fetchData() - Method in class org.apache.hadoop.yarn.server.webapp.AppsBlock

FINAL_STATUS_EVENT_INFO - Static variable in class org.apache.hadoop.yarn.server.metrics.ApplicationMetricsConstants

FINAL_STATUS_INFO - Static variable in class org.apache.hadoop.yarn.server.metrics.AppAttemptMetricsConstants

finalAppStatus - Variable in class org.apache.hadoop.yarn.server.webapp.dao.AppInfo

finishAMWithReRegister(FinishApplicationMasterRequest, ApplicationMasterProtocol, RegisterApplicationMasterRequest, ApplicationId) - Static method in class org.apache.hadoop.yarn.server.utils.AMRMClientUtils

Helper method for client calling ApplicationMasterProtocol.finishApplicationMaster that handles re-register if RM fails over.

finishApplicationMaster(FinishApplicationMasterRequest) - Method in class org.apache.hadoop.yarn.server.api.impl.pb.client.DistributedSchedulingAMProtocolPBClientImpl

finishApplicationMaster(RpcController, YarnServiceProtos.FinishApplicationMasterRequestProto) - Method in class org.apache.hadoop.yarn.server.api.impl.pb.service.DistributedSchedulingAMProtocolPBServiceImpl

finishApplicationMaster(String, FinishApplicationMasterRequest) - Method in class org.apache.hadoop.yarn.server.uam.UnmanagedAMPoolManager

Finish an UAM/application.

finishApplicationMaster(FinishApplicationMasterRequest) - Method in class org.apache.hadoop.yarn.server.uam.UnmanagedApplicationManager

Unregisters from the resource manager and stops the request handler thread.

FINISHED_EVENT_TYPE - Static variable in class org.apache.hadoop.yarn.server.metrics.AppAttemptMetricsConstants

FINISHED_EVENT_TYPE - Static variable in class org.apache.hadoop.yarn.server.metrics.ApplicationMetricsConstants

FINISHED_EVENT_TYPE - Static variable in class org.apache.hadoop.yarn.server.metrics.ContainerMetricsConstants

FINISHED_IN_RM_EVENT_TYPE - Static variable in class org.apache.hadoop.yarn.server.metrics.ContainerMetricsConstants

finishedTime - Variable in class org.apache.hadoop.yarn.server.webapp.dao.AppAttemptInfo

finishedTime - Variable in class org.apache.hadoop.yarn.server.webapp.dao.AppInfo

finishedTime - Variable in class org.apache.hadoop.yarn.server.webapp.dao.ContainerInfo

forceKillApplication() - Method in class org.apache.hadoop.yarn.server.uam.UnmanagedApplicationManager

Force kill the UAM.

fromByteBuffer(ByteBuffer) - Static method in class org.apache.hadoop.yarn.server.federation.policies.dao.WeightedPolicyInfo

Deserializes a WeightedPolicyInfo from a byte UTF-8 JSON representation.

fromString(String) - Static method in enum org.apache.hadoop.yarn.server.federation.store.records.SubClusterState

Convert a string into SubClusterState.

G

generateApplicationTable(HtmlBlock.Block, UserGroupInformation, Collection<ApplicationAttemptReport>) - Method in class org.apache.hadoop.yarn.server.webapp.AppBlock

generateContainerId() - Method in class org.apache.hadoop.yarn.server.scheduler.OpportunisticContainerAllocator.ContainerIdGenerator

Generates a new long value.

generateOverview(ApplicationAttemptReport, Collection<ContainerReport>, AppAttemptInfo, String) - Method in class org.apache.hadoop.yarn.server.webapp.AppAttemptBlock

getAccepted() - Method in class org.apache.hadoop.yarn.server.api.protocolrecords.impl.pb.SCMUploaderNotifyResponsePBImpl

getAccepted() - Method in class org.apache.hadoop.yarn.server.api.protocolrecords.SCMUploaderNotifyResponse

Get whether or not the shared cache manager has accepted the notified resource (i.e.

getActiveSubclusters() - Method in class org.apache.hadoop.yarn.server.federation.policies.AbstractConfigurableFederationPolicy

This methods gets active subclusters map from the FederationStateStoreFacade and validate it not being null/empty.

getAllApplications() - Method in class org.apache.hadoop.yarn.server.federation.utils.FederationRegistryClient

Get the list of known applications in the registry.

getAllocatedContainers() - Method in class org.apache.hadoop.yarn.server.api.protocolrecords.DistributedSchedulingAllocateRequest

Get the list of newly allocated Container by the Distributed Scheduling component on the NodeManager.

getAllocatedContainers() - Method in class org.apache.hadoop.yarn.server.api.protocolrecords.impl.pb.DistributedSchedulingAllocateRequestPBImpl

getAllocatedCpuVcores() - Method in class org.apache.hadoop.yarn.server.webapp.dao.AppInfo

getAllocatedMB() - Method in class org.apache.hadoop.yarn.server.webapp.dao.ContainerInfo

getAllocatedMemoryMB() - Method in class org.apache.hadoop.yarn.server.webapp.dao.AppInfo

getAllocatedResource() - Method in class org.apache.hadoop.yarn.server.api.protocolrecords.impl.pb.NMContainerStatusPBImpl

getAllocatedResource() - Method in class org.apache.hadoop.yarn.server.api.protocolrecords.NMContainerStatus

Get the allocated Resource of the container.

getAllocatedResources() - Method in class org.apache.hadoop.yarn.server.webapp.dao.ContainerInfo

Return a map of the allocated resources.

getAllocatedVCores() - Method in class org.apache.hadoop.yarn.server.webapp.dao.ContainerInfo

getAllocateRequest() - Method in class org.apache.hadoop.yarn.server.api.protocolrecords.DistributedSchedulingAllocateRequest

Get the underlying AllocateRequest object.

getAllocateRequest() - Method in class org.apache.hadoop.yarn.server.api.protocolrecords.impl.pb.DistributedSchedulingAllocateRequestPBImpl

getAllocateResponse() - Method in class org.apache.hadoop.yarn.server.api.protocolrecords.DistributedSchedulingAllocateResponse

getAllocateResponse() - Method in class org.apache.hadoop.yarn.server.api.protocolrecords.impl.pb.DistributedSchedulingAllocateResponsePBImpl

getAllocationRequestId() - Method in class org.apache.hadoop.yarn.server.api.protocolrecords.impl.pb.NMContainerStatusPBImpl

getAllocationRequestId() - Method in class org.apache.hadoop.yarn.server.api.protocolrecords.NMContainerStatus

getAllocationRequestId() - Method in class org.apache.hadoop.yarn.server.scheduler.SchedulerRequestKey

Get the Id of the associated ResourceRequest.

getAllocationTags() - Method in class org.apache.hadoop.yarn.server.api.protocolrecords.impl.pb.NMContainerStatusPBImpl

getAllocationTags() - Method in class org.apache.hadoop.yarn.server.api.protocolrecords.NMContainerStatus

Get and set the Allocation tags associated with the container.

getAllUAMIds() - Method in class org.apache.hadoop.yarn.server.uam.UnmanagedAMPoolManager

Get the id of all running UAMs.

getAmContainerId() - Method in class org.apache.hadoop.yarn.server.webapp.dao.AppAttemptInfo

getAmNodeLabelExpression() - Method in class org.apache.hadoop.yarn.server.webapp.dao.AppInfo

getAMRMPolicy(FederationPolicyInitializationContext, FederationAMRMProxyPolicy) - Method in class org.apache.hadoop.yarn.server.federation.policies.manager.AbstractPolicyManager

This default implementation validates the FederationPolicyInitializationContext, then checks whether it needs to reinstantiate the class (null or mismatching type), and reinitialize the policy.

getAMRMPolicy(FederationPolicyInitializationContext, FederationAMRMProxyPolicy) - Method in interface org.apache.hadoop.yarn.server.federation.policies.manager.FederationPolicyManager

If the current instance is compatible, this method returns the same instance of FederationAMRMProxyPolicy reinitialized with the current context, otherwise a new instance initialized with the current context is provided.

getAMRMPolicyWeights() - Method in class org.apache.hadoop.yarn.server.federation.policies.dao.WeightedPolicyInfo

Getter for AMRMProxy weights.

getAMRMServiceAddress() - Method in class org.apache.hadoop.yarn.server.federation.store.records.impl.pb.SubClusterInfoPBImpl

getAMRMServiceAddress() - Method in class org.apache.hadoop.yarn.server.federation.store.records.SubClusterInfo

Get the URL of the AM-RM service endpoint of the subcluster ResourceManager.

getApp(HttpServletRequest, HttpServletResponse, String) - Method in class org.apache.hadoop.yarn.server.webapp.WebServices

getAppAttempt(HttpServletRequest, HttpServletResponse, String, String) - Method in class org.apache.hadoop.yarn.server.webapp.WebServices

getAppAttemptId() - Method in class org.apache.hadoop.yarn.server.webapp.dao.AppAttemptInfo

getAppAttempts(HttpServletRequest, HttpServletResponse, String) - Method in class org.apache.hadoop.yarn.server.webapp.WebServices

getAppAttemptState() - Method in class org.apache.hadoop.yarn.server.webapp.dao.AppAttemptInfo

getAppCollectors() - Method in class org.apache.hadoop.yarn.server.api.protocolrecords.impl.pb.NodeHeartbeatResponsePBImpl

getAppCollectors() - Method in class org.apache.hadoop.yarn.server.api.protocolrecords.NodeHeartbeatResponse

getAppCollectorsList() - Method in class org.apache.hadoop.yarn.server.api.protocolrecords.impl.pb.ReportNewCollectorInfoRequestPBImpl

getAppCollectorsList() - Method in class org.apache.hadoop.yarn.server.api.protocolrecords.ReportNewCollectorInfoRequest

getAppId() - Method in class org.apache.hadoop.yarn.server.uam.UnmanagedApplicationManager

Returns the application id of the UAM.

getAppId() - Method in class org.apache.hadoop.yarn.server.webapp.dao.AppInfo

getApplicationAttemptReport(GetApplicationAttemptReportRequest) - Method in class org.apache.hadoop.yarn.server.webapp.AppAttemptBlock

getApplicationAttemptReport(GetApplicationAttemptReportRequest) - Method in class org.apache.hadoop.yarn.server.webapp.WebServices

getApplicationAttemptsReport(GetApplicationAttemptsRequest) - Method in class org.apache.hadoop.yarn.server.webapp.AppBlock

getApplicationAttemptsReport(GetApplicationAttemptsRequest) - Method in class org.apache.hadoop.yarn.server.webapp.WebServices

getApplicationHomeSubCluster(GetApplicationHomeSubClusterRequest) - Method in interface org.apache.hadoop.yarn.server.federation.store.FederationApplicationHomeSubClusterStore

Get information about the application identified by the input ApplicationId.

getApplicationHomeSubCluster(GetApplicationHomeSubClusterRequest) - Method in class org.apache.hadoop.yarn.server.federation.store.impl.MemoryFederationStateStore

getApplicationHomeSubCluster(GetApplicationHomeSubClusterRequest) - Method in class org.apache.hadoop.yarn.server.federation.store.impl.SQLFederationStateStore

getApplicationHomeSubCluster(GetApplicationHomeSubClusterRequest) - Method in class org.apache.hadoop.yarn.server.federation.store.impl.ZookeeperFederationStateStore

getApplicationHomeSubCluster() - Method in class org.apache.hadoop.yarn.server.federation.store.records.AddApplicationHomeSubClusterRequest

Get the ApplicationHomeSubCluster representing the mapping of the application to it's home sub-cluster.

getApplicationHomeSubCluster() - Method in class org.apache.hadoop.yarn.server.federation.store.records.GetApplicationHomeSubClusterResponse

Get the ApplicationHomeSubCluster representing the mapping of the application to it's home sub-cluster.

getApplicationHomeSubCluster() - Method in class org.apache.hadoop.yarn.server.federation.store.records.impl.pb.AddApplicationHomeSubClusterRequestPBImpl

getApplicationHomeSubCluster() - Method in class org.apache.hadoop.yarn.server.federation.store.records.impl.pb.GetApplicationHomeSubClusterResponsePBImpl

getApplicationHomeSubCluster() - Method in class org.apache.hadoop.yarn.server.federation.store.records.impl.pb.UpdateApplicationHomeSubClusterRequestPBImpl

getApplicationHomeSubCluster() - Method in class org.apache.hadoop.yarn.server.federation.store.records.UpdateApplicationHomeSubClusterRequest

Get the ApplicationHomeSubCluster representing the mapping of the application to it's home sub-cluster.

getApplicationHomeSubCluster(ApplicationId) - Method in class org.apache.hadoop.yarn.server.federation.utils.FederationStateStoreFacade

Returns the home SubClusterId for the specified ApplicationId.

GetApplicationHomeSubClusterRequest - Class in org.apache.hadoop.yarn.server.federation.store.records

Request class to obtain the home sub-cluster for the specified ApplicationId.

GetApplicationHomeSubClusterRequest() - Constructor for class org.apache.hadoop.yarn.server.federation.store.records.GetApplicationHomeSubClusterRequest

GetApplicationHomeSubClusterRequestPBImpl - Class in org.apache.hadoop.yarn.server.federation.store.records.impl.pb

Protocol buffer based implementation of GetApplicationHomeSubClusterRequest.

GetApplicationHomeSubClusterRequestPBImpl() - Constructor for class org.apache.hadoop.yarn.server.federation.store.records.impl.pb.GetApplicationHomeSubClusterRequestPBImpl

GetApplicationHomeSubClusterRequestPBImpl(YarnServerFederationProtos.GetApplicationHomeSubClusterRequestProto) - Constructor for class org.apache.hadoop.yarn.server.federation.store.records.impl.pb.GetApplicationHomeSubClusterRequestPBImpl

GetApplicationHomeSubClusterResponse - Class in org.apache.hadoop.yarn.server.federation.store.records

The response sent by Federation state store to a query for the home subcluster of a newly submitted application.

GetApplicationHomeSubClusterResponse() - Constructor for class org.apache.hadoop.yarn.server.federation.store.records.GetApplicationHomeSubClusterResponse

GetApplicationHomeSubClusterResponsePBImpl - Class in org.apache.hadoop.yarn.server.federation.store.records.impl.pb

Protocol buffer based implementation of GetApplicationHomeSubClusterResponse.

GetApplicationHomeSubClusterResponsePBImpl() - Constructor for class org.apache.hadoop.yarn.server.federation.store.records.impl.pb.GetApplicationHomeSubClusterResponsePBImpl

GetApplicationHomeSubClusterResponsePBImpl(YarnServerFederationProtos.GetApplicationHomeSubClusterResponseProto) - Constructor for class org.apache.hadoop.yarn.server.federation.store.records.impl.pb.GetApplicationHomeSubClusterResponsePBImpl

getApplicationId() - Method in class org.apache.hadoop.yarn.server.api.protocolrecords.GetTimelineCollectorContextRequest

getApplicationId() - Method in class org.apache.hadoop.yarn.server.api.protocolrecords.impl.pb.GetTimelineCollectorContextRequestPBImpl

getApplicationId() - Method in class org.apache.hadoop.yarn.server.api.protocolrecords.impl.pb.LogAggregationReportPBImpl

getApplicationId() - Method in class org.apache.hadoop.yarn.server.api.protocolrecords.LogAggregationReport

Get the ApplicationId of the application.

getApplicationId() - Method in class org.apache.hadoop.yarn.server.api.records.AppCollectorData

getApplicationId() - Method in class org.apache.hadoop.yarn.server.api.records.impl.pb.AppCollectorDataPBImpl

getApplicationId() - Method in class org.apache.hadoop.yarn.server.federation.store.records.ApplicationHomeSubCluster

Get the ApplicationId representing the unique identifier of the application.

getApplicationId() - Method in class org.apache.hadoop.yarn.server.federation.store.records.DeleteApplicationHomeSubClusterRequest

Get the identifier of the ApplicationId to be removed from Federation state store .

getApplicationId() - Method in class org.apache.hadoop.yarn.server.federation.store.records.GetApplicationHomeSubClusterRequest

Get the ApplicationId representing the unique identifier of the application.

getApplicationId() - Method in class org.apache.hadoop.yarn.server.federation.store.records.impl.pb.ApplicationHomeSubClusterPBImpl

getApplicationId() - Method in class org.apache.hadoop.yarn.server.federation.store.records.impl.pb.DeleteApplicationHomeSubClusterRequestPBImpl

getApplicationId() - Method in class org.apache.hadoop.yarn.server.federation.store.records.impl.pb.GetApplicationHomeSubClusterRequestPBImpl

getApplicationReport(GetApplicationReportRequest) - Method in class org.apache.hadoop.yarn.server.webapp.AppBlock

getApplicationReport(GetApplicationsRequest) - Method in class org.apache.hadoop.yarn.server.webapp.AppsBlock

getApplicationReport(GetApplicationReportRequest) - Method in class org.apache.hadoop.yarn.server.webapp.WebServices

getApplicationsHomeSubCluster(GetApplicationsHomeSubClusterRequest) - Method in interface org.apache.hadoop.yarn.server.federation.store.FederationApplicationHomeSubClusterStore

Get the ApplicationHomeSubCluster list representing the mapping of all submitted applications to it's home sub-cluster.

getApplicationsHomeSubCluster(GetApplicationsHomeSubClusterRequest) - Method in class org.apache.hadoop.yarn.server.federation.store.impl.MemoryFederationStateStore

getApplicationsHomeSubCluster(GetApplicationsHomeSubClusterRequest) - Method in class org.apache.hadoop.yarn.server.federation.store.impl.SQLFederationStateStore

getApplicationsHomeSubCluster(GetApplicationsHomeSubClusterRequest) - Method in class org.apache.hadoop.yarn.server.federation.store.impl.ZookeeperFederationStateStore

GetApplicationsHomeSubClusterRequest - Class in org.apache.hadoop.yarn.server.federation.store.records

Request class to obtain the home sub-cluster mapping of all active applications.

GetApplicationsHomeSubClusterRequest() - Constructor for class org.apache.hadoop.yarn.server.federation.store.records.GetApplicationsHomeSubClusterRequest

GetApplicationsHomeSubClusterRequestPBImpl - Class in org.apache.hadoop.yarn.server.federation.store.records.impl.pb

Protocol buffer based implementation of GetApplicationsHomeSubClusterRequest.

GetApplicationsHomeSubClusterRequestPBImpl() - Constructor for class org.apache.hadoop.yarn.server.federation.store.records.impl.pb.GetApplicationsHomeSubClusterRequestPBImpl

GetApplicationsHomeSubClusterRequestPBImpl(YarnServerFederationProtos.GetApplicationsHomeSubClusterRequestProto) - Constructor for class org.apache.hadoop.yarn.server.federation.store.records.impl.pb.GetApplicationsHomeSubClusterRequestPBImpl

GetApplicationsHomeSubClusterResponse - Class in org.apache.hadoop.yarn.server.federation.store.records

The response sent by Federation state store to a query for the home subcluster of all submitted applications.

GetApplicationsHomeSubClusterResponse() - Constructor for class org.apache.hadoop.yarn.server.federation.store.records.GetApplicationsHomeSubClusterResponse

GetApplicationsHomeSubClusterResponsePBImpl - Class in org.apache.hadoop.yarn.server.federation.store.records.impl.pb

Protocol buffer based implementation of GetApplicationsHomeSubClusterResponse.

GetApplicationsHomeSubClusterResponsePBImpl() - Constructor for class org.apache.hadoop.yarn.server.federation.store.records.impl.pb.GetApplicationsHomeSubClusterResponsePBImpl

GetApplicationsHomeSubClusterResponsePBImpl(YarnServerFederationProtos.GetApplicationsHomeSubClusterResponseProto) - Constructor for class org.apache.hadoop.yarn.server.federation.store.records.impl.pb.GetApplicationsHomeSubClusterResponsePBImpl

getApplicationsReport(GetApplicationsRequest) - Method in class org.apache.hadoop.yarn.server.webapp.WebServices

getApplicationsToCleanup() - Method in class org.apache.hadoop.yarn.server.api.protocolrecords.impl.pb.NodeHeartbeatResponsePBImpl

getApplicationsToCleanup() - Method in class org.apache.hadoop.yarn.server.api.protocolrecords.NodeHeartbeatResponse

getApplicationTags() - Method in class org.apache.hadoop.yarn.server.webapp.dao.AppInfo

getAppNodeLabelExpression() - Method in class org.apache.hadoop.yarn.server.webapp.dao.AppInfo

getAppParams() - Method in class org.apache.hadoop.yarn.server.scheduler.OpportunisticContainerContext

getApps() - Method in class org.apache.hadoop.yarn.server.webapp.dao.AppsInfo

getApps(HttpServletRequest, HttpServletResponse, String, Set<String>, String, String, String, String, String, String, String, String, Set<String>) - Method in class org.apache.hadoop.yarn.server.webapp.WebServices

getAppsHomeSubClusters() - Method in class org.apache.hadoop.yarn.server.federation.store.records.GetApplicationsHomeSubClusterResponse

Get the ApplicationHomeSubCluster list representing the mapping of all submitted applications to it's home sub-cluster.

getAppsHomeSubClusters() - Method in class org.apache.hadoop.yarn.server.federation.store.records.impl.pb.GetApplicationsHomeSubClusterResponsePBImpl

getAppState() - Method in class org.apache.hadoop.yarn.server.webapp.dao.AppInfo

getAreNodeLabelsAcceptedByRM() - Method in class org.apache.hadoop.yarn.server.api.protocolrecords.impl.pb.NodeHeartbeatResponsePBImpl

getAreNodeLabelsAcceptedByRM() - Method in class org.apache.hadoop.yarn.server.api.protocolrecords.impl.pb.RegisterNodeManagerResponsePBImpl

getAreNodeLabelsAcceptedByRM() - Method in class org.apache.hadoop.yarn.server.api.protocolrecords.NodeHeartbeatResponse

getAreNodeLabelsAcceptedByRM() - Method in class org.apache.hadoop.yarn.server.api.protocolrecords.RegisterNodeManagerResponse

getAssignedNodeId() - Method in class org.apache.hadoop.yarn.server.webapp.dao.ContainerInfo

getAttempts() - Method in class org.apache.hadoop.yarn.server.webapp.dao.AppAttemptsInfo

getBlacklist() - Method in class org.apache.hadoop.yarn.server.scheduler.OpportunisticContainerContext

getBytes() - Method in class org.apache.hadoop.yarn.server.api.records.impl.pb.MasterKeyPBImpl

getBytes() - Method in interface org.apache.hadoop.yarn.server.api.records.MasterKey

getCacheDepth(Configuration) - Static method in class org.apache.hadoop.yarn.server.sharedcache.SharedCacheUtil

getCacheEntryGlobPattern(int) - Static method in class org.apache.hadoop.yarn.server.sharedcache.SharedCacheUtil

getCacheEntryPath(int, String, String) - Static method in class org.apache.hadoop.yarn.server.sharedcache.SharedCacheUtil

getCallback() - Method in class org.apache.hadoop.yarn.server.uam.UnmanagedApplicationManager.AsyncAllocateRequestInfo

getCapability() - Method in class org.apache.hadoop.yarn.server.federation.store.records.impl.pb.SubClusterHeartbeatRequestPBImpl

getCapability() - Method in class org.apache.hadoop.yarn.server.federation.store.records.impl.pb.SubClusterInfoPBImpl

getCapability() - Method in class org.apache.hadoop.yarn.server.federation.store.records.SubClusterHeartbeatRequest

Get the current capacity and utilization of the subcluster.

getCapability() - Method in class org.apache.hadoop.yarn.server.federation.store.records.SubClusterInfo

Get the current capacity and utilization of the subcluster.

getClientRMServiceAddress() - Method in class org.apache.hadoop.yarn.server.federation.store.records.impl.pb.SubClusterInfoPBImpl

getClientRMServiceAddress() - Method in class org.apache.hadoop.yarn.server.federation.store.records.SubClusterInfo

Get the URL of the client-RM service endpoint of the subcluster ResourceManager.

getCollectorAddr() - Method in class org.apache.hadoop.yarn.server.api.records.AppCollectorData

getCollectorAddr() - Method in class org.apache.hadoop.yarn.server.api.records.impl.pb.AppCollectorDataPBImpl

getCollectorToken() - Method in class org.apache.hadoop.yarn.server.api.records.AppCollectorData

Get delegation token for app collector which AM will use to publish entities.

getCollectorToken() - Method in class org.apache.hadoop.yarn.server.api.records.impl.pb.AppCollectorDataPBImpl

getConf() - Method in class org.apache.hadoop.yarn.server.federation.resolver.DefaultSubClusterResolverImpl

getConnection() - Method in class org.apache.hadoop.yarn.server.federation.store.impl.SQLFederationStateStore

Get a connection from the DataSource pool.

getContainer(HttpServletRequest, HttpServletResponse, String, String, String) - Method in class org.apache.hadoop.yarn.server.webapp.WebServices

getContainerExitStatus() - Method in class org.apache.hadoop.yarn.server.api.protocolrecords.impl.pb.NMContainerStatusPBImpl

getContainerExitStatus() - Method in class org.apache.hadoop.yarn.server.api.protocolrecords.NMContainerStatus

Get the final exit status of the container.

getContainerExitStatus() - Method in class org.apache.hadoop.yarn.server.webapp.dao.ContainerInfo

getContainerId() - Method in class org.apache.hadoop.yarn.server.api.protocolrecords.impl.pb.NMContainerStatusPBImpl

getContainerId() - Method in class org.apache.hadoop.yarn.server.api.protocolrecords.NMContainerStatus

Get the ContainerId of the container.

getContainerId() - Method in class org.apache.hadoop.yarn.server.webapp.dao.ContainerInfo

getContainerId() - Method in class org.apache.hadoop.yarn.server.webapp.dao.ContainerLogsInfo

getContainerIdGenerator() - Method in class org.apache.hadoop.yarn.server.scheduler.OpportunisticContainerContext

getContainerIdStart() - Method in class org.apache.hadoop.yarn.server.api.protocolrecords.impl.pb.RegisterDistributedSchedulingAMResponsePBImpl

getContainerIdStart() - Method in class org.apache.hadoop.yarn.server.api.protocolrecords.RegisterDistributedSchedulingAMResponse

getContainerLogsInfo() - Method in class org.apache.hadoop.yarn.server.webapp.dao.ContainerLogsInfo

getContainerQueuingLimit() - Method in class org.apache.hadoop.yarn.server.api.protocolrecords.impl.pb.NodeHeartbeatResponsePBImpl

getContainerQueuingLimit() - Method in class org.apache.hadoop.yarn.server.api.protocolrecords.NodeHeartbeatResponse

getContainerReport(GetContainerReportRequest) - Method in class org.apache.hadoop.yarn.server.webapp.AppBlock

getContainerReport(GetContainerReportRequest) - Method in class org.apache.hadoop.yarn.server.webapp.ContainerBlock

getContainerReport(GetContainerReportRequest) - Method in class org.apache.hadoop.yarn.server.webapp.WebServices

getContainers(GetContainersRequest) - Method in class org.apache.hadoop.yarn.server.webapp.AppAttemptBlock

getContainers() - Method in class org.apache.hadoop.yarn.server.webapp.dao.ContainersInfo

getContainers(HttpServletRequest, HttpServletResponse, String, String) - Method in class org.apache.hadoop.yarn.server.webapp.WebServices

getContainersReport(GetContainersRequest) - Method in class org.apache.hadoop.yarn.server.webapp.WebServices

getContainersStatuses() - Method in class org.apache.hadoop.yarn.server.api.records.impl.pb.NodeStatusPBImpl

getContainersStatuses() - Method in class org.apache.hadoop.yarn.server.api.records.NodeStatus

getContainerState() - Method in class org.apache.hadoop.yarn.server.api.protocolrecords.impl.pb.NMContainerStatusPBImpl

getContainerState() - Method in class org.apache.hadoop.yarn.server.api.protocolrecords.NMContainerStatus

getContainerState() - Method in class org.apache.hadoop.yarn.server.webapp.dao.ContainerInfo

getContainersToBeRemovedFromNM() - Method in class org.apache.hadoop.yarn.server.api.protocolrecords.impl.pb.NodeHeartbeatResponsePBImpl

getContainersToBeRemovedFromNM() - Method in class org.apache.hadoop.yarn.server.api.protocolrecords.NodeHeartbeatResponse

getContainersToCleanup() - Method in class org.apache.hadoop.yarn.server.api.protocolrecords.impl.pb.NodeHeartbeatResponsePBImpl

getContainersToCleanup() - Method in class org.apache.hadoop.yarn.server.api.protocolrecords.NodeHeartbeatResponse

getContainersToDecrease() - Method in class org.apache.hadoop.yarn.server.api.protocolrecords.impl.pb.NodeHeartbeatResponsePBImpl

getContainersToDecrease() - Method in class org.apache.hadoop.yarn.server.api.protocolrecords.NodeHeartbeatResponse

getContainersToSignalList() - Method in class org.apache.hadoop.yarn.server.api.protocolrecords.impl.pb.NodeHeartbeatResponsePBImpl

getContainersToSignalList() - Method in class org.apache.hadoop.yarn.server.api.protocolrecords.NodeHeartbeatResponse

getContainersToUpdate() - Method in class org.apache.hadoop.yarn.server.api.protocolrecords.impl.pb.NodeHeartbeatResponsePBImpl

getContainersToUpdate() - Method in class org.apache.hadoop.yarn.server.api.protocolrecords.NodeHeartbeatResponse

getContainersUtilization() - Method in class org.apache.hadoop.yarn.server.api.records.impl.pb.NodeStatusPBImpl

getContainersUtilization() - Method in class org.apache.hadoop.yarn.server.api.records.NodeStatus

Get the resource utilization of the containers.

getContainerTokenExpiryInterval() - Method in class org.apache.hadoop.yarn.server.api.protocolrecords.impl.pb.RegisterDistributedSchedulingAMResponsePBImpl

getContainerTokenExpiryInterval() - Method in class org.apache.hadoop.yarn.server.api.protocolrecords.RegisterDistributedSchedulingAMResponse

getContainerTokenExpiryInterval() - Method in class org.apache.hadoop.yarn.server.scheduler.OpportunisticContainerAllocator.AllocationParams

Get Container Token Expiry interval.

getContainerTokenMasterKey() - Method in class org.apache.hadoop.yarn.server.api.protocolrecords.impl.pb.NodeHeartbeatResponsePBImpl

getContainerTokenMasterKey() - Method in class org.apache.hadoop.yarn.server.api.protocolrecords.impl.pb.RegisterNodeManagerResponsePBImpl

getContainerTokenMasterKey() - Method in class org.apache.hadoop.yarn.server.api.protocolrecords.NodeHeartbeatResponse

getContainerTokenMasterKey() - Method in class org.apache.hadoop.yarn.server.api.protocolrecords.RegisterNodeManagerResponse

getContainerToUpdate() - Method in class org.apache.hadoop.yarn.server.scheduler.SchedulerRequestKey

getCreationTime() - Method in class org.apache.hadoop.yarn.server.api.protocolrecords.impl.pb.NMContainerStatusPBImpl

getCreationTime() - Method in class org.apache.hadoop.yarn.server.api.protocolrecords.NMContainerStatus

Get the time when the container is created

getCSRFHeaderString(Configuration) - Static method in class org.apache.hadoop.yarn.server.webapp.AppBlock

getCurrentAppAttemptId() - Method in class org.apache.hadoop.yarn.server.webapp.dao.AppInfo

getCurrentKey() - Method in class org.apache.hadoop.yarn.server.security.BaseContainerTokenSecretManager

getCurrentKey() - Method in class org.apache.hadoop.yarn.server.security.BaseNMTokenSecretManager

getCurrentVersion() - Method in interface org.apache.hadoop.yarn.server.federation.store.FederationStateStore

Get the Version of the underlying federation state store client.

getCurrentVersion() - Method in class org.apache.hadoop.yarn.server.federation.store.impl.MemoryFederationStateStore

getCurrentVersion() - Method in class org.apache.hadoop.yarn.server.federation.store.impl.SQLFederationStateStore

getCurrentVersion() - Method in class org.apache.hadoop.yarn.server.federation.store.impl.ZookeeperFederationStateStore

getDiagnosticMessage() - Method in class org.apache.hadoop.yarn.server.api.protocolrecords.impl.pb.LogAggregationReportPBImpl

getDiagnosticMessage() - Method in class org.apache.hadoop.yarn.server.api.protocolrecords.LogAggregationReport

Get the diagnositic information of this log aggregation

getDiagnostics() - Method in class org.apache.hadoop.yarn.server.api.protocolrecords.impl.pb.NMContainerStatusPBImpl

getDiagnostics() - Method in class org.apache.hadoop.yarn.server.api.protocolrecords.NMContainerStatus

Get the DiagnosticsInfo of the container.

getDiagnosticsInfo() - Method in class org.apache.hadoop.yarn.server.webapp.dao.AppAttemptInfo

getDiagnosticsInfo() - Method in class org.apache.hadoop.yarn.server.webapp.dao.AppInfo

getDiagnosticsInfo() - Method in class org.apache.hadoop.yarn.server.webapp.dao.ContainerInfo

getDiagnosticsMessage() - Method in class org.apache.hadoop.yarn.server.api.protocolrecords.impl.pb.NodeHeartbeatResponsePBImpl

getDiagnosticsMessage() - Method in class org.apache.hadoop.yarn.server.api.protocolrecords.impl.pb.RegisterNodeManagerResponsePBImpl

getDiagnosticsMessage() - Method in class org.apache.hadoop.yarn.server.api.protocolrecords.NodeHeartbeatResponse

getDiagnosticsMessage() - Method in class org.apache.hadoop.yarn.server.api.protocolrecords.RegisterNodeManagerResponse

getElapsedTime() - Method in class org.apache.hadoop.yarn.server.webapp.dao.AppInfo

getElapsedTime() - Method in class org.apache.hadoop.yarn.server.webapp.dao.ContainerInfo

getEstimatedQueueWaitTime() - Method in class org.apache.hadoop.yarn.server.api.records.impl.pb.OpportunisticContainersStatusPBImpl

getEstimatedQueueWaitTime() - Method in class org.apache.hadoop.yarn.server.api.records.OpportunisticContainersStatus

Returns the estimated time that a container will have to wait if added to the queue of the node.

getExecutionType() - Method in class org.apache.hadoop.yarn.server.api.protocolrecords.impl.pb.NMContainerStatusPBImpl

getExecutionType() - Method in class org.apache.hadoop.yarn.server.api.protocolrecords.NMContainerStatus

Get the ExecutionType of the container.

getFederationStateStoreFacade() - Method in class org.apache.hadoop.yarn.server.federation.policies.FederationPolicyInitializationContext

Getter for the FederationStateStoreFacade.

getFederationSubclusterResolver() - Method in class org.apache.hadoop.yarn.server.federation.policies.FederationPolicyInitializationContext

Getter for the SubClusterResolver.

getFileName() - Method in class org.apache.hadoop.yarn.server.api.protocolrecords.impl.pb.SCMUploaderNotifyRequestPBImpl

getFileName() - Method in class org.apache.hadoop.yarn.server.api.protocolrecords.SCMUploaderNotifyRequest

Get the filename of the resource that was just uploaded to the shared cache.

getFilterConfig() - Method in class org.apache.hadoop.yarn.server.timeline.security.TimelineAuthenticationFilterInitializer

getFilterInactiveSubClusters() - Method in class org.apache.hadoop.yarn.server.federation.store.records.GetSubClustersInfoRequest

Get the flag that indicates whether only active sub-clusters should be returned.

getFilterInactiveSubClusters() - Method in class org.apache.hadoop.yarn.server.federation.store.records.impl.pb.GetSubClustersInfoRequestPBImpl

getFinalAppStatus() - Method in class org.apache.hadoop.yarn.server.webapp.dao.AppInfo

getFinishedTime() - Method in class org.apache.hadoop.yarn.server.webapp.dao.AppAttemptInfo

getFinishedTime() - Method in class org.apache.hadoop.yarn.server.webapp.dao.AppInfo

getFinishedTime() - Method in class org.apache.hadoop.yarn.server.webapp.dao.ContainerInfo

getFlowName() - Method in class org.apache.hadoop.yarn.server.api.protocolrecords.GetTimelineCollectorContextResponse

getFlowName() - Method in class org.apache.hadoop.yarn.server.api.protocolrecords.impl.pb.GetTimelineCollectorContextResponsePBImpl

getFlowRunId() - Method in class org.apache.hadoop.yarn.server.api.protocolrecords.GetTimelineCollectorContextResponse

getFlowRunId() - Method in class org.apache.hadoop.yarn.server.api.protocolrecords.impl.pb.GetTimelineCollectorContextResponsePBImpl

getFlowVersion() - Method in class org.apache.hadoop.yarn.server.api.protocolrecords.GetTimelineCollectorContextResponse

getFlowVersion() - Method in class org.apache.hadoop.yarn.server.api.protocolrecords.impl.pb.GetTimelineCollectorContextResponsePBImpl

getGuaranteed() - Method in class org.apache.hadoop.yarn.server.scheduler.OpportunisticContainerAllocator.PartitionedResourceRequests

getHeadroomAlpha() - Method in class org.apache.hadoop.yarn.server.federation.policies.dao.WeightedPolicyInfo

Return the parameter headroomAlpha, used by policies that balance weight-based and load-based considerations in their decisions.

getHealthReport() - Method in class org.apache.hadoop.yarn.server.api.records.impl.pb.NodeHealthStatusPBImpl

getHealthReport() - Method in class org.apache.hadoop.yarn.server.api.records.NodeHealthStatus

Get the diagnostic health report of the node.

getHomeSubcluster() - Method in class org.apache.hadoop.yarn.server.federation.policies.FederationPolicyInitializationContext

Returns the current home sub-cluster.

getHomeSubcluster(ApplicationSubmissionContext, List<SubClusterId>) - Method in interface org.apache.hadoop.yarn.server.federation.policies.router.FederationRouterPolicy

Determines the sub-cluster that the user application submission should be routed to.

getHomeSubcluster(ApplicationSubmissionContext, List<SubClusterId>) - Method in class org.apache.hadoop.yarn.server.federation.policies.router.HashBasedRouterPolicy

Simply picks from alphabetically-sorted active subclusters based on the hash of quey name.

getHomeSubcluster(ApplicationSubmissionContext, List<SubClusterId>) - Method in class org.apache.hadoop.yarn.server.federation.policies.router.LoadBasedRouterPolicy

getHomeSubcluster(ApplicationSubmissionContext, List<SubClusterId>) - Method in class org.apache.hadoop.yarn.server.federation.policies.router.PriorityRouterPolicy

getHomeSubcluster(ApplicationSubmissionContext, List<SubClusterId>) - Method in class org.apache.hadoop.yarn.server.federation.policies.router.RejectRouterPolicy

The policy always reject requests.

getHomeSubcluster(ApplicationSubmissionContext, List<SubClusterId>) - Method in class org.apache.hadoop.yarn.server.federation.policies.router.UniformRandomRouterPolicy

Simply picks a random active subCluster to start the AM (this does NOT depend on the weights in the policy).

getHomeSubcluster(ApplicationSubmissionContext, List<SubClusterId>) - Method in class org.apache.hadoop.yarn.server.federation.policies.router.WeightedRandomRouterPolicy

getHomeSubcluster(ApplicationSubmissionContext, List<SubClusterId>) - Method in class org.apache.hadoop.yarn.server.federation.policies.RouterPolicyFacade

This method provides a wrapper of all policy functionalities for routing .

getHomeSubCluster() - Method in class org.apache.hadoop.yarn.server.federation.store.records.AddApplicationHomeSubClusterResponse

Get the home sub-cluster that this application has been assigned to.

getHomeSubCluster() - Method in class org.apache.hadoop.yarn.server.federation.store.records.ApplicationHomeSubCluster

Get the SubClusterId representing the unique identifier of the home subcluster in which the ApplicationMaster of the application is running.

getHomeSubCluster() - Method in class org.apache.hadoop.yarn.server.federation.store.records.impl.pb.AddApplicationHomeSubClusterResponsePBImpl

getHomeSubCluster() - Method in class org.apache.hadoop.yarn.server.federation.store.records.impl.pb.ApplicationHomeSubClusterPBImpl

getHost() - Method in class org.apache.hadoop.yarn.server.webapp.dao.AppAttemptInfo

getHost() - Method in class org.apache.hadoop.yarn.server.webapp.dao.AppInfo

getHttpAddress() - Method in class org.apache.hadoop.yarn.server.api.protocolrecords.impl.pb.RemoteNodePBImpl

getHttpAddress() - Method in class org.apache.hadoop.yarn.server.api.protocolrecords.RemoteNode

Get HTTP address.

getHttpPort() - Method in class org.apache.hadoop.yarn.server.api.protocolrecords.impl.pb.RegisterNodeManagerRequestPBImpl

getHttpPort() - Method in class org.apache.hadoop.yarn.server.api.protocolrecords.RegisterNodeManagerRequest

getId() - Method in class org.apache.hadoop.yarn.server.federation.store.records.impl.pb.SubClusterIdPBImpl

getId() - Method in class org.apache.hadoop.yarn.server.federation.store.records.SubClusterId

Get the string identifier of the subcluster which is unique across the federated cluster.

getIncrContainerResource() - Method in class org.apache.hadoop.yarn.server.api.protocolrecords.impl.pb.RegisterDistributedSchedulingAMResponsePBImpl

getIncrContainerResource() - Method in class org.apache.hadoop.yarn.server.api.protocolrecords.RegisterDistributedSchedulingAMResponse

getIncreasedContainers() - Method in class org.apache.hadoop.yarn.server.api.records.impl.pb.NodeStatusPBImpl

getIncreasedContainers() - Method in class org.apache.hadoop.yarn.server.api.records.NodeStatus

getIncrementResource() - Method in class org.apache.hadoop.yarn.server.scheduler.OpportunisticContainerAllocator.AllocationParams

Get Incremental Resource.

getInstance() - Static method in class org.apache.hadoop.yarn.server.federation.store.metrics.FederationStateStoreClientMetrics

getInstance() - Static method in class org.apache.hadoop.yarn.server.federation.utils.FederationStateStoreFacade

Returns the singleton instance of the FederationStateStoreFacade object.

getInterface() - Method in class org.apache.hadoop.yarn.server.federation.failover.FederationRMFailoverProxyProvider

getIsDirty() - Method in class org.apache.hadoop.yarn.server.federation.policies.AbstractConfigurableFederationPolicy

Returns true whether the last reinitialization requires actual changes, or was "free" as the weights have not changed.

getIsNodeHealthy() - Method in class org.apache.hadoop.yarn.server.api.records.impl.pb.NodeHealthStatusPBImpl

getIsNodeHealthy() - Method in class org.apache.hadoop.yarn.server.api.records.NodeHealthStatus

Is the node healthy?

getKeepAliveApplications() - Method in class org.apache.hadoop.yarn.server.api.records.impl.pb.NodeStatusPBImpl

getKeepAliveApplications() - Method in class org.apache.hadoop.yarn.server.api.records.NodeStatus

getKerberosInfo(Class<?>, Configuration) - Method in class org.apache.hadoop.yarn.server.RMNMSecurityInfoClass

getKeyId() - Method in class org.apache.hadoop.yarn.server.api.records.impl.pb.MasterKeyPBImpl

getKeyId() - Method in interface org.apache.hadoop.yarn.server.api.records.MasterKey

getLastHealthReportTime() - Method in class org.apache.hadoop.yarn.server.api.records.impl.pb.NodeHealthStatusPBImpl

getLastHealthReportTime() - Method in class org.apache.hadoop.yarn.server.api.records.NodeHealthStatus

Get the last timestamp at which the health report was received.

getLastHeartBeat() - Method in class org.apache.hadoop.yarn.server.federation.store.records.impl.pb.SubClusterHeartbeatRequestPBImpl

getLastHeartBeat() - Method in class org.apache.hadoop.yarn.server.federation.store.records.impl.pb.SubClusterInfoPBImpl

getLastHeartBeat() - Method in class org.apache.hadoop.yarn.server.federation.store.records.SubClusterHeartbeatRequest

Get the last heart beat time of the subcluster.

getLastHeartBeat() - Method in class org.apache.hadoop.yarn.server.federation.store.records.SubClusterInfo

Get the last heart beat time of the subcluster.

getLastKnownContainerTokenMasterKey() - Method in class org.apache.hadoop.yarn.server.api.protocolrecords.impl.pb.NodeHeartbeatRequestPBImpl

getLastKnownContainerTokenMasterKey() - Method in class org.apache.hadoop.yarn.server.api.protocolrecords.NodeHeartbeatRequest

getLastKnownNMTokenMasterKey() - Method in class org.apache.hadoop.yarn.server.api.protocolrecords.impl.pb.NodeHeartbeatRequestPBImpl

getLastKnownNMTokenMasterKey() - Method in class org.apache.hadoop.yarn.server.api.protocolrecords.NodeHeartbeatRequest

getLastStartTime() - Method in class org.apache.hadoop.yarn.server.federation.store.records.impl.pb.SubClusterInfoPBImpl

getLastStartTime() - Method in class org.apache.hadoop.yarn.server.federation.store.records.SubClusterInfo

Get the timestamp representing the last start time of the subcluster.

getLogAggregationReportsForApps() - Method in class org.apache.hadoop.yarn.server.api.protocolrecords.impl.pb.NodeHeartbeatRequestPBImpl

getLogAggregationReportsForApps() - Method in class org.apache.hadoop.yarn.server.api.protocolrecords.impl.pb.RegisterNodeManagerRequestPBImpl

getLogAggregationReportsForApps() - Method in class org.apache.hadoop.yarn.server.api.protocolrecords.NodeHeartbeatRequest

getLogAggregationReportsForApps() - Method in class org.apache.hadoop.yarn.server.api.protocolrecords.RegisterNodeManagerRequest

getLogAggregationStatus() - Method in class org.apache.hadoop.yarn.server.api.protocolrecords.impl.pb.LogAggregationReportPBImpl

getLogAggregationStatus() - Method in class org.apache.hadoop.yarn.server.api.protocolrecords.LogAggregationReport

Get the LogAggregationStatus.

getLogAggregationStatus() - Method in class org.apache.hadoop.yarn.server.webapp.AppBlock

getLogType() - Method in class org.apache.hadoop.yarn.server.webapp.dao.ContainerLogsInfo

getLogUrl() - Method in class org.apache.hadoop.yarn.server.webapp.dao.ContainerInfo

getMajorVersion() - Method in class org.apache.hadoop.yarn.server.records.impl.pb.VersionPBImpl

getMajorVersion() - Method in class org.apache.hadoop.yarn.server.records.Version

getMasterKey() - Method in class org.apache.hadoop.yarn.server.security.MasterKeyData

getMaxAllocationsPerSchedulerKeyPerRound() - Method in class org.apache.hadoop.yarn.server.scheduler.OpportunisticContainerAllocator.AllocationParams

Get the Max Allocations per Scheduler Key per allocation round.

getMaxContainerResource() - Method in class org.apache.hadoop.yarn.server.api.protocolrecords.impl.pb.RegisterDistributedSchedulingAMResponsePBImpl

getMaxContainerResource() - Method in class org.apache.hadoop.yarn.server.api.protocolrecords.RegisterDistributedSchedulingAMResponse

getMaxQueueLength() - Method in class org.apache.hadoop.yarn.server.api.records.ContainerQueuingLimit

getMaxQueueLength() - Method in class org.apache.hadoop.yarn.server.api.records.impl.pb.ContainerQueuingLimitPBImpl

getMaxQueueWaitTimeInMs() - Method in class org.apache.hadoop.yarn.server.api.records.ContainerQueuingLimit

getMaxQueueWaitTimeInMs() - Method in class org.apache.hadoop.yarn.server.api.records.impl.pb.ContainerQueuingLimitPBImpl

getMaxResource() - Method in class org.apache.hadoop.yarn.server.scheduler.OpportunisticContainerAllocator.AllocationParams

Return Max Resource.

getMetrics(MetricsCollector, boolean) - Method in class org.apache.hadoop.yarn.server.federation.store.metrics.FederationStateStoreClientMetrics

getMinContainerResource() - Method in class org.apache.hadoop.yarn.server.api.protocolrecords.impl.pb.RegisterDistributedSchedulingAMResponsePBImpl

getMinContainerResource() - Method in class org.apache.hadoop.yarn.server.api.protocolrecords.RegisterDistributedSchedulingAMResponse

getMinorVersion() - Method in class org.apache.hadoop.yarn.server.records.impl.pb.VersionPBImpl

getMinorVersion() - Method in class org.apache.hadoop.yarn.server.records.Version

getMinResource() - Method in class org.apache.hadoop.yarn.server.scheduler.OpportunisticContainerAllocator.AllocationParams

Get Min Resource.

getName() - Method in class org.apache.hadoop.yarn.server.webapp.dao.AppInfo

getNextHeartBeatInterval() - Method in class org.apache.hadoop.yarn.server.api.protocolrecords.impl.pb.NodeHeartbeatResponsePBImpl

getNextHeartBeatInterval() - Method in class org.apache.hadoop.yarn.server.api.protocolrecords.NodeHeartbeatResponse

getNMContainerStatuses() - Method in class org.apache.hadoop.yarn.server.api.protocolrecords.impl.pb.RegisterNodeManagerRequestPBImpl

getNMContainerStatuses() - Method in class org.apache.hadoop.yarn.server.api.protocolrecords.RegisterNodeManagerRequest

getNMTokenMasterKey() - Method in class org.apache.hadoop.yarn.server.api.protocolrecords.impl.pb.NodeHeartbeatResponsePBImpl

getNMTokenMasterKey() - Method in class org.apache.hadoop.yarn.server.api.protocolrecords.impl.pb.RegisterNodeManagerResponsePBImpl

getNMTokenMasterKey() - Method in class org.apache.hadoop.yarn.server.api.protocolrecords.NodeHeartbeatResponse

getNMTokenMasterKey() - Method in class org.apache.hadoop.yarn.server.api.protocolrecords.RegisterNodeManagerResponse

getNMVersion() - Method in class org.apache.hadoop.yarn.server.api.protocolrecords.impl.pb.RegisterNodeManagerRequestPBImpl

getNMVersion() - Method in class org.apache.hadoop.yarn.server.api.protocolrecords.RegisterNodeManagerRequest

getNodeAction() - Method in class org.apache.hadoop.yarn.server.api.protocolrecords.impl.pb.NodeHeartbeatResponsePBImpl

getNodeAction() - Method in class org.apache.hadoop.yarn.server.api.protocolrecords.impl.pb.RegisterNodeManagerResponsePBImpl

getNodeAction() - Method in class org.apache.hadoop.yarn.server.api.protocolrecords.NodeHeartbeatResponse

getNodeAction() - Method in class org.apache.hadoop.yarn.server.api.protocolrecords.RegisterNodeManagerResponse

getNodeHealthStatus() - Method in class org.apache.hadoop.yarn.server.api.records.impl.pb.NodeStatusPBImpl

getNodeHealthStatus() - Method in class org.apache.hadoop.yarn.server.api.records.NodeStatus

getNodeHttpAddress() - Method in class org.apache.hadoop.yarn.server.webapp.dao.ContainerInfo

getNodeId() - Method in class org.apache.hadoop.yarn.server.api.protocolrecords.impl.pb.RegisterNodeManagerRequestPBImpl

getNodeId() - Method in class org.apache.hadoop.yarn.server.api.protocolrecords.impl.pb.RemoteNodePBImpl

getNodeId() - Method in class org.apache.hadoop.yarn.server.api.protocolrecords.impl.pb.UnRegisterNodeManagerRequestPBImpl

getNodeId() - Method in class org.apache.hadoop.yarn.server.api.protocolrecords.RegisterNodeManagerRequest

getNodeId() - Method in class org.apache.hadoop.yarn.server.api.protocolrecords.RemoteNode

Get NodeId.

getNodeId() - Method in class org.apache.hadoop.yarn.server.api.protocolrecords.UnRegisterNodeManagerRequest

getNodeId() - Method in class org.apache.hadoop.yarn.server.api.records.impl.pb.NodeStatusPBImpl

getNodeId() - Method in class org.apache.hadoop.yarn.server.api.records.NodeStatus

getNodeId() - Method in class org.apache.hadoop.yarn.server.webapp.dao.ContainerInfo

getNodeId() - Method in class org.apache.hadoop.yarn.server.webapp.dao.ContainerLogsInfo

getNodeLabelExpression() - Method in class org.apache.hadoop.yarn.server.api.protocolrecords.impl.pb.NMContainerStatusPBImpl

getNodeLabelExpression() - Method in class org.apache.hadoop.yarn.server.api.protocolrecords.NMContainerStatus

Get the node-label-expression in the original ResourceRequest

getNodeLabels() - Method in class org.apache.hadoop.yarn.server.api.protocolrecords.impl.pb.NodeHeartbeatRequestPBImpl

getNodeLabels() - Method in class org.apache.hadoop.yarn.server.api.protocolrecords.impl.pb.RegisterNodeManagerRequestPBImpl

getNodeLabels() - Method in class org.apache.hadoop.yarn.server.api.protocolrecords.NodeHeartbeatRequest

getNodeLabels() - Method in class org.apache.hadoop.yarn.server.api.protocolrecords.RegisterNodeManagerRequest

getNodeMap() - Method in class org.apache.hadoop.yarn.server.scheduler.OpportunisticContainerContext

getNodesForScheduling() - Method in class org.apache.hadoop.yarn.server.api.protocolrecords.DistributedSchedulingAllocateResponse

getNodesForScheduling() - Method in class org.apache.hadoop.yarn.server.api.protocolrecords.impl.pb.DistributedSchedulingAllocateResponsePBImpl

getNodesForScheduling() - Method in class org.apache.hadoop.yarn.server.api.protocolrecords.impl.pb.RegisterDistributedSchedulingAMResponsePBImpl

getNodesForScheduling() - Method in class org.apache.hadoop.yarn.server.api.protocolrecords.RegisterDistributedSchedulingAMResponse

getNodeStatus() - Method in class org.apache.hadoop.yarn.server.api.protocolrecords.impl.pb.NodeHeartbeatRequestPBImpl

getNodeStatus() - Method in class org.apache.hadoop.yarn.server.api.protocolrecords.NodeHeartbeatRequest

getNodeToSubCluster() - Method in class org.apache.hadoop.yarn.server.federation.resolver.AbstractSubClusterResolver

getNodeUtilization() - Method in class org.apache.hadoop.yarn.server.api.records.impl.pb.NodeStatusPBImpl

getNodeUtilization() - Method in class org.apache.hadoop.yarn.server.api.records.NodeStatus

Get the resource utilization of the node.

getOpportCoresUsed() - Method in class org.apache.hadoop.yarn.server.api.records.impl.pb.OpportunisticContainersStatusPBImpl

getOpportCoresUsed() - Method in class org.apache.hadoop.yarn.server.api.records.OpportunisticContainersStatus

Returns CPU cores currently used on the node for running opportunistic containers.

getOpportMemoryUsed() - Method in class org.apache.hadoop.yarn.server.api.records.impl.pb.OpportunisticContainersStatusPBImpl

getOpportMemoryUsed() - Method in class org.apache.hadoop.yarn.server.api.records.OpportunisticContainersStatus

Returns memory currently used on the node for running opportunistic containers.

getOpportQueueCapacity() - Method in class org.apache.hadoop.yarn.server.api.records.impl.pb.OpportunisticContainersStatusPBImpl

getOpportQueueCapacity() - Method in class org.apache.hadoop.yarn.server.api.records.OpportunisticContainersStatus

Gets the capacity of the opportunistic containers queue on the node.

getOpportunistic() - Method in class org.apache.hadoop.yarn.server.scheduler.OpportunisticContainerAllocator.PartitionedResourceRequests

getOpportunisticContainersStatus() - Method in class org.apache.hadoop.yarn.server.api.records.impl.pb.NodeStatusPBImpl

getOpportunisticContainersStatus() - Method in class org.apache.hadoop.yarn.server.api.records.NodeStatus

getOriginalTrackingUrl() - Method in class org.apache.hadoop.yarn.server.webapp.dao.AppAttemptInfo

getOriginalTrackingUrl() - Method in class org.apache.hadoop.yarn.server.webapp.dao.AppInfo

getOutstandingOpReqs() - Method in class org.apache.hadoop.yarn.server.scheduler.OpportunisticContainerContext

getParams() - Method in class org.apache.hadoop.yarn.server.federation.store.records.impl.pb.SubClusterPolicyConfigurationPBImpl

getParams() - Method in class org.apache.hadoop.yarn.server.federation.store.records.SubClusterPolicyConfiguration

Get the policy parameters.

getPhysicalResource() - Method in class org.apache.hadoop.yarn.server.api.protocolrecords.impl.pb.RegisterNodeManagerRequestPBImpl

getPhysicalResource() - Method in class org.apache.hadoop.yarn.server.api.protocolrecords.RegisterNodeManagerRequest

Get the physical resources in the node to properly estimate resource utilization.

getPoliciesConfigs() - Method in class org.apache.hadoop.yarn.server.federation.store.records.GetSubClusterPoliciesConfigurationsResponse

Get all the policies configured in the system.

getPoliciesConfigs() - Method in class org.apache.hadoop.yarn.server.federation.store.records.impl.pb.GetSubClusterPoliciesConfigurationsResponsePBImpl

getPoliciesConfigurations(GetSubClusterPoliciesConfigurationsRequest) - Method in interface org.apache.hadoop.yarn.server.federation.store.FederationPolicyStore

Get a map of all queue-to-policy configurations.

getPoliciesConfigurations(GetSubClusterPoliciesConfigurationsRequest) - Method in class org.apache.hadoop.yarn.server.federation.store.impl.MemoryFederationStateStore

getPoliciesConfigurations(GetSubClusterPoliciesConfigurationsRequest) - Method in class org.apache.hadoop.yarn.server.federation.store.impl.SQLFederationStateStore

getPoliciesConfigurations(GetSubClusterPoliciesConfigurationsRequest) - Method in class org.apache.hadoop.yarn.server.federation.store.impl.ZookeeperFederationStateStore

getPoliciesConfigurations() - Method in class org.apache.hadoop.yarn.server.federation.utils.FederationStateStoreFacade

Get the policies that is represented as SubClusterPolicyConfiguration for all currently active queues in the system.

getPolicyConfiguration(GetSubClusterPolicyConfigurationRequest) - Method in interface org.apache.hadoop.yarn.server.federation.store.FederationPolicyStore

Get the policy configuration for a given queue.

getPolicyConfiguration(GetSubClusterPolicyConfigurationRequest) - Method in class org.apache.hadoop.yarn.server.federation.store.impl.MemoryFederationStateStore

getPolicyConfiguration(GetSubClusterPolicyConfigurationRequest) - Method in class org.apache.hadoop.yarn.server.federation.store.impl.SQLFederationStateStore

getPolicyConfiguration(GetSubClusterPolicyConfigurationRequest) - Method in class org.apache.hadoop.yarn.server.federation.store.impl.ZookeeperFederationStateStore

getPolicyConfiguration() - Method in class org.apache.hadoop.yarn.server.federation.store.records.GetSubClusterPolicyConfigurationResponse

Get the policy configuration.

getPolicyConfiguration() - Method in class org.apache.hadoop.yarn.server.federation.store.records.impl.pb.GetSubClusterPolicyConfigurationResponsePBImpl

getPolicyConfiguration() - Method in class org.apache.hadoop.yarn.server.federation.store.records.impl.pb.SetSubClusterPolicyConfigurationRequestPBImpl

getPolicyConfiguration() - Method in class org.apache.hadoop.yarn.server.federation.store.records.SetSubClusterPolicyConfigurationRequest

Get the policy configuration assigned to the queue.

getPolicyConfiguration(String) - Method in class org.apache.hadoop.yarn.server.federation.utils.FederationStateStoreFacade

Returns the SubClusterPolicyConfiguration for the specified queue.

getPolicyContext() - Method in class org.apache.hadoop.yarn.server.federation.policies.AbstractConfigurableFederationPolicy

Getter method for the FederationPolicyInitializationContext.

getPolicyInfo() - Method in class org.apache.hadoop.yarn.server.federation.policies.AbstractConfigurableFederationPolicy

Getter method for the configuration weights.

getPriority() - Method in class org.apache.hadoop.yarn.server.api.protocolrecords.impl.pb.NMContainerStatusPBImpl

getPriority() - Method in class org.apache.hadoop.yarn.server.api.protocolrecords.NMContainerStatus

Get the Priority of the request.

getPriority() - Method in class org.apache.hadoop.yarn.server.scheduler.SchedulerRequestKey

Get the Priority of the request.

getPriority() - Method in class org.apache.hadoop.yarn.server.webapp.dao.AppInfo

getPriority() - Method in class org.apache.hadoop.yarn.server.webapp.dao.ContainerInfo

getProgress() - Method in class org.apache.hadoop.yarn.server.webapp.dao.AppInfo

getProto() - Method in class org.apache.hadoop.yarn.server.api.protocolrecords.impl.pb.DistributedSchedulingAllocateRequestPBImpl

getProto() - Method in class org.apache.hadoop.yarn.server.api.protocolrecords.impl.pb.DistributedSchedulingAllocateResponsePBImpl

getProto() - Method in class org.apache.hadoop.yarn.server.api.protocolrecords.impl.pb.GetTimelineCollectorContextRequestPBImpl

getProto() - Method in class org.apache.hadoop.yarn.server.api.protocolrecords.impl.pb.GetTimelineCollectorContextResponsePBImpl

getProto() - Method in class org.apache.hadoop.yarn.server.api.protocolrecords.impl.pb.LogAggregationReportPBImpl

getProto() - Method in class org.apache.hadoop.yarn.server.api.protocolrecords.impl.pb.NMContainerStatusPBImpl

getProto() - Method in class org.apache.hadoop.yarn.server.api.protocolrecords.impl.pb.NodeHeartbeatRequestPBImpl

getProto() - Method in class org.apache.hadoop.yarn.server.api.protocolrecords.impl.pb.NodeHeartbeatResponsePBImpl

getProto() - Method in class org.apache.hadoop.yarn.server.api.protocolrecords.impl.pb.RegisterDistributedSchedulingAMResponsePBImpl

getProto() - Method in class org.apache.hadoop.yarn.server.api.protocolrecords.impl.pb.RegisterNodeManagerRequestPBImpl

getProto() - Method in class org.apache.hadoop.yarn.server.api.protocolrecords.impl.pb.RegisterNodeManagerResponsePBImpl

getProto() - Method in class org.apache.hadoop.yarn.server.api.protocolrecords.impl.pb.RemoteNodePBImpl

getProto() - Method in class org.apache.hadoop.yarn.server.api.protocolrecords.impl.pb.ReportNewCollectorInfoRequestPBImpl

getProto() - Method in class org.apache.hadoop.yarn.server.api.protocolrecords.impl.pb.ReportNewCollectorInfoResponsePBImpl

getProto() - Method in class org.apache.hadoop.yarn.server.api.protocolrecords.impl.pb.SCMUploaderCanUploadRequestPBImpl

getProto() - Method in class org.apache.hadoop.yarn.server.api.protocolrecords.impl.pb.SCMUploaderCanUploadResponsePBImpl

getProto() - Method in class org.apache.hadoop.yarn.server.api.protocolrecords.impl.pb.SCMUploaderNotifyRequestPBImpl

getProto() - Method in class org.apache.hadoop.yarn.server.api.protocolrecords.impl.pb.SCMUploaderNotifyResponsePBImpl

getProto() - Method in class org.apache.hadoop.yarn.server.api.protocolrecords.impl.pb.UnRegisterNodeManagerRequestPBImpl

getProto() - Method in class org.apache.hadoop.yarn.server.api.protocolrecords.impl.pb.UnRegisterNodeManagerResponsePBImpl

getProto() - Method in class org.apache.hadoop.yarn.server.api.records.impl.pb.AppCollectorDataPBImpl

getProto() - Method in class org.apache.hadoop.yarn.server.api.records.impl.pb.ContainerQueuingLimitPBImpl

getProto() - Method in class org.apache.hadoop.yarn.server.api.records.impl.pb.MasterKeyPBImpl

getProto() - Method in class org.apache.hadoop.yarn.server.api.records.impl.pb.NodeHealthStatusPBImpl

getProto() - Method in class org.apache.hadoop.yarn.server.api.records.impl.pb.NodeStatusPBImpl

getProto() - Method in class org.apache.hadoop.yarn.server.api.records.impl.pb.OpportunisticContainersStatusPBImpl

getProto() - Method in class org.apache.hadoop.yarn.server.federation.store.records.impl.pb.AddApplicationHomeSubClusterRequestPBImpl

getProto() - Method in class org.apache.hadoop.yarn.server.federation.store.records.impl.pb.AddApplicationHomeSubClusterResponsePBImpl

getProto() - Method in class org.apache.hadoop.yarn.server.federation.store.records.impl.pb.ApplicationHomeSubClusterPBImpl

getProto() - Method in class org.apache.hadoop.yarn.server.federation.store.records.impl.pb.DeleteApplicationHomeSubClusterRequestPBImpl

getProto() - Method in class org.apache.hadoop.yarn.server.federation.store.records.impl.pb.DeleteApplicationHomeSubClusterResponsePBImpl

getProto() - Method in class org.apache.hadoop.yarn.server.federation.store.records.impl.pb.GetApplicationHomeSubClusterRequestPBImpl

getProto() - Method in class org.apache.hadoop.yarn.server.federation.store.records.impl.pb.GetApplicationHomeSubClusterResponsePBImpl

getProto() - Method in class org.apache.hadoop.yarn.server.federation.store.records.impl.pb.GetApplicationsHomeSubClusterRequestPBImpl

getProto() - Method in class org.apache.hadoop.yarn.server.federation.store.records.impl.pb.GetApplicationsHomeSubClusterResponsePBImpl

getProto() - Method in class org.apache.hadoop.yarn.server.federation.store.records.impl.pb.GetSubClusterInfoRequestPBImpl

getProto() - Method in class org.apache.hadoop.yarn.server.federation.store.records.impl.pb.GetSubClusterInfoResponsePBImpl

getProto() - Method in class org.apache.hadoop.yarn.server.federation.store.records.impl.pb.GetSubClusterPoliciesConfigurationsRequestPBImpl

getProto() - Method in class org.apache.hadoop.yarn.server.federation.store.records.impl.pb.GetSubClusterPoliciesConfigurationsResponsePBImpl

getProto() - Method in class org.apache.hadoop.yarn.server.federation.store.records.impl.pb.GetSubClusterPolicyConfigurationRequestPBImpl

getProto() - Method in class org.apache.hadoop.yarn.server.federation.store.records.impl.pb.GetSubClusterPolicyConfigurationResponsePBImpl

getProto() - Method in class org.apache.hadoop.yarn.server.federation.store.records.impl.pb.GetSubClustersInfoRequestPBImpl

getProto() - Method in class org.apache.hadoop.yarn.server.federation.store.records.impl.pb.GetSubClustersInfoResponsePBImpl

getProto() - Method in class org.apache.hadoop.yarn.server.federation.store.records.impl.pb.SetSubClusterPolicyConfigurationRequestPBImpl

getProto() - Method in class org.apache.hadoop.yarn.server.federation.store.records.impl.pb.SetSubClusterPolicyConfigurationResponsePBImpl

getProto() - Method in class org.apache.hadoop.yarn.server.federation.store.records.impl.pb.SubClusterDeregisterRequestPBImpl

getProto() - Method in class org.apache.hadoop.yarn.server.federation.store.records.impl.pb.SubClusterDeregisterResponsePBImpl

getProto() - Method in class org.apache.hadoop.yarn.server.federation.store.records.impl.pb.SubClusterHeartbeatRequestPBImpl

getProto() - Method in class org.apache.hadoop.yarn.server.federation.store.records.impl.pb.SubClusterHeartbeatResponsePBImpl

getProto() - Method in class org.apache.hadoop.yarn.server.federation.store.records.impl.pb.SubClusterIdPBImpl

getProto() - Method in class org.apache.hadoop.yarn.server.federation.store.records.impl.pb.SubClusterInfoPBImpl

getProto() - Method in class org.apache.hadoop.yarn.server.federation.store.records.impl.pb.SubClusterPolicyConfigurationPBImpl

getProto() - Method in class org.apache.hadoop.yarn.server.federation.store.records.impl.pb.SubClusterRegisterRequestPBImpl

getProto() - Method in class org.apache.hadoop.yarn.server.federation.store.records.impl.pb.SubClusterRegisterResponsePBImpl

getProto() - Method in class org.apache.hadoop.yarn.server.federation.store.records.impl.pb.UpdateApplicationHomeSubClusterRequestPBImpl

getProto() - Method in class org.apache.hadoop.yarn.server.federation.store.records.impl.pb.UpdateApplicationHomeSubClusterResponsePBImpl

getProto() - Method in class org.apache.hadoop.yarn.server.records.impl.pb.VersionPBImpl

getProxy() - Method in class org.apache.hadoop.yarn.server.federation.failover.FederationRMFailoverProxyProvider

getQueue() - Method in class org.apache.hadoop.yarn.server.federation.policies.manager.AbstractPolicyManager

getQueue() - Method in interface org.apache.hadoop.yarn.server.federation.policies.manager.FederationPolicyManager

This method returns the queue this policy is configured for.

getQueue() - Method in class org.apache.hadoop.yarn.server.federation.store.records.GetSubClusterPolicyConfigurationRequest

Get the name of the queue for which we are requesting a policy configuration.

getQueue() - Method in class org.apache.hadoop.yarn.server.federation.store.records.impl.pb.GetSubClusterPolicyConfigurationRequestPBImpl

getQueue() - Method in class org.apache.hadoop.yarn.server.federation.store.records.impl.pb.SubClusterPolicyConfigurationPBImpl

getQueue() - Method in class org.apache.hadoop.yarn.server.federation.store.records.SubClusterPolicyConfiguration

Get the name of the queue for which we are configuring a policy.

getQueue() - Method in class org.apache.hadoop.yarn.server.webapp.dao.AppInfo

getQueuedOpportContainers() - Method in class org.apache.hadoop.yarn.server.api.records.impl.pb.OpportunisticContainersStatusPBImpl

getQueuedOpportContainers() - Method in class org.apache.hadoop.yarn.server.api.records.OpportunisticContainersStatus

Returns the number of queued opportunistic containers on the node.

getRackName() - Method in class org.apache.hadoop.yarn.server.api.protocolrecords.impl.pb.RemoteNodePBImpl

getRackName() - Method in class org.apache.hadoop.yarn.server.api.protocolrecords.RemoteNode

Get Rack Name.

getRackToSubClusters() - Method in class org.apache.hadoop.yarn.server.federation.resolver.AbstractSubClusterResolver

getRegisteringCollectors() - Method in class org.apache.hadoop.yarn.server.api.protocolrecords.impl.pb.NodeHeartbeatRequestPBImpl

getRegisteringCollectors() - Method in class org.apache.hadoop.yarn.server.api.protocolrecords.NodeHeartbeatRequest

getRegisterResponse() - Method in class org.apache.hadoop.yarn.server.api.protocolrecords.impl.pb.RegisterDistributedSchedulingAMResponsePBImpl

getRegisterResponse() - Method in class org.apache.hadoop.yarn.server.api.protocolrecords.RegisterDistributedSchedulingAMResponse

getRequest() - Method in class org.apache.hadoop.yarn.server.uam.UnmanagedApplicationManager.AsyncAllocateRequestInfo

getRequestQueueSize() - Method in class org.apache.hadoop.yarn.server.uam.UnmanagedApplicationManager

getReservedCpuVcores() - Method in class org.apache.hadoop.yarn.server.webapp.dao.AppInfo

getReservedMemoryMB() - Method in class org.apache.hadoop.yarn.server.webapp.dao.AppInfo

getResource() - Method in class org.apache.hadoop.yarn.server.api.protocolrecords.impl.pb.NodeHeartbeatResponsePBImpl

getResource() - Method in class org.apache.hadoop.yarn.server.api.protocolrecords.impl.pb.RegisterNodeManagerRequestPBImpl

getResource() - Method in class org.apache.hadoop.yarn.server.api.protocolrecords.impl.pb.RegisterNodeManagerResponsePBImpl

getResource() - Method in class org.apache.hadoop.yarn.server.api.protocolrecords.NodeHeartbeatResponse

getResource() - Method in class org.apache.hadoop.yarn.server.api.protocolrecords.RegisterNodeManagerRequest

getResource() - Method in class org.apache.hadoop.yarn.server.api.protocolrecords.RegisterNodeManagerResponse

getResourceKey() - Method in class org.apache.hadoop.yarn.server.api.protocolrecords.impl.pb.SCMUploaderCanUploadRequestPBImpl

getResourceKey() - Method in class org.apache.hadoop.yarn.server.api.protocolrecords.impl.pb.SCMUploaderNotifyRequestPBImpl

getResourceKey() - Method in class org.apache.hadoop.yarn.server.api.protocolrecords.SCMUploaderCanUploadRequest

Get the key of the resource that would be uploaded to the shared cache.

getResourceKey() - Method in class org.apache.hadoop.yarn.server.api.protocolrecords.SCMUploaderNotifyRequest

Get the key of the resource that was just uploaded to the shared cache.

getResponseId() - Method in class org.apache.hadoop.yarn.server.api.protocolrecords.impl.pb.NodeHeartbeatResponsePBImpl

getResponseId() - Method in class org.apache.hadoop.yarn.server.api.protocolrecords.NodeHeartbeatResponse

getResponseId() - Method in class org.apache.hadoop.yarn.server.api.records.impl.pb.NodeStatusPBImpl

getResponseId() - Method in class org.apache.hadoop.yarn.server.api.records.NodeStatus

getRMAddress(YarnConfiguration, Class<?>) - Method in class org.apache.hadoop.yarn.server.api.ServerRMProxy

getRMAdminServiceAddress() - Method in class org.apache.hadoop.yarn.server.federation.store.records.impl.pb.SubClusterInfoPBImpl

getRMAdminServiceAddress() - Method in class org.apache.hadoop.yarn.server.federation.store.records.SubClusterInfo

Get the URL of the ResourceManager administration service.

getRMIdentifier() - Method in class org.apache.hadoop.yarn.server.api.protocolrecords.impl.pb.RegisterNodeManagerResponsePBImpl

getRMIdentifier() - Method in class org.apache.hadoop.yarn.server.api.protocolrecords.RegisterNodeManagerResponse

getRMIdentifier() - Method in class org.apache.hadoop.yarn.server.api.records.AppCollectorData

getRMIdentifier() - Method in class org.apache.hadoop.yarn.server.api.records.impl.pb.AppCollectorDataPBImpl

getRMVersion() - Method in class org.apache.hadoop.yarn.server.api.protocolrecords.impl.pb.RegisterNodeManagerResponsePBImpl

getRMVersion() - Method in class org.apache.hadoop.yarn.server.api.protocolrecords.RegisterNodeManagerResponse

getRMWebServiceAddress() - Method in class org.apache.hadoop.yarn.server.federation.store.records.impl.pb.SubClusterInfoPBImpl

getRMWebServiceAddress() - Method in class org.apache.hadoop.yarn.server.federation.store.records.SubClusterInfo

Get the URL of the ResourceManager web application interface.

getRouterPolicy(FederationPolicyInitializationContext, FederationRouterPolicy) - Method in class org.apache.hadoop.yarn.server.federation.policies.manager.AbstractPolicyManager

This default implementation validates the FederationPolicyInitializationContext, then checks whether it needs to reinstantiate the class (null or mismatching type), and reinitialize the policy.

getRouterPolicy(FederationPolicyInitializationContext, FederationRouterPolicy) - Method in interface org.apache.hadoop.yarn.server.federation.policies.manager.FederationPolicyManager

If the current instance is compatible, this method returns the same instance of FederationRouterPolicy reinitialized with the current context, otherwise a new instance initialized with the current context is provided.

getRouterPolicyWeights() - Method in class org.apache.hadoop.yarn.server.federation.policies.dao.WeightedPolicyInfo

Getter of the router weights.

getRpcPort() - Method in class org.apache.hadoop.yarn.server.webapp.dao.AppAttemptInfo

getRpcPort() - Method in class org.apache.hadoop.yarn.server.webapp.dao.AppInfo

getRunningApplications() - Method in class org.apache.hadoop.yarn.server.api.protocolrecords.impl.pb.RegisterNodeManagerRequestPBImpl

getRunningApplications() - Method in class org.apache.hadoop.yarn.server.api.protocolrecords.RegisterNodeManagerRequest

We introduce this here because currently YARN RM doesn't persist nodes info for application running.

getRunningContainers() - Method in class org.apache.hadoop.yarn.server.webapp.dao.AppInfo

getRunningOpportContainers() - Method in class org.apache.hadoop.yarn.server.api.records.impl.pb.OpportunisticContainersStatusPBImpl

getRunningOpportContainers() - Method in class org.apache.hadoop.yarn.server.api.records.OpportunisticContainersStatus

Returns the number of currently running opportunistic containers on the node.

getSecretKey() - Method in class org.apache.hadoop.yarn.server.security.MasterKeyData

getServiceData(String) - Method in class org.apache.hadoop.yarn.lib.ZKClient

get data published by the service at the registration address

getStartedTime() - Method in class org.apache.hadoop.yarn.server.webapp.dao.AppAttemptInfo

getStartedTime() - Method in class org.apache.hadoop.yarn.server.webapp.dao.AppInfo

getStartedTime() - Method in class org.apache.hadoop.yarn.server.webapp.dao.ContainerInfo

getState() - Method in class org.apache.hadoop.yarn.server.federation.store.records.impl.pb.SubClusterDeregisterRequestPBImpl

getState() - Method in class org.apache.hadoop.yarn.server.federation.store.records.impl.pb.SubClusterHeartbeatRequestPBImpl

getState() - Method in class org.apache.hadoop.yarn.server.federation.store.records.impl.pb.SubClusterInfoPBImpl

getState() - Method in class org.apache.hadoop.yarn.server.federation.store.records.SubClusterDeregisterRequest

Get the SubClusterState of the subcluster.

getState() - Method in class org.apache.hadoop.yarn.server.federation.store.records.SubClusterHeartbeatRequest

Get the SubClusterState of the subcluster.

getState() - Method in class org.apache.hadoop.yarn.server.federation.store.records.SubClusterInfo

Get the SubClusterState of the subcluster.

getSubCluster(GetSubClusterInfoRequest) - Method in interface org.apache.hadoop.yarn.server.federation.store.FederationMembershipStateStore

Get the membership information of subcluster as identified by SubClusterId.

getSubCluster(GetSubClusterInfoRequest) - Method in class org.apache.hadoop.yarn.server.federation.store.impl.MemoryFederationStateStore

getSubCluster(GetSubClusterInfoRequest) - Method in class org.apache.hadoop.yarn.server.federation.store.impl.SQLFederationStateStore

getSubCluster(GetSubClusterInfoRequest) - Method in class org.apache.hadoop.yarn.server.federation.store.impl.ZookeeperFederationStateStore

getSubCluster(SubClusterId) - Method in class org.apache.hadoop.yarn.server.federation.utils.FederationStateStoreFacade

Returns the SubClusterInfo for the specified SubClusterId.

getSubCluster(SubClusterId, boolean) - Method in class org.apache.hadoop.yarn.server.federation.utils.FederationStateStoreFacade

Updates the cache with the central FederationStateStore and returns the SubClusterInfo for the specified SubClusterId.

getSubClusterForNode(String) - Method in class org.apache.hadoop.yarn.server.federation.resolver.AbstractSubClusterResolver

getSubClusterForNode(String) - Method in class org.apache.hadoop.yarn.server.federation.resolver.DefaultSubClusterResolverImpl

getSubClusterForNode(String) - Method in interface org.apache.hadoop.yarn.server.federation.resolver.SubClusterResolver

Obtain the sub-cluster that a specified node belongs to.

getSubClusterId() - Method in class org.apache.hadoop.yarn.server.federation.store.records.GetSubClusterInfoRequest

Get the SubClusterId representing the unique identifier of the subcluster.

getSubClusterId() - Method in class org.apache.hadoop.yarn.server.federation.store.records.impl.pb.GetSubClusterInfoRequestPBImpl

getSubClusterId() - Method in class org.apache.hadoop.yarn.server.federation.store.records.impl.pb.SubClusterDeregisterRequestPBImpl

getSubClusterId() - Method in class org.apache.hadoop.yarn.server.federation.store.records.impl.pb.SubClusterHeartbeatRequestPBImpl

getSubClusterId() - Method in class org.apache.hadoop.yarn.server.federation.store.records.impl.pb.SubClusterInfoPBImpl

getSubClusterId() - Method in class org.apache.hadoop.yarn.server.federation.store.records.SubClusterDeregisterRequest

Get the SubClusterId representing the unique identifier of the subcluster.

getSubClusterId() - Method in class org.apache.hadoop.yarn.server.federation.store.records.SubClusterHeartbeatRequest

Get the SubClusterId representing the unique identifier of the subcluster.

getSubClusterId() - Method in class org.apache.hadoop.yarn.server.federation.store.records.SubClusterInfo

Get the SubClusterId representing the unique identifier of the subcluster.

getSubClusterInfo() - Method in class org.apache.hadoop.yarn.server.federation.store.records.GetSubClusterInfoResponse

Get the SubClusterInfo encapsulating the information about the sub-cluster.

getSubClusterInfo() - Method in class org.apache.hadoop.yarn.server.federation.store.records.impl.pb.GetSubClusterInfoResponsePBImpl

getSubClusterInfo() - Method in class org.apache.hadoop.yarn.server.federation.store.records.impl.pb.SubClusterRegisterRequestPBImpl

getSubClusterInfo() - Method in class org.apache.hadoop.yarn.server.federation.store.records.SubClusterRegisterRequest

Get the SubClusterInfo encapsulating the information about the sub-cluster.

GetSubClusterInfoRequest - Class in org.apache.hadoop.yarn.server.federation.store.records

Request class to obtain information about a sub-cluster identified by its SubClusterId.

GetSubClusterInfoRequest() - Constructor for class org.apache.hadoop.yarn.server.federation.store.records.GetSubClusterInfoRequest

GetSubClusterInfoRequestPBImpl - Class in org.apache.hadoop.yarn.server.federation.store.records.impl.pb

Protocol buffer based implementation of GetSubClusterInfoRequest.

GetSubClusterInfoRequestPBImpl() - Constructor for class org.apache.hadoop.yarn.server.federation.store.records.impl.pb.GetSubClusterInfoRequestPBImpl

GetSubClusterInfoRequestPBImpl(YarnServerFederationProtos.GetSubClusterInfoRequestProto) - Constructor for class org.apache.hadoop.yarn.server.federation.store.records.impl.pb.GetSubClusterInfoRequestPBImpl

GetSubClusterInfoResponse - Class in org.apache.hadoop.yarn.server.federation.store.records

Response to a query with SubClusterInfo about a sub-cluster.

GetSubClusterInfoResponse() - Constructor for class org.apache.hadoop.yarn.server.federation.store.records.GetSubClusterInfoResponse

GetSubClusterInfoResponsePBImpl - Class in org.apache.hadoop.yarn.server.federation.store.records.impl.pb

Protocol buffer based implementation of GetSubClusterInfoResponse.

GetSubClusterInfoResponsePBImpl() - Constructor for class org.apache.hadoop.yarn.server.federation.store.records.impl.pb.GetSubClusterInfoResponsePBImpl

GetSubClusterInfoResponsePBImpl(YarnServerFederationProtos.GetSubClusterInfoResponseProto) - Constructor for class org.apache.hadoop.yarn.server.federation.store.records.impl.pb.GetSubClusterInfoResponsePBImpl

GetSubClusterPoliciesConfigurationsRequest - Class in org.apache.hadoop.yarn.server.federation.store.records

GetSubClusterPoliciesConfigurationsRequest is a request to the FederationPolicyStore to obtain all policy configurations.

GetSubClusterPoliciesConfigurationsRequest() - Constructor for class org.apache.hadoop.yarn.server.federation.store.records.GetSubClusterPoliciesConfigurationsRequest

GetSubClusterPoliciesConfigurationsRequestPBImpl - Class in org.apache.hadoop.yarn.server.federation.store.records.impl.pb

Protocol buffer based implementation of GetSubClusterPoliciesConfigurationsRequest.

GetSubClusterPoliciesConfigurationsRequestPBImpl() - Constructor for class org.apache.hadoop.yarn.server.federation.store.records.impl.pb.GetSubClusterPoliciesConfigurationsRequestPBImpl

GetSubClusterPoliciesConfigurationsRequestPBImpl(YarnServerFederationProtos.GetSubClusterPoliciesConfigurationsRequestProto) - Constructor for class org.apache.hadoop.yarn.server.federation.store.records.impl.pb.GetSubClusterPoliciesConfigurationsRequestPBImpl

GetSubClusterPoliciesConfigurationsResponse - Class in org.apache.hadoop.yarn.server.federation.store.records

GetSubClusterPolicyConfigurationResponse contains the answer from the FederationPolicyStore to a request to get all the policies configured in the system via a SubClusterPolicyConfiguration.

GetSubClusterPoliciesConfigurationsResponse() - Constructor for class org.apache.hadoop.yarn.server.federation.store.records.GetSubClusterPoliciesConfigurationsResponse

GetSubClusterPoliciesConfigurationsResponsePBImpl - Class in org.apache.hadoop.yarn.server.federation.store.records.impl.pb

Protocol buffer based implementation of GetSubClusterPoliciesConfigurationsResponse.

GetSubClusterPoliciesConfigurationsResponsePBImpl() - Constructor for class org.apache.hadoop.yarn.server.federation.store.records.impl.pb.GetSubClusterPoliciesConfigurationsResponsePBImpl

GetSubClusterPoliciesConfigurationsResponsePBImpl(YarnServerFederationProtos.GetSubClusterPoliciesConfigurationsResponseProto) - Constructor for class org.apache.hadoop.yarn.server.federation.store.records.impl.pb.GetSubClusterPoliciesConfigurationsResponsePBImpl

getSubClusterPolicyConfiguration() - Method in class org.apache.hadoop.yarn.server.federation.policies.FederationPolicyInitializationContext

Getter for the SubClusterPolicyConfiguration.

GetSubClusterPolicyConfigurationRequest - Class in org.apache.hadoop.yarn.server.federation.store.records

GetSubClusterPolicyConfigurationRequest is a request to the FederationPolicyStore to get the configuration of a policy for a given queue.

GetSubClusterPolicyConfigurationRequest() - Constructor for class org.apache.hadoop.yarn.server.federation.store.records.GetSubClusterPolicyConfigurationRequest

GetSubClusterPolicyConfigurationRequestPBImpl - Class in org.apache.hadoop.yarn.server.federation.store.records.impl.pb

Protocol buffer based implementation of GetSubClusterPolicyConfigurationRequest.

GetSubClusterPolicyConfigurationRequestPBImpl() - Constructor for class org.apache.hadoop.yarn.server.federation.store.records.impl.pb.GetSubClusterPolicyConfigurationRequestPBImpl

GetSubClusterPolicyConfigurationRequestPBImpl(YarnServerFederationProtos.GetSubClusterPolicyConfigurationRequestProto) - Constructor for class org.apache.hadoop.yarn.server.federation.store.records.impl.pb.GetSubClusterPolicyConfigurationRequestPBImpl

GetSubClusterPolicyConfigurationResponse - Class in org.apache.hadoop.yarn.server.federation.store.records

GetSubClusterPolicyConfigurationResponse contains the answer from the FederationPolicyStore to a request to get the information about how a policy should be configured via a SubClusterPolicyConfiguration.

GetSubClusterPolicyConfigurationResponse() - Constructor for class org.apache.hadoop.yarn.server.federation.store.records.GetSubClusterPolicyConfigurationResponse

GetSubClusterPolicyConfigurationResponsePBImpl - Class in org.apache.hadoop.yarn.server.federation.store.records.impl.pb

Protocol buffer based implementation of GetSubClusterPolicyConfigurationResponse.

GetSubClusterPolicyConfigurationResponsePBImpl() - Constructor for class org.apache.hadoop.yarn.server.federation.store.records.impl.pb.GetSubClusterPolicyConfigurationResponsePBImpl

GetSubClusterPolicyConfigurationResponsePBImpl(YarnServerFederationProtos.GetSubClusterPolicyConfigurationResponseProto) - Constructor for class org.apache.hadoop.yarn.server.federation.store.records.impl.pb.GetSubClusterPolicyConfigurationResponsePBImpl

getSubClusterResolver() - Method in class org.apache.hadoop.yarn.server.federation.utils.FederationStateStoreFacade

Get the singleton instance of SubClusterResolver.

getSubClusters(GetSubClustersInfoRequest) - Method in interface org.apache.hadoop.yarn.server.federation.store.FederationMembershipStateStore

Get the membership information of all the subclusters that are currently participating in federation.

getSubClusters(GetSubClustersInfoRequest) - Method in class org.apache.hadoop.yarn.server.federation.store.impl.MemoryFederationStateStore

getSubClusters(GetSubClustersInfoRequest) - Method in class org.apache.hadoop.yarn.server.federation.store.impl.SQLFederationStateStore

getSubClusters(GetSubClustersInfoRequest) - Method in class org.apache.hadoop.yarn.server.federation.store.impl.ZookeeperFederationStateStore

getSubClusters() - Method in class org.apache.hadoop.yarn.server.federation.store.records.GetSubClustersInfoResponse

Get the list of SubClusterInfo representing the information about all sub-clusters that are currently participating in Federation.

getSubClusters() - Method in class org.apache.hadoop.yarn.server.federation.store.records.impl.pb.GetSubClustersInfoResponsePBImpl

getSubClusters(boolean) - Method in class org.apache.hadoop.yarn.server.federation.utils.FederationStateStoreFacade

Returns the SubClusterInfo of all active sub cluster(s).

getSubClustersForRack(String) - Method in class org.apache.hadoop.yarn.server.federation.resolver.AbstractSubClusterResolver

getSubClustersForRack(String) - Method in class org.apache.hadoop.yarn.server.federation.resolver.DefaultSubClusterResolverImpl

getSubClustersForRack(String) - Method in interface org.apache.hadoop.yarn.server.federation.resolver.SubClusterResolver

Obtain the sub-clusters that have nodes on a specified rack.

GetSubClustersInfoRequest - Class in org.apache.hadoop.yarn.server.federation.store.records

Request class to obtain information about all sub-clusters that are participating in federation.

GetSubClustersInfoRequest() - Constructor for class org.apache.hadoop.yarn.server.federation.store.records.GetSubClustersInfoRequest

GetSubClustersInfoRequestPBImpl - Class in org.apache.hadoop.yarn.server.federation.store.records.impl.pb

Protocol buffer based implementation of GetSubClustersInfoRequest.

GetSubClustersInfoRequestPBImpl() - Constructor for class org.apache.hadoop.yarn.server.federation.store.records.impl.pb.GetSubClustersInfoRequestPBImpl

GetSubClustersInfoRequestPBImpl(YarnServerFederationProtos.GetSubClustersInfoRequestProto) - Constructor for class org.apache.hadoop.yarn.server.federation.store.records.impl.pb.GetSubClustersInfoRequestPBImpl

GetSubClustersInfoResponse - Class in org.apache.hadoop.yarn.server.federation.store.records

Response to a query with list of SubClusterInfo about all sub-clusters that are currently participating in Federation.

GetSubClustersInfoResponse() - Constructor for class org.apache.hadoop.yarn.server.federation.store.records.GetSubClustersInfoResponse

GetSubClustersInfoResponsePBImpl - Class in org.apache.hadoop.yarn.server.federation.store.records.impl.pb

Protocol buffer based implementation of GetSubClustersInfoResponse.

GetSubClustersInfoResponsePBImpl() - Constructor for class org.apache.hadoop.yarn.server.federation.store.records.impl.pb.GetSubClustersInfoResponsePBImpl

GetSubClustersInfoResponsePBImpl(YarnServerFederationProtos.GetSubClustersInfoResponseProto) - Constructor for class org.apache.hadoop.yarn.server.federation.store.records.impl.pb.GetSubClustersInfoResponsePBImpl

getSubmittedTime() - Method in class org.apache.hadoop.yarn.server.webapp.dao.AppInfo

getSystemCredentialsForApps() - Method in class org.apache.hadoop.yarn.server.api.protocolrecords.impl.pb.NodeHeartbeatResponsePBImpl

getSystemCredentialsForApps() - Method in class org.apache.hadoop.yarn.server.api.protocolrecords.NodeHeartbeatResponse

getTimelineCollectorContext(GetTimelineCollectorContextRequest) - Method in interface org.apache.hadoop.yarn.server.api.CollectorNodemanagerProtocol

The collector needs to get the context information including user, flow and flow run ID to associate with every incoming put-entity requests.

getTimelineCollectorContext(GetTimelineCollectorContextRequest) - Method in class org.apache.hadoop.yarn.server.api.impl.pb.client.CollectorNodemanagerProtocolPBClientImpl

getTimelineCollectorContext(RpcController, YarnServerCommonServiceProtos.GetTimelineCollectorContextRequestProto) - Method in class org.apache.hadoop.yarn.server.api.impl.pb.service.CollectorNodemanagerProtocolPBServiceImpl

GetTimelineCollectorContextRequest - Class in org.apache.hadoop.yarn.server.api.protocolrecords

GetTimelineCollectorContextRequest() - Constructor for class org.apache.hadoop.yarn.server.api.protocolrecords.GetTimelineCollectorContextRequest

GetTimelineCollectorContextRequestPBImpl - Class in org.apache.hadoop.yarn.server.api.protocolrecords.impl.pb

GetTimelineCollectorContextRequestPBImpl() - Constructor for class org.apache.hadoop.yarn.server.api.protocolrecords.impl.pb.GetTimelineCollectorContextRequestPBImpl

GetTimelineCollectorContextRequestPBImpl(YarnServerCommonServiceProtos.GetTimelineCollectorContextRequestProto) - Constructor for class org.apache.hadoop.yarn.server.api.protocolrecords.impl.pb.GetTimelineCollectorContextRequestPBImpl

GetTimelineCollectorContextResponse - Class in org.apache.hadoop.yarn.server.api.protocolrecords

GetTimelineCollectorContextResponse() - Constructor for class org.apache.hadoop.yarn.server.api.protocolrecords.GetTimelineCollectorContextResponse

GetTimelineCollectorContextResponsePBImpl - Class in org.apache.hadoop.yarn.server.api.protocolrecords.impl.pb

GetTimelineCollectorContextResponsePBImpl() - Constructor for class org.apache.hadoop.yarn.server.api.protocolrecords.impl.pb.GetTimelineCollectorContextResponsePBImpl

GetTimelineCollectorContextResponsePBImpl(YarnServerCommonServiceProtos.GetTimelineCollectorContextResponseProto) - Constructor for class org.apache.hadoop.yarn.server.api.protocolrecords.impl.pb.GetTimelineCollectorContextResponsePBImpl

getTimelineDelegationTokenSecretManager() - Method in class org.apache.hadoop.yarn.server.timeline.security.TimelineDelgationTokenSecretManagerService

getTokenInfo(Class<?>, Configuration) - Method in class org.apache.hadoop.yarn.server.RMNMSecurityInfoClass

getTrackingUrl() - Method in class org.apache.hadoop.yarn.server.webapp.dao.AppAttemptInfo

getTrackingUrl() - Method in class org.apache.hadoop.yarn.server.webapp.dao.AppInfo

getType() - Method in class org.apache.hadoop.yarn.server.federation.store.records.impl.pb.SubClusterPolicyConfigurationPBImpl

getType() - Method in class org.apache.hadoop.yarn.server.federation.store.records.SubClusterPolicyConfiguration

Get the type of the policy.

getType() - Method in class org.apache.hadoop.yarn.server.webapp.dao.AppInfo

getUAMToken() - Method in class org.apache.hadoop.yarn.server.uam.UnmanagedApplicationManager

Gets the amrmToken of the unmanaged AM.

getUploadable() - Method in class org.apache.hadoop.yarn.server.api.protocolrecords.impl.pb.SCMUploaderCanUploadResponsePBImpl

getUploadable() - Method in class org.apache.hadoop.yarn.server.api.protocolrecords.SCMUploaderCanUploadResponse

Get whether or not the node manager can upload the resource to the shared cache.

getUser() - Method in class org.apache.hadoop.yarn.server.webapp.dao.AppInfo

getUser(HttpServletRequest) - Static method in class org.apache.hadoop.yarn.server.webapp.WebServices

getUserId() - Method in class org.apache.hadoop.yarn.server.api.protocolrecords.GetTimelineCollectorContextResponse

getUserId() - Method in class org.apache.hadoop.yarn.server.api.protocolrecords.impl.pb.GetTimelineCollectorContextResponsePBImpl

getVersion() - Method in class org.apache.hadoop.yarn.server.api.protocolrecords.impl.pb.NMContainerStatusPBImpl

getVersion() - Method in class org.apache.hadoop.yarn.server.api.protocolrecords.NMContainerStatus

getVersion() - Method in class org.apache.hadoop.yarn.server.api.records.AppCollectorData

getVersion() - Method in class org.apache.hadoop.yarn.server.api.records.impl.pb.AppCollectorDataPBImpl

getWaitQueueLength() - Method in class org.apache.hadoop.yarn.server.api.records.impl.pb.OpportunisticContainersStatusPBImpl

getWaitQueueLength() - Method in class org.apache.hadoop.yarn.server.api.records.OpportunisticContainersStatus

Returns the length of the containers queue on the node.

getWeightedPolicyInfo() - Method in class org.apache.hadoop.yarn.server.federation.policies.manager.PriorityBroadcastPolicyManager

getWeightedPolicyInfo() - Method in class org.apache.hadoop.yarn.server.federation.policies.manager.WeightedLocalityPolicyManager

getWeightedRandom(ArrayList<Float>) - Static method in class org.apache.hadoop.yarn.server.federation.policies.FederationPolicyUtils

Select a random bin according to the weight array for the bins.

H

handleNotRegisteredExceptionAndReRegister(ApplicationId, ApplicationMasterProtocol, RegisterApplicationMasterRequest) - Static method in class org.apache.hadoop.yarn.server.utils.AMRMClientUtils

Handle ApplicationNotRegistered exception and re-register.

happensBefore(AppCollectorData, AppCollectorData) - Static method in class org.apache.hadoop.yarn.server.api.records.AppCollectorData

Returns if a collector data item happens before another one.

hasAMContainer(ContainerId, Collection<ContainerReport>) - Method in class org.apache.hadoop.yarn.server.webapp.AppAttemptBlock

HashBasedRouterPolicy - Class in org.apache.hadoop.yarn.server.federation.policies.router

This FederationRouterPolicy pick a subcluster based on the hash of the job's queue name.

HashBasedRouterPolicy() - Constructor for class org.apache.hadoop.yarn.server.federation.policies.router.HashBasedRouterPolicy

HashBroadcastPolicyManager - Class in org.apache.hadoop.yarn.server.federation.policies.manager

Policy that routes applications via hashing of their queuename, and broadcast resource requests.

HashBroadcastPolicyManager() - Constructor for class org.apache.hadoop.yarn.server.federation.policies.manager.HashBroadcastPolicyManager

hashCode() - Method in class org.apache.hadoop.yarn.server.api.protocolrecords.impl.pb.GetTimelineCollectorContextRequestPBImpl

hashCode() - Method in class org.apache.hadoop.yarn.server.api.protocolrecords.impl.pb.GetTimelineCollectorContextResponsePBImpl

hashCode() - Method in class org.apache.hadoop.yarn.server.api.protocolrecords.impl.pb.LogAggregationReportPBImpl

hashCode() - Method in class org.apache.hadoop.yarn.server.api.protocolrecords.impl.pb.NMContainerStatusPBImpl

hashCode() - Method in class org.apache.hadoop.yarn.server.api.protocolrecords.impl.pb.NodeHeartbeatRequestPBImpl

hashCode() - Method in class org.apache.hadoop.yarn.server.api.protocolrecords.impl.pb.RegisterNodeManagerRequestPBImpl

hashCode() - Method in class org.apache.hadoop.yarn.server.api.protocolrecords.impl.pb.RemoteNodePBImpl

hashCode() - Method in class org.apache.hadoop.yarn.server.api.protocolrecords.impl.pb.ReportNewCollectorInfoRequestPBImpl

hashCode() - Method in class org.apache.hadoop.yarn.server.api.protocolrecords.impl.pb.ReportNewCollectorInfoResponsePBImpl

hashCode() - Method in class org.apache.hadoop.yarn.server.api.records.impl.pb.AppCollectorDataPBImpl

hashCode() - Method in class org.apache.hadoop.yarn.server.api.records.impl.pb.MasterKeyPBImpl

hashCode() - Method in class org.apache.hadoop.yarn.server.api.records.impl.pb.NodeHealthStatusPBImpl

hashCode() - Method in class org.apache.hadoop.yarn.server.api.records.impl.pb.NodeStatusPBImpl

hashCode() - Method in class org.apache.hadoop.yarn.server.federation.policies.dao.WeightedPolicyInfo

hashCode() - Method in class org.apache.hadoop.yarn.server.federation.store.records.ApplicationHomeSubCluster

hashCode() - Method in class org.apache.hadoop.yarn.server.federation.store.records.impl.pb.AddApplicationHomeSubClusterRequestPBImpl

hashCode() - Method in class org.apache.hadoop.yarn.server.federation.store.records.impl.pb.AddApplicationHomeSubClusterResponsePBImpl

hashCode() - Method in class org.apache.hadoop.yarn.server.federation.store.records.impl.pb.ApplicationHomeSubClusterPBImpl

hashCode() - Method in class org.apache.hadoop.yarn.server.federation.store.records.impl.pb.DeleteApplicationHomeSubClusterRequestPBImpl

hashCode() - Method in class org.apache.hadoop.yarn.server.federation.store.records.impl.pb.DeleteApplicationHomeSubClusterResponsePBImpl

hashCode() - Method in class org.apache.hadoop.yarn.server.federation.store.records.impl.pb.GetApplicationHomeSubClusterRequestPBImpl

hashCode() - Method in class org.apache.hadoop.yarn.server.federation.store.records.impl.pb.GetApplicationHomeSubClusterResponsePBImpl

hashCode() - Method in class org.apache.hadoop.yarn.server.federation.store.records.impl.pb.GetApplicationsHomeSubClusterRequestPBImpl

hashCode() - Method in class org.apache.hadoop.yarn.server.federation.store.records.impl.pb.GetApplicationsHomeSubClusterResponsePBImpl

hashCode() - Method in class org.apache.hadoop.yarn.server.federation.store.records.impl.pb.GetSubClusterInfoRequestPBImpl

hashCode() - Method in class org.apache.hadoop.yarn.server.federation.store.records.impl.pb.GetSubClusterInfoResponsePBImpl

hashCode() - Method in class org.apache.hadoop.yarn.server.federation.store.records.impl.pb.GetSubClusterPoliciesConfigurationsRequestPBImpl

hashCode() - Method in class org.apache.hadoop.yarn.server.federation.store.records.impl.pb.GetSubClusterPoliciesConfigurationsResponsePBImpl

hashCode() - Method in class org.apache.hadoop.yarn.server.federation.store.records.impl.pb.GetSubClusterPolicyConfigurationRequestPBImpl

hashCode() - Method in class org.apache.hadoop.yarn.server.federation.store.records.impl.pb.GetSubClusterPolicyConfigurationResponsePBImpl

hashCode() - Method in class org.apache.hadoop.yarn.server.federation.store.records.impl.pb.GetSubClustersInfoRequestPBImpl

hashCode() - Method in class org.apache.hadoop.yarn.server.federation.store.records.impl.pb.GetSubClustersInfoResponsePBImpl

hashCode() - Method in class org.apache.hadoop.yarn.server.federation.store.records.impl.pb.SetSubClusterPolicyConfigurationRequestPBImpl

hashCode() - Method in class org.apache.hadoop.yarn.server.federation.store.records.impl.pb.SetSubClusterPolicyConfigurationResponsePBImpl

hashCode() - Method in class org.apache.hadoop.yarn.server.federation.store.records.impl.pb.SubClusterDeregisterRequestPBImpl

hashCode() - Method in class org.apache.hadoop.yarn.server.federation.store.records.impl.pb.SubClusterDeregisterResponsePBImpl

hashCode() - Method in class org.apache.hadoop.yarn.server.federation.store.records.impl.pb.SubClusterHeartbeatRequestPBImpl

hashCode() - Method in class org.apache.hadoop.yarn.server.federation.store.records.impl.pb.SubClusterHeartbeatResponsePBImpl

hashCode() - Method in class org.apache.hadoop.yarn.server.federation.store.records.impl.pb.SubClusterPolicyConfigurationPBImpl

hashCode() - Method in class org.apache.hadoop.yarn.server.federation.store.records.impl.pb.SubClusterRegisterRequestPBImpl

hashCode() - Method in class org.apache.hadoop.yarn.server.federation.store.records.impl.pb.SubClusterRegisterResponsePBImpl

hashCode() - Method in class org.apache.hadoop.yarn.server.federation.store.records.impl.pb.UpdateApplicationHomeSubClusterRequestPBImpl

hashCode() - Method in class org.apache.hadoop.yarn.server.federation.store.records.impl.pb.UpdateApplicationHomeSubClusterResponsePBImpl

hashCode() - Method in class org.apache.hadoop.yarn.server.federation.store.records.SubClusterId

hashCode() - Method in class org.apache.hadoop.yarn.server.federation.store.records.SubClusterIdInfo

hashCode() - Method in class org.apache.hadoop.yarn.server.federation.store.records.SubClusterInfo

hashCode() - Method in class org.apache.hadoop.yarn.server.federation.store.records.SubClusterPolicyConfiguration

hashCode() - Method in class org.apache.hadoop.yarn.server.records.Version

hashCode() - Method in class org.apache.hadoop.yarn.server.scheduler.SchedulerRequestKey

hasNext() - Method in class org.apache.hadoop.yarn.server.utils.LeveldbIterator

Returns true if the iteration has more elements.

hasPrev() - Method in class org.apache.hadoop.yarn.server.utils.LeveldbIterator

hasUAMId(String) - Method in class org.apache.hadoop.yarn.server.uam.UnmanagedAMPoolManager

Return whether an UAM exists.

HeartBeatThreadUncaughtExceptionHandler() - Constructor for class org.apache.hadoop.yarn.server.uam.UnmanagedApplicationManager.HeartBeatThreadUncaughtExceptionHandler

host - Variable in class org.apache.hadoop.yarn.server.webapp.dao.AppAttemptInfo

host - Variable in class org.apache.hadoop.yarn.server.webapp.dao.AppInfo

HOST_INFO - Static variable in class org.apache.hadoop.yarn.server.metrics.AppAttemptMetricsConstants

I

init(Configuration, RMProxy<T>, Class<T>) - Method in class org.apache.hadoop.yarn.server.federation.failover.FederationRMFailoverProxyProvider

init(Configuration) - Method in interface org.apache.hadoop.yarn.server.federation.store.FederationStateStore

Initialize the FederationStore.

init(Configuration) - Method in class org.apache.hadoop.yarn.server.federation.store.impl.MemoryFederationStateStore

init(Configuration) - Method in class org.apache.hadoop.yarn.server.federation.store.impl.SQLFederationStateStore

init(Configuration) - Method in class org.apache.hadoop.yarn.server.federation.store.impl.ZookeeperFederationStateStore

init(FilterConfig) - Method in class org.apache.hadoop.yarn.server.security.http.RMAuthenticationFilter

init(FilterConfig) - Method in class org.apache.hadoop.yarn.server.timeline.security.TimelineAuthenticationFilter

init(HttpServletResponse) - Method in class org.apache.hadoop.yarn.server.webapp.WebServices

initFilter(FilterContainer, Configuration) - Method in class org.apache.hadoop.yarn.server.security.http.RMAuthenticationFilterInitializer

initFilter(FilterContainer, Configuration) - Method in class org.apache.hadoop.yarn.server.timeline.security.TimelineAuthenticationFilterInitializer

Initializes TimelineAuthenticationFilter.

initializeUnmanagedAM(ApplicationId) - Method in class org.apache.hadoop.yarn.server.uam.UnmanagedApplicationManager

Launch and initialize an unmanaged AM.

instantiatePolicyManager(String) - Static method in class org.apache.hadoop.yarn.server.federation.policies.FederationPolicyUtils

A utilize method to instantiate a policy manager class given the type (class name) from SubClusterPolicyConfiguration.

invoke(T) - Method in interface org.apache.hadoop.yarn.server.federation.utils.FederationStateStoreFacade.Func

isActive() - Method in enum org.apache.hadoop.yarn.server.federation.store.records.SubClusterState

isCompatibleTo(Version) - Method in class org.apache.hadoop.yarn.server.records.Version

isFinal() - Method in enum org.apache.hadoop.yarn.server.federation.store.records.SubClusterState

isStamped() - Method in class org.apache.hadoop.yarn.server.api.records.AppCollectorData

Returns if the collector data has been stamped by the RM with a RM cluster timestamp and a version number.

isUnmanagedApp() - Method in class org.apache.hadoop.yarn.server.webapp.dao.AppInfo

isUnusable() - Method in enum org.apache.hadoop.yarn.server.federation.store.records.SubClusterState

L

LATEST_APP_ATTEMPT_EVENT_INFO - Static variable in class org.apache.hadoop.yarn.server.metrics.ApplicationMetricsConstants

launchUAM(String, Configuration, ApplicationId, String, String, String, boolean) - Method in class org.apache.hadoop.yarn.server.uam.UnmanagedAMPoolManager

Launch a new UAM, using the provided uamId and appId.

launchUAM() - Method in class org.apache.hadoop.yarn.server.uam.UnmanagedApplicationManager

Launch a new UAM in the resource manager.

LeveldbIterator - Class in org.apache.hadoop.yarn.server.utils

A wrapper for a DBIterator to translate the raw RuntimeExceptions that can be thrown into DBExceptions.

LeveldbIterator(DB) - Constructor for class org.apache.hadoop.yarn.server.utils.LeveldbIterator

Create an iterator for the specified database

LeveldbIterator(DB, ReadOptions) - Constructor for class org.apache.hadoop.yarn.server.utils.LeveldbIterator

Create an iterator for the specified database

LeveldbIterator(DBIterator) - Constructor for class org.apache.hadoop.yarn.server.utils.LeveldbIterator

Create an iterator using the specified underlying DBIterator

listServices(String) - Method in class org.apache.hadoop.yarn.lib.ZKClient

list the services registered under a path

load() - Method in class org.apache.hadoop.yarn.server.federation.resolver.DefaultSubClusterResolverImpl

load() - Method in interface org.apache.hadoop.yarn.server.federation.resolver.SubClusterResolver

Load the nodes to subCluster mapping from the file.

loadAMRMPolicy(String, FederationAMRMProxyPolicy, Configuration, FederationStateStoreFacade, SubClusterId) - Static method in class org.apache.hadoop.yarn.server.federation.policies.FederationPolicyUtils

Get AMRMProxy policy from state store, using default queue and configuration as fallback.

LoadBasedRouterPolicy - Class in org.apache.hadoop.yarn.server.federation.policies.router

This implements a simple load-balancing policy.

LoadBasedRouterPolicy() - Constructor for class org.apache.hadoop.yarn.server.federation.policies.router.LoadBasedRouterPolicy

loadPolicyConfiguration(String, Configuration, FederationStateStoreFacade) - Static method in class org.apache.hadoop.yarn.server.federation.policies.FederationPolicyUtils

Get Federation policy configuration from state store, using default queue and configuration as fallback.

loadStateFromRegistry(ApplicationId) - Method in class org.apache.hadoop.yarn.server.federation.utils.FederationRegistryClient

Load the information of one application from registry.

loadVersion() - Method in interface org.apache.hadoop.yarn.server.federation.store.FederationStateStore

Load the version information from the federation state store.

loadVersion() - Method in class org.apache.hadoop.yarn.server.federation.store.impl.MemoryFederationStateStore

loadVersion() - Method in class org.apache.hadoop.yarn.server.federation.store.impl.SQLFederationStateStore

loadVersion() - Method in class org.apache.hadoop.yarn.server.federation.store.impl.ZookeeperFederationStateStore

LocalityMulticastAMRMProxyPolicy - Class in org.apache.hadoop.yarn.server.federation.policies.amrmproxy

An implementation of the FederationAMRMProxyPolicy interface that carefully multicasts the requests with the following behavior:

LocalityMulticastAMRMProxyPolicy() - Constructor for class org.apache.hadoop.yarn.server.federation.policies.amrmproxy.LocalityMulticastAMRMProxyPolicy

LOCALIZATION_FINISHED_EVENT_TYPE - Static variable in class org.apache.hadoop.yarn.server.metrics.ContainerMetricsConstants

LOCALIZATION_START_EVENT_TYPE - Static variable in class org.apache.hadoop.yarn.server.metrics.ContainerMetricsConstants

Lock - Annotation Type in org.apache.hadoop.yarn.server.utils

Annotation to document locking order.

Lock.NoLock - Class in org.apache.hadoop.yarn.server.utils

LOG - Static variable in class org.apache.hadoop.yarn.server.federation.failover.FederationProxyProviderUtil

LOG - Static variable in class org.apache.hadoop.yarn.server.federation.policies.amrmproxy.LocalityMulticastAMRMProxyPolicy

LOG - Static variable in class org.apache.hadoop.yarn.server.federation.policies.manager.AbstractPolicyManager

LOG - Static variable in class org.apache.hadoop.yarn.server.federation.store.impl.MemoryFederationStateStore

LOG - Static variable in class org.apache.hadoop.yarn.server.federation.store.impl.SQLFederationStateStore

LOG - Static variable in class org.apache.hadoop.yarn.server.federation.store.metrics.FederationStateStoreClientMetrics

LOG - Static variable in enum org.apache.hadoop.yarn.server.federation.store.records.SubClusterState

LOG - Static variable in class org.apache.hadoop.yarn.server.federation.store.utils.FederationStateStoreUtils

LOG - Static variable in class org.apache.hadoop.yarn.server.uam.UnmanagedAMPoolManager

LogAggregationReport - Class in org.apache.hadoop.yarn.server.api.protocolrecords

LogAggregationReport is a report for log aggregation status in one NodeManager of an application.

LogAggregationReport() - Constructor for class org.apache.hadoop.yarn.server.api.protocolrecords.LogAggregationReport

LogAggregationReportPBImpl - Class in org.apache.hadoop.yarn.server.api.protocolrecords.impl.pb

LogAggregationReportPBImpl() - Constructor for class org.apache.hadoop.yarn.server.api.protocolrecords.impl.pb.LogAggregationReportPBImpl

LogAggregationReportPBImpl(YarnServerCommonServiceProtos.LogAggregationReportProto) - Constructor for class org.apache.hadoop.yarn.server.api.protocolrecords.impl.pb.LogAggregationReportPBImpl

logAndThrowException(Logger, String, Throwable) - Static method in class org.apache.hadoop.yarn.server.federation.store.utils.FederationStateStoreUtils

Throws an exception due to an error in FederationStateStore.

logAndThrowInvalidInputException(Logger, String) - Static method in class org.apache.hadoop.yarn.server.federation.store.utils.FederationStateStoreUtils

Throws an FederationStateStoreInvalidInputException due to an error in FederationStateStore.

logAndThrowRetriableException(Logger, String, Throwable) - Static method in class org.apache.hadoop.yarn.server.federation.store.utils.FederationStateStoreUtils

Throws an FederationStateStoreRetriableException due to an error in FederationStateStore.

logAndThrowStoreException(Logger, String) - Static method in class org.apache.hadoop.yarn.server.federation.store.utils.FederationStateStoreUtils

Throws an FederationStateStoreException due to an error in FederationStateStore.

logType - Variable in class org.apache.hadoop.yarn.server.webapp.dao.ContainerLogsInfo

logUrl - Variable in class org.apache.hadoop.yarn.server.webapp.dao.ContainerInfo

M

MASTER_CONTAINER_INFO - Static variable in class org.apache.hadoop.yarn.server.metrics.AppAttemptMetricsConstants

MasterKey - Interface in org.apache.hadoop.yarn.server.api.records

MasterKeyData - Class in org.apache.hadoop.yarn.server.security

MasterKeyData(int, SecretKey) - Constructor for class org.apache.hadoop.yarn.server.security.MasterKeyData

MasterKeyData(MasterKey, SecretKey) - Constructor for class org.apache.hadoop.yarn.server.security.MasterKeyData

MasterKeyPBImpl - Class in org.apache.hadoop.yarn.server.api.records.impl.pb

MasterKeyPBImpl() - Constructor for class org.apache.hadoop.yarn.server.api.records.impl.pb.MasterKeyPBImpl

MasterKeyPBImpl(YarnServerCommonProtos.MasterKeyProto) - Constructor for class org.apache.hadoop.yarn.server.api.records.impl.pb.MasterKeyPBImpl

matchAllocationToOutstandingRequest(Resource, List<OpportunisticContainerAllocator.Allocation>) - Method in class org.apache.hadoop.yarn.server.scheduler.OpportunisticContainerContext

This method matches a returned list of Container Allocations to any outstanding OPPORTUNISTIC ResourceRequest.

MemoryFederationStateStore - Class in org.apache.hadoop.yarn.server.federation.store.impl

In-memory implementation of FederationStateStore.

MemoryFederationStateStore() - Constructor for class org.apache.hadoop.yarn.server.federation.store.impl.MemoryFederationStateStore

N

name - Variable in class org.apache.hadoop.yarn.server.webapp.dao.AppInfo

NAME_ENTITY_INFO - Static variable in class org.apache.hadoop.yarn.server.metrics.ApplicationMetricsConstants

newAllocateResponse(int, List<ContainerStatus>, List<Container>, List<NodeReport>, Resource, AMCommand, int, PreemptionMessage) - Static method in class org.apache.hadoop.yarn.server.utils.BuilderUtils

newAMRMToken(byte[], String, byte[], String) - Static method in class org.apache.hadoop.yarn.server.utils.BuilderUtils

newApplicationAttemptId(ApplicationId, int) - Static method in class org.apache.hadoop.yarn.server.utils.BuilderUtils

newApplicationId(RecordFactory, long, CharSequence) - Static method in class org.apache.hadoop.yarn.server.utils.BuilderUtils

newApplicationId(RecordFactory, long, int) - Static method in class org.apache.hadoop.yarn.server.utils.BuilderUtils

newApplicationId(long, int) - Static method in class org.apache.hadoop.yarn.server.utils.BuilderUtils

newApplicationReport(ApplicationId, ApplicationAttemptId, String, String, String, String, int, Token, YarnApplicationState, String, String, long, long, FinalApplicationStatus, ApplicationResourceUsageReport, String, float, String, Token, Set<String>, Priority) - Static method in class org.apache.hadoop.yarn.server.utils.BuilderUtils

newApplicationResourceUsageReport(int, int, Resource, Resource, Resource, Map<String, Long>, Map<String, Long>) - Static method in class org.apache.hadoop.yarn.server.utils.BuilderUtils

newApplicationSubmissionContext(ApplicationId, String, String, Priority, ContainerLaunchContext, boolean, boolean, int, Resource, String) - Static method in class org.apache.hadoop.yarn.server.utils.BuilderUtils

newApplicationSubmissionContext(ApplicationId, String, String, Priority, ContainerLaunchContext, boolean, boolean, int, Resource) - Static method in class org.apache.hadoop.yarn.server.utils.BuilderUtils

newClientToAMToken(byte[], String, byte[], String) - Static method in class org.apache.hadoop.yarn.server.utils.BuilderUtils

newContainer(ContainerId, NodeId, String, Resource, Priority, Token, ExecutionType, long) - Static method in class org.apache.hadoop.yarn.server.utils.BuilderUtils

newContainer(ContainerId, NodeId, String, Resource, Priority, Token) - Static method in class org.apache.hadoop.yarn.server.utils.BuilderUtils

newContainer(ContainerId, NodeId, String, Resource, Priority, Token, long) - Static method in class org.apache.hadoop.yarn.server.utils.BuilderUtils

newContainerId(ApplicationAttemptId, long) - Static method in class org.apache.hadoop.yarn.server.utils.BuilderUtils

newContainerId(int, int, long, long) - Static method in class org.apache.hadoop.yarn.server.utils.BuilderUtils

newContainerId(RecordFactory, ApplicationId, ApplicationAttemptId, int) - Static method in class org.apache.hadoop.yarn.server.utils.BuilderUtils

newContainerLaunchContext(Map<String, LocalResource>, Map<String, String>, List<String>, Map<String, ByteBuffer>, ByteBuffer, Map<ApplicationAccessType, String>) - Static method in class org.apache.hadoop.yarn.server.utils.BuilderUtils

newContainerStatus(ContainerId, ContainerState, String, int, Resource) - Static method in class org.apache.hadoop.yarn.server.utils.BuilderUtils

newContainerStatus(ContainerId, ContainerState, String, int, Resource, ExecutionType) - Static method in class org.apache.hadoop.yarn.server.utils.BuilderUtils

newContainerToken(ContainerId, int, String, int, String, Resource, long, int, byte[], long) - Static method in class org.apache.hadoop.yarn.server.utils.BuilderUtils

newContainerToken(NodeId, byte[], ContainerTokenIdentifier) - Static method in class org.apache.hadoop.yarn.server.utils.BuilderUtils

newContainerTokenIdentifier(Token) - Static method in class org.apache.hadoop.yarn.server.utils.BuilderUtils

newDelegationToken(byte[], String, byte[], String) - Static method in class org.apache.hadoop.yarn.server.utils.BuilderUtils

newInstance(AllocateResponse) - Static method in class org.apache.hadoop.yarn.server.api.protocolrecords.DistributedSchedulingAllocateResponse

newInstance(ApplicationId) - Static method in class org.apache.hadoop.yarn.server.api.protocolrecords.GetTimelineCollectorContextRequest

newInstance(String, String, String, long) - Static method in class org.apache.hadoop.yarn.server.api.protocolrecords.GetTimelineCollectorContextResponse

newInstance(ApplicationId, LogAggregationStatus, String) - Static method in class org.apache.hadoop.yarn.server.api.protocolrecords.LogAggregationReport

newInstance(ContainerId, int, ContainerState, Resource, String, int, Priority, long) - Static method in class org.apache.hadoop.yarn.server.api.protocolrecords.NMContainerStatus

newInstance(ContainerId, int, ContainerState, Resource, String, int, Priority, long, String, ExecutionType, long) - Static method in class org.apache.hadoop.yarn.server.api.protocolrecords.NMContainerStatus

newInstance(NodeStatus, MasterKey, MasterKey, Set<NodeLabel>) - Static method in class org.apache.hadoop.yarn.server.api.protocolrecords.NodeHeartbeatRequest

newInstance(NodeStatus, MasterKey, MasterKey, Set<NodeLabel>, Map<ApplicationId, AppCollectorData>) - Static method in class org.apache.hadoop.yarn.server.api.protocolrecords.NodeHeartbeatRequest

newInstance(RegisterApplicationMasterResponse) - Static method in class org.apache.hadoop.yarn.server.api.protocolrecords.RegisterDistributedSchedulingAMResponse

newInstance(NodeId, int, Resource, String, List<NMContainerStatus>, List<ApplicationId>) - Static method in class org.apache.hadoop.yarn.server.api.protocolrecords.RegisterNodeManagerRequest

newInstance(NodeId, int, Resource, String, List<NMContainerStatus>, List<ApplicationId>, Set<NodeLabel>) - Static method in class org.apache.hadoop.yarn.server.api.protocolrecords.RegisterNodeManagerRequest

newInstance(NodeId, int, Resource, String, List<NMContainerStatus>, List<ApplicationId>, Set<NodeLabel>, Resource) - Static method in class org.apache.hadoop.yarn.server.api.protocolrecords.RegisterNodeManagerRequest

newInstance(NodeId, String) - Static method in class org.apache.hadoop.yarn.server.api.protocolrecords.RemoteNode

Create new Instance.

newInstance(NodeId, String, String) - Static method in class org.apache.hadoop.yarn.server.api.protocolrecords.RemoteNode

Create new Instance.

newInstance(List<AppCollectorData>) - Static method in class org.apache.hadoop.yarn.server.api.protocolrecords.ReportNewCollectorInfoRequest

newInstance(ApplicationId, String, Token) - Static method in class org.apache.hadoop.yarn.server.api.protocolrecords.ReportNewCollectorInfoRequest

newInstance() - Static method in class org.apache.hadoop.yarn.server.api.protocolrecords.ReportNewCollectorInfoResponse

newInstance(NodeId) - Static method in class org.apache.hadoop.yarn.server.api.protocolrecords.UnRegisterNodeManagerRequest

newInstance() - Static method in class org.apache.hadoop.yarn.server.api.protocolrecords.UnRegisterNodeManagerResponse

newInstance(ApplicationId, String, long, long, Token) - Static method in class org.apache.hadoop.yarn.server.api.records.AppCollectorData

newInstance(ApplicationId, String, long, long) - Static method in class org.apache.hadoop.yarn.server.api.records.AppCollectorData

newInstance(ApplicationId, String, Token) - Static method in class org.apache.hadoop.yarn.server.api.records.AppCollectorData

newInstance(ApplicationId, String) - Static method in class org.apache.hadoop.yarn.server.api.records.AppCollectorData

newInstance() - Static method in class org.apache.hadoop.yarn.server.api.records.ContainerQueuingLimit

newInstance(boolean, String, long) - Static method in class org.apache.hadoop.yarn.server.api.records.NodeHealthStatus

newInstance(NodeId, int, List<ContainerStatus>, List<ApplicationId>, NodeHealthStatus, ResourceUtilization, ResourceUtilization, List<Container>) - Static method in class org.apache.hadoop.yarn.server.api.records.NodeStatus

Create a new NodeStatus.

newInstance() - Static method in class org.apache.hadoop.yarn.server.api.records.OpportunisticContainersStatus

newInstance(ApplicationHomeSubCluster) - Static method in class org.apache.hadoop.yarn.server.federation.store.records.AddApplicationHomeSubClusterRequest

newInstance(SubClusterId) - Static method in class org.apache.hadoop.yarn.server.federation.store.records.AddApplicationHomeSubClusterResponse

newInstance(ApplicationId, SubClusterId) - Static method in class org.apache.hadoop.yarn.server.federation.store.records.ApplicationHomeSubCluster

newInstance(ApplicationId) - Static method in class org.apache.hadoop.yarn.server.federation.store.records.DeleteApplicationHomeSubClusterRequest

newInstance() - Static method in class org.apache.hadoop.yarn.server.federation.store.records.DeleteApplicationHomeSubClusterResponse

newInstance(ApplicationId) - Static method in class org.apache.hadoop.yarn.server.federation.store.records.GetApplicationHomeSubClusterRequest

newInstance(ApplicationHomeSubCluster) - Static method in class org.apache.hadoop.yarn.server.federation.store.records.GetApplicationHomeSubClusterResponse

newInstance() - Static method in class org.apache.hadoop.yarn.server.federation.store.records.GetApplicationsHomeSubClusterRequest

newInstance(List<ApplicationHomeSubCluster>) - Static method in class org.apache.hadoop.yarn.server.federation.store.records.GetApplicationsHomeSubClusterResponse

newInstance(SubClusterId) - Static method in class org.apache.hadoop.yarn.server.federation.store.records.GetSubClusterInfoRequest

newInstance(SubClusterInfo) - Static method in class org.apache.hadoop.yarn.server.federation.store.records.GetSubClusterInfoResponse

newInstance() - Static method in class org.apache.hadoop.yarn.server.federation.store.records.GetSubClusterPoliciesConfigurationsRequest

newInstance(List<SubClusterPolicyConfiguration>) - Static method in class org.apache.hadoop.yarn.server.federation.store.records.GetSubClusterPoliciesConfigurationsResponse

newInstance(String) - Static method in class org.apache.hadoop.yarn.server.federation.store.records.GetSubClusterPolicyConfigurationRequest

newInstance(SubClusterPolicyConfiguration) - Static method in class org.apache.hadoop.yarn.server.federation.store.records.GetSubClusterPolicyConfigurationResponse

newInstance(boolean) - Static method in class org.apache.hadoop.yarn.server.federation.store.records.GetSubClustersInfoRequest

newInstance(List<SubClusterInfo>) - Static method in class org.apache.hadoop.yarn.server.federation.store.records.GetSubClustersInfoResponse

newInstance(SubClusterPolicyConfiguration) - Static method in class org.apache.hadoop.yarn.server.federation.store.records.SetSubClusterPolicyConfigurationRequest

newInstance() - Static method in class org.apache.hadoop.yarn.server.federation.store.records.SetSubClusterPolicyConfigurationResponse

newInstance(SubClusterId, SubClusterState) - Static method in class org.apache.hadoop.yarn.server.federation.store.records.SubClusterDeregisterRequest

newInstance() - Static method in class org.apache.hadoop.yarn.server.federation.store.records.SubClusterDeregisterResponse

newInstance(SubClusterId, SubClusterState, String) - Static method in class org.apache.hadoop.yarn.server.federation.store.records.SubClusterHeartbeatRequest

newInstance(SubClusterId, long, SubClusterState, String) - Static method in class org.apache.hadoop.yarn.server.federation.store.records.SubClusterHeartbeatRequest

newInstance() - Static method in class org.apache.hadoop.yarn.server.federation.store.records.SubClusterHeartbeatResponse

newInstance(String) - Static method in class org.apache.hadoop.yarn.server.federation.store.records.SubClusterId

newInstance(SubClusterId, String, String, String, String, SubClusterState, long, String) - Static method in class org.apache.hadoop.yarn.server.federation.store.records.SubClusterInfo

newInstance(SubClusterId, String, String, String, String, long, SubClusterState, long, String) - Static method in class org.apache.hadoop.yarn.server.federation.store.records.SubClusterInfo

newInstance(String, String, ByteBuffer) - Static method in class org.apache.hadoop.yarn.server.federation.store.records.SubClusterPolicyConfiguration

newInstance(SubClusterPolicyConfiguration) - Static method in class org.apache.hadoop.yarn.server.federation.store.records.SubClusterPolicyConfiguration

newInstance(SubClusterInfo) - Static method in class org.apache.hadoop.yarn.server.federation.store.records.SubClusterRegisterRequest

newInstance() - Static method in class org.apache.hadoop.yarn.server.federation.store.records.SubClusterRegisterResponse

newInstance(ApplicationHomeSubCluster) - Static method in class org.apache.hadoop.yarn.server.federation.store.records.UpdateApplicationHomeSubClusterRequest

newInstance() - Static method in class org.apache.hadoop.yarn.server.federation.store.records.UpdateApplicationHomeSubClusterResponse

newInstance(int, int) - Static method in class org.apache.hadoop.yarn.server.records.Version

newInstance(byte[], NMTokenIdentifier) - Static method in class org.apache.hadoop.yarn.server.security.BaseNMTokenSecretManager

newLocalResource(URL, LocalResourceType, LocalResourceVisibility, long, long, boolean) - Static method in class org.apache.hadoop.yarn.server.utils.BuilderUtils

newLocalResource(URI, LocalResourceType, LocalResourceVisibility, long, long, boolean) - Static method in class org.apache.hadoop.yarn.server.utils.BuilderUtils

newNodeHeartbeatResponse(NodeAction, String) - Static method in class org.apache.hadoop.yarn.server.utils.YarnServerBuilderUtils

newNodeHeartbeatResponse(int, NodeAction, List<ContainerId>, List<ApplicationId>, MasterKey, MasterKey, long) - Static method in class org.apache.hadoop.yarn.server.utils.YarnServerBuilderUtils

newNodeId(String, int) - Static method in class org.apache.hadoop.yarn.server.utils.BuilderUtils

newNodeReport(NodeId, NodeState, String, String, Resource, Resource, int, String, long) - Static method in class org.apache.hadoop.yarn.server.utils.BuilderUtils

newNodeReport(NodeId, NodeState, String, String, Resource, Resource, int, String, long, Set<String>, Integer, NodeUpdateType) - Static method in class org.apache.hadoop.yarn.server.utils.BuilderUtils

newNodeReport(NodeId, NodeState, String, String, Resource, Resource, int, String, long, Set<String>, ResourceUtilization, ResourceUtilization, Integer, NodeUpdateType) - Static method in class org.apache.hadoop.yarn.server.utils.BuilderUtils

newPriority(int) - Static method in class org.apache.hadoop.yarn.server.utils.BuilderUtils

newResource(long, int) - Static method in class org.apache.hadoop.yarn.server.utils.BuilderUtils

newResourceRequest(Priority, String, Resource, int) - Static method in class org.apache.hadoop.yarn.server.utils.BuilderUtils

newResourceRequest(Priority, String, Resource, int, String) - Static method in class org.apache.hadoop.yarn.server.utils.BuilderUtils

newResourceRequest(ResourceRequest) - Static method in class org.apache.hadoop.yarn.server.utils.BuilderUtils

newToken(Class<T>, byte[], String, byte[], String) - Static method in class org.apache.hadoop.yarn.server.utils.BuilderUtils

newURL(String, String, int, String) - Static method in class org.apache.hadoop.yarn.server.utils.BuilderUtils

next() - Method in class org.apache.hadoop.yarn.server.utils.LeveldbIterator

Returns the next element in the iteration.

NM_ID - Static variable in interface org.apache.hadoop.yarn.server.webapp.YarnWebServiceParams

NMContainerStatus - Class in org.apache.hadoop.yarn.server.api.protocolrecords

NMContainerStatus includes the current information of a container.

NMContainerStatus() - Constructor for class org.apache.hadoop.yarn.server.api.protocolrecords.NMContainerStatus

NMContainerStatusPBImpl - Class in org.apache.hadoop.yarn.server.api.protocolrecords.impl.pb

NMContainerStatusPBImpl() - Constructor for class org.apache.hadoop.yarn.server.api.protocolrecords.impl.pb.NMContainerStatusPBImpl

NMContainerStatusPBImpl(YarnServerCommonServiceProtos.NMContainerStatusProto) - Constructor for class org.apache.hadoop.yarn.server.api.protocolrecords.impl.pb.NMContainerStatusPBImpl

NO_ACTIVE_SUBCLUSTER_AVAILABLE - Static variable in class org.apache.hadoop.yarn.server.federation.policies.FederationPolicyUtils

NoActiveSubclustersException - Exception in org.apache.hadoop.yarn.server.federation.policies.exceptions

This exception is thrown when policies cannot locate any active cluster.

NoActiveSubclustersException(String) - Constructor for exception org.apache.hadoop.yarn.server.federation.policies.exceptions.NoActiveSubclustersException

NodeAction - Enum in org.apache.hadoop.yarn.server.api.records

The NodeManager is instructed to perform the given action.

NodeHealthStatus - Class in org.apache.hadoop.yarn.server.api.records

NodeHealthStatus is a summary of the health status of the node.

NodeHealthStatus() - Constructor for class org.apache.hadoop.yarn.server.api.records.NodeHealthStatus

NodeHealthStatusPBImpl - Class in org.apache.hadoop.yarn.server.api.records.impl.pb

NodeHealthStatusPBImpl() - Constructor for class org.apache.hadoop.yarn.server.api.records.impl.pb.NodeHealthStatusPBImpl

NodeHealthStatusPBImpl(YarnServerCommonProtos.NodeHealthStatusProto) - Constructor for class org.apache.hadoop.yarn.server.api.records.impl.pb.NodeHealthStatusPBImpl

nodeHeartbeat(NodeHeartbeatRequest) - Method in class org.apache.hadoop.yarn.server.api.impl.pb.client.ResourceTrackerPBClientImpl

nodeHeartbeat(RpcController, YarnServerCommonServiceProtos.NodeHeartbeatRequestProto) - Method in class org.apache.hadoop.yarn.server.api.impl.pb.service.ResourceTrackerPBServiceImpl

nodeHeartbeat(NodeHeartbeatRequest) - Method in interface org.apache.hadoop.yarn.server.api.ResourceTracker

NodeHeartbeatRequest - Class in org.apache.hadoop.yarn.server.api.protocolrecords

NodeHeartbeatRequest() - Constructor for class org.apache.hadoop.yarn.server.api.protocolrecords.NodeHeartbeatRequest

NodeHeartbeatRequestPBImpl - Class in org.apache.hadoop.yarn.server.api.protocolrecords.impl.pb

NodeHeartbeatRequestPBImpl() - Constructor for class org.apache.hadoop.yarn.server.api.protocolrecords.impl.pb.NodeHeartbeatRequestPBImpl

NodeHeartbeatRequestPBImpl(YarnServerCommonServiceProtos.NodeHeartbeatRequestProto) - Constructor for class org.apache.hadoop.yarn.server.api.protocolrecords.impl.pb.NodeHeartbeatRequestPBImpl

NodeHeartbeatResponse - Class in org.apache.hadoop.yarn.server.api.protocolrecords

Node Manager's heartbeat response.

NodeHeartbeatResponse() - Constructor for class org.apache.hadoop.yarn.server.api.protocolrecords.NodeHeartbeatResponse

NodeHeartbeatResponsePBImpl - Class in org.apache.hadoop.yarn.server.api.protocolrecords.impl.pb

PBImpl class for NodeHeartbeatResponse.

NodeHeartbeatResponsePBImpl() - Constructor for class org.apache.hadoop.yarn.server.api.protocolrecords.impl.pb.NodeHeartbeatResponsePBImpl

NodeHeartbeatResponsePBImpl(YarnServerCommonServiceProtos.NodeHeartbeatResponseProto) - Constructor for class org.apache.hadoop.yarn.server.api.protocolrecords.impl.pb.NodeHeartbeatResponsePBImpl

nodeHttpAddress - Variable in class org.apache.hadoop.yarn.server.webapp.dao.ContainerInfo

nodeId - Variable in class org.apache.hadoop.yarn.server.webapp.dao.ContainerInfo

nodeId - Variable in class org.apache.hadoop.yarn.server.webapp.dao.ContainerLogsInfo

NodeStatus - Class in org.apache.hadoop.yarn.server.api.records

NodeStatus is a summary of the status of the node.

NodeStatus() - Constructor for class org.apache.hadoop.yarn.server.api.records.NodeStatus

NodeStatusPBImpl - Class in org.apache.hadoop.yarn.server.api.records.impl.pb

NodeStatusPBImpl() - Constructor for class org.apache.hadoop.yarn.server.api.records.impl.pb.NodeStatusPBImpl

NodeStatusPBImpl(YarnServerCommonProtos.NodeStatusProto) - Constructor for class org.apache.hadoop.yarn.server.api.records.impl.pb.NodeStatusPBImpl

NoLock() - Constructor for class org.apache.hadoop.yarn.server.utils.Lock.NoLock

notify(SCMUploaderNotifyRequest) - Method in class org.apache.hadoop.yarn.server.api.impl.pb.client.SCMUploaderProtocolPBClientImpl

notify(RpcController, YarnServerCommonServiceProtos.SCMUploaderNotifyRequestProto) - Method in class org.apache.hadoop.yarn.server.api.impl.pb.service.SCMUploaderProtocolPBServiceImpl

notify(SCMUploaderNotifyRequest) - Method in interface org.apache.hadoop.yarn.server.api.SCMUploaderProtocol

The method used by the NodeManager's SharedCacheUploadService to notify the shared cache manager of a newly cached resource.

notifyOfResponse(SubClusterId, AllocateResponse) - Method in class org.apache.hadoop.yarn.server.federation.policies.amrmproxy.BroadcastAMRMProxyPolicy

notifyOfResponse(SubClusterId, AllocateResponse) - Method in interface org.apache.hadoop.yarn.server.federation.policies.amrmproxy.FederationAMRMProxyPolicy

This method should be invoked to notify the policy about responses being received.

notifyOfResponse(SubClusterId, AllocateResponse) - Method in class org.apache.hadoop.yarn.server.federation.policies.amrmproxy.LocalityMulticastAMRMProxyPolicy

notifyOfResponse(SubClusterId, AllocateResponse) - Method in class org.apache.hadoop.yarn.server.federation.policies.amrmproxy.RejectAMRMProxyPolicy

O

OpportunisticContainerAllocator - Class in org.apache.hadoop.yarn.server.scheduler

The OpportunisticContainerAllocator allocates containers on a given list of nodes, after modifying the container sizes to respect the limits set by the ResourceManager.

OpportunisticContainerAllocator(BaseContainerTokenSecretManager) - Constructor for class org.apache.hadoop.yarn.server.scheduler.OpportunisticContainerAllocator

Create a new Opportunistic Container Allocator.

OpportunisticContainerAllocator.AllocationParams - Class in org.apache.hadoop.yarn.server.scheduler

This class encapsulates application specific parameters used to build a Container.

OpportunisticContainerAllocator.ContainerIdGenerator - Class in org.apache.hadoop.yarn.server.scheduler

A Container Id Generator.

OpportunisticContainerAllocator.PartitionedResourceRequests - Class in org.apache.hadoop.yarn.server.scheduler

Class that includes two lists of ResourceRequests: one for GUARANTEED and one for OPPORTUNISTIC ResourceRequests.

OpportunisticContainerContext - Class in org.apache.hadoop.yarn.server.scheduler

This encapsulates application specific information used by the Opportunistic Container Allocator to allocate containers.

OpportunisticContainerContext() - Constructor for class org.apache.hadoop.yarn.server.scheduler.OpportunisticContainerContext

OpportunisticContainersStatus - Class in org.apache.hadoop.yarn.server.api.records

OpportunisticContainersStatus captures information pertaining to the state of execution of the opportunistic containers within a node.

OpportunisticContainersStatus() - Constructor for class org.apache.hadoop.yarn.server.api.records.OpportunisticContainersStatus

OpportunisticContainersStatusPBImpl - Class in org.apache.hadoop.yarn.server.api.records.impl.pb

Protocol Buffer implementation of OpportunisticContainersStatus.

OpportunisticContainersStatusPBImpl() - Constructor for class org.apache.hadoop.yarn.server.api.records.impl.pb.OpportunisticContainersStatusPBImpl

OpportunisticContainersStatusPBImpl(YarnServerCommonProtos.OpportunisticContainersStatusProto) - Constructor for class org.apache.hadoop.yarn.server.api.records.impl.pb.OpportunisticContainersStatusPBImpl

org.apache.hadoop.yarn.lib - package org.apache.hadoop.yarn.lib

org.apache.hadoop.yarn.server - package org.apache.hadoop.yarn.server

org.apache.hadoop.yarn.server.api - package org.apache.hadoop.yarn.server.api

org.apache.hadoop.yarn.server.api.impl.pb.client - package org.apache.hadoop.yarn.server.api.impl.pb.client

org.apache.hadoop.yarn.server.api.impl.pb.service - package org.apache.hadoop.yarn.server.api.impl.pb.service

org.apache.hadoop.yarn.server.api.protocolrecords - package org.apache.hadoop.yarn.server.api.protocolrecords

org.apache.hadoop.yarn.server.api.protocolrecords.impl.pb - package org.apache.hadoop.yarn.server.api.protocolrecords.impl.pb

org.apache.hadoop.yarn.server.api.records - package org.apache.hadoop.yarn.server.api.records

Server records.

org.apache.hadoop.yarn.server.api.records.impl.pb - package org.apache.hadoop.yarn.server.api.records.impl.pb

Server records PB implementations.

org.apache.hadoop.yarn.server.federation.failover - package org.apache.hadoop.yarn.server.federation.failover

Licensed to the Apache Software Foundation (ASF) under one or more contributor license agreements.

org.apache.hadoop.yarn.server.federation.policies - package org.apache.hadoop.yarn.server.federation.policies

Federation Policies.

org.apache.hadoop.yarn.server.federation.policies.amrmproxy - package org.apache.hadoop.yarn.server.federation.policies.amrmproxy

AMRMPRoxy policies.

org.apache.hadoop.yarn.server.federation.policies.dao - package org.apache.hadoop.yarn.server.federation.policies.dao

DAO objects for serializing/deserializing policy configurations.

org.apache.hadoop.yarn.server.federation.policies.exceptions - package org.apache.hadoop.yarn.server.federation.policies.exceptions

Exceptions for policies.

org.apache.hadoop.yarn.server.federation.policies.manager - package org.apache.hadoop.yarn.server.federation.policies.manager

Various implementation of FederationPolicyManager.

org.apache.hadoop.yarn.server.federation.policies.router - package org.apache.hadoop.yarn.server.federation.policies.router

Router policies.

org.apache.hadoop.yarn.server.federation.resolver - package org.apache.hadoop.yarn.server.federation.resolver

Licensed to the Apache Software Foundation (ASF) under one or more contributor license agreements.

org.apache.hadoop.yarn.server.federation.store - package org.apache.hadoop.yarn.server.federation.store

Licensed to the Apache Software Foundation (ASF) under one or more contributor license agreements.

org.apache.hadoop.yarn.server.federation.store.exception - package org.apache.hadoop.yarn.server.federation.store.exception

Licensed to the Apache Software Foundation (ASF) under one or more contributor license agreements.

org.apache.hadoop.yarn.server.federation.store.impl - package org.apache.hadoop.yarn.server.federation.store.impl

Licensed to the Apache Software Foundation (ASF) under one or more contributor license agreements.

org.apache.hadoop.yarn.server.federation.store.metrics - package org.apache.hadoop.yarn.server.federation.store.metrics

Licensed to the Apache Software Foundation (ASF) under one or more contributor license agreements.

org.apache.hadoop.yarn.server.federation.store.records - package org.apache.hadoop.yarn.server.federation.store.records

Licensed to the Apache Software Foundation (ASF) under one or more contributor license agreements.

org.apache.hadoop.yarn.server.federation.store.records.impl.pb - package org.apache.hadoop.yarn.server.federation.store.records.impl.pb

Licensed to the Apache Software Foundation (ASF) under one or more contributor license agreements.

org.apache.hadoop.yarn.server.federation.store.utils - package org.apache.hadoop.yarn.server.federation.store.utils

Licensed to the Apache Software Foundation (ASF) under one or more contributor license agreements.

org.apache.hadoop.yarn.server.federation.utils - package org.apache.hadoop.yarn.server.federation.utils

Licensed to the Apache Software Foundation (ASF) under one or more contributor license agreements.

org.apache.hadoop.yarn.server.metrics - package org.apache.hadoop.yarn.server.metrics

org.apache.hadoop.yarn.server.records - package org.apache.hadoop.yarn.server.records

org.apache.hadoop.yarn.server.records.impl.pb - package org.apache.hadoop.yarn.server.records.impl.pb

org.apache.hadoop.yarn.server.scheduler - package org.apache.hadoop.yarn.server.scheduler

Utility classes used for Scheduling.

org.apache.hadoop.yarn.server.security - package org.apache.hadoop.yarn.server.security

org.apache.hadoop.yarn.server.security.http - package org.apache.hadoop.yarn.server.security.http

org.apache.hadoop.yarn.server.sharedcache - package org.apache.hadoop.yarn.server.sharedcache

org.apache.hadoop.yarn.server.timeline.security - package org.apache.hadoop.yarn.server.timeline.security

Package org.apache.hadoop.server.timeline.security contains classes related to timeline authentication filters and abstract delegation token service for ATSv1 and ATSv2.

org.apache.hadoop.yarn.server.uam - package org.apache.hadoop.yarn.server.uam

Licensed to the Apache Software Foundation (ASF) under one or more contributor license agreements.

org.apache.hadoop.yarn.server.util.timeline - package org.apache.hadoop.yarn.server.util.timeline

Package org.apache.hadoop.server.util.timeline contains utility classes used by ATSv1 and ATSv2 on the server side.

org.apache.hadoop.yarn.server.utils - package org.apache.hadoop.yarn.server.utils

org.apache.hadoop.yarn.server.webapp - package org.apache.hadoop.yarn.server.webapp

org.apache.hadoop.yarn.server.webapp.dao - package org.apache.hadoop.yarn.server.webapp.dao

ORIGINAL_TRACKING_URL_INFO - Static variable in class org.apache.hadoop.yarn.server.metrics.AppAttemptMetricsConstants

originalTrackingUrl - Variable in class org.apache.hadoop.yarn.server.webapp.dao.AppAttemptInfo

originalTrackingUrl - Variable in class org.apache.hadoop.yarn.server.webapp.dao.AppInfo

P

PARENT_PRIMARIY_FILTER - Static variable in class org.apache.hadoop.yarn.server.metrics.ContainerMetricsConstants

PARENT_PRIMARY_FILTER - Static variable in class org.apache.hadoop.yarn.server.metrics.AppAttemptMetricsConstants

parseApplicationAttemptId(String) - Static method in class org.apache.hadoop.yarn.server.webapp.WebServices

parseApplicationId(String) - Static method in class org.apache.hadoop.yarn.server.webapp.WebServices

parseContainerId(String) - Static method in class org.apache.hadoop.yarn.server.webapp.WebServices

parseCredentials(ApplicationSubmissionContext) - Static method in class org.apache.hadoop.yarn.server.utils.BuilderUtils

parseCredentials(ContainerLaunchContext) - Static method in class org.apache.hadoop.yarn.server.utils.YarnServerSecurityUtils

Parses the container launch context and returns a Credential instance that contains all the tokens from the launch context.

parseQueries(Set<String>, boolean) - Static method in class org.apache.hadoop.yarn.server.webapp.WebServices

parseTokensConf(ApplicationSubmissionContext) - Static method in class org.apache.hadoop.yarn.server.utils.BuilderUtils

partitionAskList(List<ResourceRequest>) - Method in class org.apache.hadoop.yarn.server.scheduler.OpportunisticContainerAllocator

Partitions a list of ResourceRequest to two separate lists, one for GUARANTEED and one for OPPORTUNISTIC ResourceRequests.

PartitionedResourceRequests() - Constructor for class org.apache.hadoop.yarn.server.scheduler.OpportunisticContainerAllocator.PartitionedResourceRequests

peekNext() - Method in class org.apache.hadoop.yarn.server.utils.LeveldbIterator

Returns the next element in the iteration, without advancing the iteration.

peekPrev() - Method in class org.apache.hadoop.yarn.server.utils.LeveldbIterator

performFailover(T) - Method in class org.apache.hadoop.yarn.server.federation.failover.FederationRMFailoverProxyProvider

PREFIX - Static variable in class org.apache.hadoop.yarn.server.timeline.security.TimelineAuthenticationFilterInitializer

The configuration prefix of timeline HTTP authentication.

prev() - Method in class org.apache.hadoop.yarn.server.utils.LeveldbIterator

priority - Variable in class org.apache.hadoop.yarn.server.webapp.dao.AppInfo

priority - Variable in class org.apache.hadoop.yarn.server.webapp.dao.ContainerInfo

PriorityBroadcastPolicyManager - Class in org.apache.hadoop.yarn.server.federation.policies.manager

Policy that allows operator to configure "weights" for routing.

PriorityBroadcastPolicyManager() - Constructor for class org.apache.hadoop.yarn.server.federation.policies.manager.PriorityBroadcastPolicyManager

PriorityRouterPolicy - Class in org.apache.hadoop.yarn.server.federation.policies.router

This implements a policy that interprets "weights" as a ordered list of preferences among sub-clusters.

PriorityRouterPolicy() - Constructor for class org.apache.hadoop.yarn.server.federation.policies.router.PriorityRouterPolicy

progress - Variable in class org.apache.hadoop.yarn.server.webapp.dao.AppInfo

Q

queue - Variable in class org.apache.hadoop.yarn.server.webapp.dao.AppInfo

QUEUE_ENTITY_INFO - Static variable in class org.apache.hadoop.yarn.server.metrics.ApplicationMetricsConstants

R

readLock - Variable in class org.apache.hadoop.yarn.server.security.BaseContainerTokenSecretManager

readLock - Variable in class org.apache.hadoop.yarn.server.security.BaseNMTokenSecretManager

readWriteLock - Variable in class org.apache.hadoop.yarn.server.security.BaseContainerTokenSecretManager

readWriteLock - Variable in class org.apache.hadoop.yarn.server.security.BaseNMTokenSecretManager

reAttachUAM(String, Configuration, ApplicationId, String, String, String, Token<AMRMTokenIdentifier>) - Method in class org.apache.hadoop.yarn.server.uam.UnmanagedAMPoolManager

Re-attach to an existing UAM, using the provided uamIdentifier.

reAttachUAM(Token<AMRMTokenIdentifier>) - Method in class org.apache.hadoop.yarn.server.uam.UnmanagedApplicationManager

Re-attach to an existing UAM in the resource manager.

REDIRECTED_FROM_NODE - Static variable in interface org.apache.hadoop.yarn.server.webapp.YarnWebServiceParams

registerApplicationMaster(RegisterApplicationMasterRequest) - Method in class org.apache.hadoop.yarn.server.api.impl.pb.client.DistributedSchedulingAMProtocolPBClientImpl

registerApplicationMaster(RpcController, YarnServiceProtos.RegisterApplicationMasterRequestProto) - Method in class org.apache.hadoop.yarn.server.api.impl.pb.service.DistributedSchedulingAMProtocolPBServiceImpl

registerApplicationMaster(String, RegisterApplicationMasterRequest) - Method in class org.apache.hadoop.yarn.server.uam.UnmanagedAMPoolManager

Register application master for the UAM.

registerApplicationMaster(RegisterApplicationMasterRequest) - Method in class org.apache.hadoop.yarn.server.uam.UnmanagedApplicationManager

Registers this UnmanagedApplicationManager with the resource manager.

registerApplicationMasterForDistributedScheduling(RegisterApplicationMasterRequest) - Method in interface org.apache.hadoop.yarn.server.api.DistributedSchedulingAMProtocol

Extends the registerApplicationMaster to wrap the response with additional metadata.

registerApplicationMasterForDistributedScheduling(RegisterApplicationMasterRequest) - Method in class org.apache.hadoop.yarn.server.api.impl.pb.client.DistributedSchedulingAMProtocolPBClientImpl

registerApplicationMasterForDistributedScheduling(RpcController, YarnServiceProtos.RegisterApplicationMasterRequestProto) - Method in class org.apache.hadoop.yarn.server.api.impl.pb.service.DistributedSchedulingAMProtocolPBServiceImpl

RegisterDistributedSchedulingAMResponse - Class in org.apache.hadoop.yarn.server.api.protocolrecords

This is the response to registering an Application Master when distributed scheduling is enabled.

RegisterDistributedSchedulingAMResponse() - Constructor for class org.apache.hadoop.yarn.server.api.protocolrecords.RegisterDistributedSchedulingAMResponse

RegisterDistributedSchedulingAMResponsePBImpl - Class in org.apache.hadoop.yarn.server.api.protocolrecords.impl.pb

Implementation of RegisterDistributedSchedulingAMResponse.

RegisterDistributedSchedulingAMResponsePBImpl() - Constructor for class org.apache.hadoop.yarn.server.api.protocolrecords.impl.pb.RegisterDistributedSchedulingAMResponsePBImpl

RegisterDistributedSchedulingAMResponsePBImpl(YarnServerCommonServiceProtos.RegisterDistributedSchedulingAMResponseProto) - Constructor for class org.apache.hadoop.yarn.server.api.protocolrecords.impl.pb.RegisterDistributedSchedulingAMResponsePBImpl

REGISTERED_EVENT_TYPE - Static variable in class org.apache.hadoop.yarn.server.metrics.AppAttemptMetricsConstants

registerNodeManager(RegisterNodeManagerRequest) - Method in class org.apache.hadoop.yarn.server.api.impl.pb.client.ResourceTrackerPBClientImpl

registerNodeManager(RpcController, YarnServerCommonServiceProtos.RegisterNodeManagerRequestProto) - Method in class org.apache.hadoop.yarn.server.api.impl.pb.service.ResourceTrackerPBServiceImpl

registerNodeManager(RegisterNodeManagerRequest) - Method in interface org.apache.hadoop.yarn.server.api.ResourceTracker

RegisterNodeManagerRequest - Class in org.apache.hadoop.yarn.server.api.protocolrecords

RegisterNodeManagerRequest() - Constructor for class org.apache.hadoop.yarn.server.api.protocolrecords.RegisterNodeManagerRequest

RegisterNodeManagerRequestPBImpl - Class in org.apache.hadoop.yarn.server.api.protocolrecords.impl.pb

RegisterNodeManagerRequestPBImpl() - Constructor for class org.apache.hadoop.yarn.server.api.protocolrecords.impl.pb.RegisterNodeManagerRequestPBImpl

RegisterNodeManagerRequestPBImpl(YarnServerCommonServiceProtos.RegisterNodeManagerRequestProto) - Constructor for class org.apache.hadoop.yarn.server.api.protocolrecords.impl.pb.RegisterNodeManagerRequestPBImpl

RegisterNodeManagerResponse - Class in org.apache.hadoop.yarn.server.api.protocolrecords

Node Manager's register response.

RegisterNodeManagerResponse() - Constructor for class org.apache.hadoop.yarn.server.api.protocolrecords.RegisterNodeManagerResponse

RegisterNodeManagerResponsePBImpl - Class in org.apache.hadoop.yarn.server.api.protocolrecords.impl.pb

PBImpl class for RegisterNodeManagerResponse.

RegisterNodeManagerResponsePBImpl() - Constructor for class org.apache.hadoop.yarn.server.api.protocolrecords.impl.pb.RegisterNodeManagerResponsePBImpl

RegisterNodeManagerResponsePBImpl(YarnServerCommonServiceProtos.RegisterNodeManagerResponseProto) - Constructor for class org.apache.hadoop.yarn.server.api.protocolrecords.impl.pb.RegisterNodeManagerResponsePBImpl

registerService(String, String) - Method in class org.apache.hadoop.yarn.lib.ZKClient

register the service to a specific path

registerSubCluster(SubClusterRegisterRequest) - Method in interface org.apache.hadoop.yarn.server.federation.store.FederationMembershipStateStore

Register a subcluster by publishing capabilities as represented by SubClusterInfo to indicate participation in federation.

registerSubCluster(SubClusterRegisterRequest) - Method in class org.apache.hadoop.yarn.server.federation.store.impl.MemoryFederationStateStore

registerSubCluster(SubClusterRegisterRequest) - Method in class org.apache.hadoop.yarn.server.federation.store.impl.SQLFederationStateStore

registerSubCluster(SubClusterRegisterRequest) - Method in class org.apache.hadoop.yarn.server.federation.store.impl.ZookeeperFederationStateStore

reinitialize(FederationPolicyInitializationContext) - Method in class org.apache.hadoop.yarn.server.federation.policies.AbstractConfigurableFederationPolicy

reinitialize(FederationPolicyInitializationContext) - Method in class org.apache.hadoop.yarn.server.federation.policies.amrmproxy.BroadcastAMRMProxyPolicy

reinitialize(FederationPolicyInitializationContext) - Method in class org.apache.hadoop.yarn.server.federation.policies.amrmproxy.LocalityMulticastAMRMProxyPolicy

reinitialize(FederationPolicyInitializationContext) - Method in class org.apache.hadoop.yarn.server.federation.policies.amrmproxy.RejectAMRMProxyPolicy

reinitialize(FederationPolicyInitializationContext) - Method in interface org.apache.hadoop.yarn.server.federation.policies.ConfigurableFederationPolicy

This method is invoked to initialize of update the configuration of policies.

reinitialize(FederationPolicyInitializationContext) - Method in class org.apache.hadoop.yarn.server.federation.policies.router.HashBasedRouterPolicy

reinitialize(FederationPolicyInitializationContext) - Method in class org.apache.hadoop.yarn.server.federation.policies.router.LoadBasedRouterPolicy

reinitialize(FederationPolicyInitializationContext) - Method in class org.apache.hadoop.yarn.server.federation.policies.router.RejectRouterPolicy

reinitialize(FederationPolicyInitializationContext) - Method in class org.apache.hadoop.yarn.server.federation.policies.router.UniformRandomRouterPolicy

reinitialize(FederationStateStore, Configuration) - Method in class org.apache.hadoop.yarn.server.federation.utils.FederationStateStoreFacade

Delete and re-initialize the cache, to force it to use the given configuration.

RejectAllPolicyManager - Class in org.apache.hadoop.yarn.server.federation.policies.manager

This class represents a simple implementation of a FederationPolicyManager.

RejectAllPolicyManager() - Constructor for class org.apache.hadoop.yarn.server.federation.policies.manager.RejectAllPolicyManager

RejectAMRMProxyPolicy - Class in org.apache.hadoop.yarn.server.federation.policies.amrmproxy

An implementation of the FederationAMRMProxyPolicy that simply rejects all requests.

RejectAMRMProxyPolicy() - Constructor for class org.apache.hadoop.yarn.server.federation.policies.amrmproxy.RejectAMRMProxyPolicy

RejectRouterPolicy - Class in org.apache.hadoop.yarn.server.federation.policies.router

This FederationRouterPolicy simply rejects all incoming requests.

RejectRouterPolicy() - Constructor for class org.apache.hadoop.yarn.server.federation.policies.router.RejectRouterPolicy

RemoteNode - Class in org.apache.hadoop.yarn.server.api.protocolrecords

This class is used to encapsulate the NodeId as well as the HTTP address that can be used to communicate with the Node.

RemoteNode() - Constructor for class org.apache.hadoop.yarn.server.api.protocolrecords.RemoteNode

RemoteNodePBImpl - Class in org.apache.hadoop.yarn.server.api.protocolrecords.impl.pb

Implementation of RemoteNode.

RemoteNodePBImpl() - Constructor for class org.apache.hadoop.yarn.server.api.protocolrecords.impl.pb.RemoteNodePBImpl

RemoteNodePBImpl(YarnServerCommonServiceProtos.RemoteNodeProto) - Constructor for class org.apache.hadoop.yarn.server.api.protocolrecords.impl.pb.RemoteNodePBImpl

remove() - Method in class org.apache.hadoop.yarn.server.utils.LeveldbIterator

Removes from the database the last element returned by the iterator.

removeAppFromRegistry(ApplicationId) - Method in class org.apache.hadoop.yarn.server.federation.utils.FederationRegistryClient

Remove an application from registry.

render(HtmlBlock.Block) - Method in class org.apache.hadoop.yarn.server.webapp.AppAttemptBlock

render(HtmlBlock.Block) - Method in class org.apache.hadoop.yarn.server.webapp.AppBlock

render(HtmlBlock.Block) - Method in class org.apache.hadoop.yarn.server.webapp.AppsBlock

render(HtmlBlock.Block) - Method in class org.apache.hadoop.yarn.server.webapp.ContainerBlock

render(HtmlBlock.Block) - Method in class org.apache.hadoop.yarn.server.webapp.ErrorsAndWarningsBlock.ErrorMetrics

render(HtmlBlock.Block) - Method in class org.apache.hadoop.yarn.server.webapp.ErrorsAndWarningsBlock.MetricsBase

render(HtmlBlock.Block) - Method in class org.apache.hadoop.yarn.server.webapp.ErrorsAndWarningsBlock

render(HtmlBlock.Block) - Method in class org.apache.hadoop.yarn.server.webapp.ErrorsAndWarningsBlock.WarningMetrics

renderData(HtmlBlock.Block) - Method in class org.apache.hadoop.yarn.server.webapp.AppsBlock

reportNewCollectorInfo(ReportNewCollectorInfoRequest) - Method in interface org.apache.hadoop.yarn.server.api.CollectorNodemanagerProtocol

The TimelineCollectorManager provides a list of mapping between application and collector's address in ReportNewCollectorInfoRequest to a NodeManager to register collector's info, include: applicationId and REST URI to access collector.

reportNewCollectorInfo(ReportNewCollectorInfoRequest) - Method in class org.apache.hadoop.yarn.server.api.impl.pb.client.CollectorNodemanagerProtocolPBClientImpl

reportNewCollectorInfo(RpcController, YarnServerCommonServiceProtos.ReportNewCollectorInfoRequestProto) - Method in class org.apache.hadoop.yarn.server.api.impl.pb.service.CollectorNodemanagerProtocolPBServiceImpl

ReportNewCollectorInfoRequest - Class in org.apache.hadoop.yarn.server.api.protocolrecords

ReportNewCollectorInfoRequest() - Constructor for class org.apache.hadoop.yarn.server.api.protocolrecords.ReportNewCollectorInfoRequest

ReportNewCollectorInfoRequestPBImpl - Class in org.apache.hadoop.yarn.server.api.protocolrecords.impl.pb

ReportNewCollectorInfoRequestPBImpl() - Constructor for class org.apache.hadoop.yarn.server.api.protocolrecords.impl.pb.ReportNewCollectorInfoRequestPBImpl

ReportNewCollectorInfoRequestPBImpl(YarnServerCommonServiceProtos.ReportNewCollectorInfoRequestProto) - Constructor for class org.apache.hadoop.yarn.server.api.protocolrecords.impl.pb.ReportNewCollectorInfoRequestPBImpl

ReportNewCollectorInfoResponse - Class in org.apache.hadoop.yarn.server.api.protocolrecords

ReportNewCollectorInfoResponse() - Constructor for class org.apache.hadoop.yarn.server.api.protocolrecords.ReportNewCollectorInfoResponse

ReportNewCollectorInfoResponsePBImpl - Class in org.apache.hadoop.yarn.server.api.protocolrecords.impl.pb

ReportNewCollectorInfoResponsePBImpl() - Constructor for class org.apache.hadoop.yarn.server.api.protocolrecords.impl.pb.ReportNewCollectorInfoResponsePBImpl

ReportNewCollectorInfoResponsePBImpl(YarnServerCommonServiceProtos.ReportNewCollectorInfoResponseProto) - Constructor for class org.apache.hadoop.yarn.server.api.protocolrecords.impl.pb.ReportNewCollectorInfoResponsePBImpl

reqAppStates - Variable in class org.apache.hadoop.yarn.server.webapp.AppsBlock

reset() - Method in class org.apache.hadoop.yarn.server.federation.policies.RouterPolicyFacade

This method flushes all cached configurations and policies.

resetContainerIdCounter(long) - Method in class org.apache.hadoop.yarn.server.scheduler.OpportunisticContainerAllocator.ContainerIdGenerator

This method can reset the generator to a specific value.

ResourceManagerConstants - Interface in org.apache.hadoop.yarn.server.api

resourceRequestsTableInit() - Static method in class org.apache.hadoop.yarn.server.webapp.WebPageUtils

ResourceTracker - Interface in org.apache.hadoop.yarn.server.api

This is used by the Node Manager to register/nodeHeartbeat/unregister with the ResourceManager.

ResourceTrackerPB - Interface in org.apache.hadoop.yarn.server.api

ResourceTrackerPBClientImpl - Class in org.apache.hadoop.yarn.server.api.impl.pb.client

ResourceTrackerPBClientImpl(long, InetSocketAddress, Configuration) - Constructor for class org.apache.hadoop.yarn.server.api.impl.pb.client.ResourceTrackerPBClientImpl

ResourceTrackerPBServiceImpl - Class in org.apache.hadoop.yarn.server.api.impl.pb.service

ResourceTrackerPBServiceImpl(ResourceTracker) - Constructor for class org.apache.hadoop.yarn.server.api.impl.pb.service.ResourceTrackerPBServiceImpl

RESPONSE_CONTENT_FORMAT - Static variable in interface org.apache.hadoop.yarn.server.webapp.YarnWebServiceParams

RESPONSE_CONTENT_SIZE - Static variable in interface org.apache.hadoop.yarn.server.webapp.YarnWebServiceParams

retrievePassword(ContainerTokenIdentifier) - Method in class org.apache.hadoop.yarn.server.security.BaseContainerTokenSecretManager

retrievePassword(NMTokenIdentifier) - Method in class org.apache.hadoop.yarn.server.security.BaseNMTokenSecretManager

retrievePasswordInternal(ContainerTokenIdentifier, MasterKeyData) - Method in class org.apache.hadoop.yarn.server.security.BaseContainerTokenSecretManager

retrivePasswordInternal(NMTokenIdentifier, MasterKeyData) - Method in class org.apache.hadoop.yarn.server.security.BaseNMTokenSecretManager

returnToPool(Logger, CallableStatement, Connection, ResultSet) - Static method in class org.apache.hadoop.yarn.server.federation.store.utils.FederationStateStoreUtils

Returns the SQL FederationStateStore connections to the pool.

returnToPool(Logger, CallableStatement, Connection) - Static method in class org.apache.hadoop.yarn.server.federation.store.utils.FederationStateStoreUtils

Returns the SQL FederationStateStore connections to the pool.

RM_INVALID_IDENTIFIER - Static variable in interface org.apache.hadoop.yarn.server.api.ResourceManagerConstants

This states the invalid identifier of Resource Manager.

RMAuthenticationFilter - Class in org.apache.hadoop.yarn.server.security.http

RMAuthenticationFilter() - Constructor for class org.apache.hadoop.yarn.server.security.http.RMAuthenticationFilter

RMAuthenticationFilterInitializer - Class in org.apache.hadoop.yarn.server.security.http

RMAuthenticationFilterInitializer() - Constructor for class org.apache.hadoop.yarn.server.security.http.RMAuthenticationFilterInitializer

RMNMSecurityInfoClass - Class in org.apache.hadoop.yarn.server

RMNMSecurityInfoClass() - Constructor for class org.apache.hadoop.yarn.server.RMNMSecurityInfoClass

routerFederationPolicy - Variable in class org.apache.hadoop.yarn.server.federation.policies.manager.AbstractPolicyManager

RouterPolicyFacade - Class in org.apache.hadoop.yarn.server.federation.policies

This class provides a facade to the policy subsystem, and handles the lifecycle of policies (e.g., refresh from remote, default behaviors etc.).

RouterPolicyFacade(Configuration, FederationStateStoreFacade, SubClusterResolver, SubClusterId) - Constructor for class org.apache.hadoop.yarn.server.federation.policies.RouterPolicyFacade

RPC_PORT_INFO - Static variable in class org.apache.hadoop.yarn.server.metrics.AppAttemptMetricsConstants

rpcPort - Variable in class org.apache.hadoop.yarn.server.webapp.dao.AppAttemptInfo

rpcPort - Variable in class org.apache.hadoop.yarn.server.webapp.dao.AppInfo

run() - Method in class org.apache.hadoop.yarn.server.uam.UnmanagedApplicationManager.AMRequestHandlerThread

runningContainers - Variable in class org.apache.hadoop.yarn.server.webapp.dao.AppInfo

S

SchedulerRequestKey - Class in org.apache.hadoop.yarn.server.scheduler

Composite key for outstanding scheduler requests for any schedulable entity.

SchedulerRequestKey(Priority, long, ContainerId) - Constructor for class org.apache.hadoop.yarn.server.scheduler.SchedulerRequestKey

SCMUploaderCanUploadRequest - Class in org.apache.hadoop.yarn.server.api.protocolrecords

The request from the NodeManager to the SharedCacheManager that requests whether it can upload a resource in the shared cache.

SCMUploaderCanUploadRequest() - Constructor for class org.apache.hadoop.yarn.server.api.protocolrecords.SCMUploaderCanUploadRequest

SCMUploaderCanUploadRequestPBImpl - Class in org.apache.hadoop.yarn.server.api.protocolrecords.impl.pb

SCMUploaderCanUploadRequestPBImpl() - Constructor for class org.apache.hadoop.yarn.server.api.protocolrecords.impl.pb.SCMUploaderCanUploadRequestPBImpl

SCMUploaderCanUploadRequestPBImpl(YarnServerCommonServiceProtos.SCMUploaderCanUploadRequestProto) - Constructor for class org.apache.hadoop.yarn.server.api.protocolrecords.impl.pb.SCMUploaderCanUploadRequestPBImpl

SCMUploaderCanUploadResponse - Class in org.apache.hadoop.yarn.server.api.protocolrecords

The response from the SharedCacheManager to the NodeManager that indicates whether the NodeManager can upload the resource to the shared cache.

SCMUploaderCanUploadResponse() - Constructor for class org.apache.hadoop.yarn.server.api.protocolrecords.SCMUploaderCanUploadResponse

SCMUploaderCanUploadResponsePBImpl - Class in org.apache.hadoop.yarn.server.api.protocolrecords.impl.pb

SCMUploaderCanUploadResponsePBImpl() - Constructor for class org.apache.hadoop.yarn.server.api.protocolrecords.impl.pb.SCMUploaderCanUploadResponsePBImpl

SCMUploaderCanUploadResponsePBImpl(YarnServerCommonServiceProtos.SCMUploaderCanUploadResponseProto) - Constructor for class org.apache.hadoop.yarn.server.api.protocolrecords.impl.pb.SCMUploaderCanUploadResponsePBImpl

SCMUploaderNotifyRequest - Class in org.apache.hadoop.yarn.server.api.protocolrecords

The request from the NodeManager to the SharedCacheManager that notifies that a resource has been uploaded to the shared cache.

SCMUploaderNotifyRequest() - Constructor for class org.apache.hadoop.yarn.server.api.protocolrecords.SCMUploaderNotifyRequest

SCMUploaderNotifyRequestPBImpl - Class in org.apache.hadoop.yarn.server.api.protocolrecords.impl.pb

SCMUploaderNotifyRequestPBImpl() - Constructor for class org.apache.hadoop.yarn.server.api.protocolrecords.impl.pb.SCMUploaderNotifyRequestPBImpl

SCMUploaderNotifyRequestPBImpl(YarnServerCommonServiceProtos.SCMUploaderNotifyRequestProto) - Constructor for class org.apache.hadoop.yarn.server.api.protocolrecords.impl.pb.SCMUploaderNotifyRequestPBImpl

SCMUploaderNotifyResponse - Class in org.apache.hadoop.yarn.server.api.protocolrecords

The response from the SharedCacheManager to the NodeManager that indicates whether the NodeManager needs to delete the cached resource it was sending the notification for.

SCMUploaderNotifyResponse() - Constructor for class org.apache.hadoop.yarn.server.api.protocolrecords.SCMUploaderNotifyResponse

SCMUploaderNotifyResponsePBImpl - Class in org.apache.hadoop.yarn.server.api.protocolrecords.impl.pb

SCMUploaderNotifyResponsePBImpl() - Constructor for class org.apache.hadoop.yarn.server.api.protocolrecords.impl.pb.SCMUploaderNotifyResponsePBImpl

SCMUploaderNotifyResponsePBImpl(YarnServerCommonServiceProtos.SCMUploaderNotifyResponseProto) - Constructor for class org.apache.hadoop.yarn.server.api.protocolrecords.impl.pb.SCMUploaderNotifyResponsePBImpl

SCMUploaderProtocol - Interface in org.apache.hadoop.yarn.server.api

The protocol between a NodeManager's SharedCacheUploadService and the SharedCacheManager.

SCMUploaderProtocolPB - Interface in org.apache.hadoop.yarn.server.api

SCMUploaderProtocolPBClientImpl - Class in org.apache.hadoop.yarn.server.api.impl.pb.client

SCMUploaderProtocolPBClientImpl(long, InetSocketAddress, Configuration) - Constructor for class org.apache.hadoop.yarn.server.api.impl.pb.client.SCMUploaderProtocolPBClientImpl

SCMUploaderProtocolPBServiceImpl - Class in org.apache.hadoop.yarn.server.api.impl.pb.service

SCMUploaderProtocolPBServiceImpl(SCMUploaderProtocol) - Constructor for class org.apache.hadoop.yarn.server.api.impl.pb.service.SCMUploaderProtocolPBServiceImpl

seek(byte[]) - Method in class org.apache.hadoop.yarn.server.utils.LeveldbIterator

Repositions the iterator so the key of the next BlockElement returned greater than or equal to the specified targetKey.

seekToFirst() - Method in class org.apache.hadoop.yarn.server.utils.LeveldbIterator

Repositions the iterator so is is at the beginning of the Database.

seekToLast() - Method in class org.apache.hadoop.yarn.server.utils.LeveldbIterator

Repositions the iterator so it is at the end of of the Database.

serializeConf() - Method in class org.apache.hadoop.yarn.server.federation.policies.manager.AbstractPolicyManager

serializeConf() - Method in interface org.apache.hadoop.yarn.server.federation.policies.manager.FederationPolicyManager

This method is invoked to derive a SubClusterPolicyConfiguration.

serializeConf() - Method in class org.apache.hadoop.yarn.server.federation.policies.manager.PriorityBroadcastPolicyManager

serializeConf() - Method in class org.apache.hadoop.yarn.server.federation.policies.manager.WeightedLocalityPolicyManager

serialNo - Variable in class org.apache.hadoop.yarn.server.security.BaseContainerTokenSecretManager

serialNo - Variable in class org.apache.hadoop.yarn.server.security.BaseNMTokenSecretManager

ServerRMProxy<T> - Class in org.apache.hadoop.yarn.server.api

serviceInit(Configuration) - Method in class org.apache.hadoop.yarn.server.timeline.security.TimelineDelgationTokenSecretManagerService

serviceStart() - Method in class org.apache.hadoop.yarn.server.timeline.security.TimelineDelgationTokenSecretManagerService

serviceStart() - Method in class org.apache.hadoop.yarn.server.uam.UnmanagedAMPoolManager

serviceStop() - Method in class org.apache.hadoop.yarn.server.timeline.security.TimelineDelgationTokenSecretManagerService

serviceStop() - Method in class org.apache.hadoop.yarn.server.uam.UnmanagedAMPoolManager

Normally we should finish all applications before stop.

setAccepted(boolean) - Method in class org.apache.hadoop.yarn.server.api.protocolrecords.impl.pb.SCMUploaderNotifyResponsePBImpl

setAccepted(boolean) - Method in class org.apache.hadoop.yarn.server.api.protocolrecords.SCMUploaderNotifyResponse

Set whether or not the shared cache manager has accepted the notified resource (i.e.

setAllocatedContainers(List<Container>) - Method in class org.apache.hadoop.yarn.server.api.protocolrecords.DistributedSchedulingAllocateRequest

Set the list of newly allocated Container by the Distributed Scheduling component on the NodeManager.

setAllocatedContainers(List<Container>) - Method in class org.apache.hadoop.yarn.server.api.protocolrecords.impl.pb.DistributedSchedulingAllocateRequestPBImpl

setAllocatedResource(Resource) - Method in class org.apache.hadoop.yarn.server.api.protocolrecords.impl.pb.NMContainerStatusPBImpl

setAllocatedResource(Resource) - Method in class org.apache.hadoop.yarn.server.api.protocolrecords.NMContainerStatus

setAllocateRequest(AllocateRequest) - Method in class org.apache.hadoop.yarn.server.api.protocolrecords.DistributedSchedulingAllocateRequest

Set the underlying AllocateRequest object.

setAllocateRequest(AllocateRequest) - Method in class org.apache.hadoop.yarn.server.api.protocolrecords.impl.pb.DistributedSchedulingAllocateRequestPBImpl

setAllocateResponse(AllocateResponse) - Method in class org.apache.hadoop.yarn.server.api.protocolrecords.DistributedSchedulingAllocateResponse

setAllocateResponse(AllocateResponse) - Method in class org.apache.hadoop.yarn.server.api.protocolrecords.impl.pb.DistributedSchedulingAllocateResponsePBImpl

setAllocationRequestId(long) - Method in class org.apache.hadoop.yarn.server.api.protocolrecords.impl.pb.NMContainerStatusPBImpl

setAllocationRequestId(long) - Method in class org.apache.hadoop.yarn.server.api.protocolrecords.NMContainerStatus

Set the ID corresponding to the original allocation request.

setAllocationTags(Set<String>) - Method in class org.apache.hadoop.yarn.server.api.protocolrecords.impl.pb.NMContainerStatusPBImpl

setAllocationTags(Set<String>) - Method in class org.apache.hadoop.yarn.server.api.protocolrecords.NMContainerStatus

setAMRMPolicyWeights(Map<SubClusterIdInfo, Float>) - Method in class org.apache.hadoop.yarn.server.federation.policies.dao.WeightedPolicyInfo

Setter method for ARMRMProxy weights.

setAMRMServiceAddress(String) - Method in class org.apache.hadoop.yarn.server.federation.store.records.impl.pb.SubClusterInfoPBImpl

setAMRMServiceAddress(String) - Method in class org.apache.hadoop.yarn.server.federation.store.records.SubClusterInfo

Set the URL of the AM-RM service endpoint of the subcluster ResourceManager.

setAppCollectors(Map<ApplicationId, AppCollectorData>) - Method in class org.apache.hadoop.yarn.server.api.protocolrecords.impl.pb.NodeHeartbeatResponsePBImpl

setAppCollectors(Map<ApplicationId, AppCollectorData>) - Method in class org.apache.hadoop.yarn.server.api.protocolrecords.NodeHeartbeatResponse

setAppCollectorsList(List<AppCollectorData>) - Method in class org.apache.hadoop.yarn.server.api.protocolrecords.impl.pb.ReportNewCollectorInfoRequestPBImpl

setAppCollectorsList(List<AppCollectorData>) - Method in class org.apache.hadoop.yarn.server.api.protocolrecords.ReportNewCollectorInfoRequest

setApplicationHomeSubCluster(ApplicationHomeSubCluster) - Method in class org.apache.hadoop.yarn.server.federation.store.records.AddApplicationHomeSubClusterRequest

Set the ApplicationHomeSubCluster representing the mapping of the application to it's home sub-cluster.

setApplicationHomeSubCluster(ApplicationHomeSubCluster) - Method in class org.apache.hadoop.yarn.server.federation.store.records.GetApplicationHomeSubClusterResponse

Set the ApplicationHomeSubCluster representing the mapping of the application to it's home sub-cluster.

setApplicationHomeSubCluster(ApplicationHomeSubCluster) - Method in class org.apache.hadoop.yarn.server.federation.store.records.impl.pb.AddApplicationHomeSubClusterRequestPBImpl

setApplicationHomeSubCluster(ApplicationHomeSubCluster) - Method in class org.apache.hadoop.yarn.server.federation.store.records.impl.pb.GetApplicationHomeSubClusterResponsePBImpl

setApplicationHomeSubCluster(ApplicationHomeSubCluster) - Method in class org.apache.hadoop.yarn.server.federation.store.records.impl.pb.UpdateApplicationHomeSubClusterRequestPBImpl

setApplicationHomeSubCluster(ApplicationHomeSubCluster) - Method in class org.apache.hadoop.yarn.server.federation.store.records.UpdateApplicationHomeSubClusterRequest

Set the ApplicationHomeSubCluster representing the mapping of the application to it's home sub-cluster.

setApplicationId(ApplicationId) - Method in class org.apache.hadoop.yarn.server.api.protocolrecords.GetTimelineCollectorContextRequest

setApplicationId(ApplicationId) - Method in class org.apache.hadoop.yarn.server.api.protocolrecords.impl.pb.GetTimelineCollectorContextRequestPBImpl

setApplicationId(ApplicationId) - Method in class org.apache.hadoop.yarn.server.api.protocolrecords.impl.pb.LogAggregationReportPBImpl

setApplicationId(ApplicationId) - Method in class org.apache.hadoop.yarn.server.api.protocolrecords.LogAggregationReport

setApplicationId(ApplicationId) - Method in class org.apache.hadoop.yarn.server.api.records.AppCollectorData

setApplicationId(ApplicationId) - Method in class org.apache.hadoop.yarn.server.api.records.impl.pb.AppCollectorDataPBImpl

setApplicationId(ApplicationId) - Method in class org.apache.hadoop.yarn.server.federation.store.records.ApplicationHomeSubCluster

Set the ApplicationId representing the unique identifier of the application.

setApplicationId(ApplicationId) - Method in class org.apache.hadoop.yarn.server.federation.store.records.DeleteApplicationHomeSubClusterRequest

Set the identifier of the ApplicationId to be removed from Federation state store .

setApplicationId(ApplicationId) - Method in class org.apache.hadoop.yarn.server.federation.store.records.GetApplicationHomeSubClusterRequest

Set the ApplicationId representing the unique identifier of the application.

setApplicationId(ApplicationId) - Method in class org.apache.hadoop.yarn.server.federation.store.records.impl.pb.ApplicationHomeSubClusterPBImpl

setApplicationId(ApplicationId) - Method in class org.apache.hadoop.yarn.server.federation.store.records.impl.pb.DeleteApplicationHomeSubClusterRequestPBImpl

setApplicationId(ApplicationId) - Method in class org.apache.hadoop.yarn.server.federation.store.records.impl.pb.GetApplicationHomeSubClusterRequestPBImpl

setAppsHomeSubClusters(List<ApplicationHomeSubCluster>) - Method in class org.apache.hadoop.yarn.server.federation.store.records.GetApplicationsHomeSubClusterResponse

Set the ApplicationHomeSubCluster list representing the mapping of all submitted applications to it's home sub-cluster.

setAppsHomeSubClusters(List<ApplicationHomeSubCluster>) - Method in class org.apache.hadoop.yarn.server.federation.store.records.impl.pb.GetApplicationsHomeSubClusterResponsePBImpl

setAreNodeLabelsAcceptedByRM(boolean) - Method in class org.apache.hadoop.yarn.server.api.protocolrecords.impl.pb.NodeHeartbeatResponsePBImpl

setAreNodeLabelsAcceptedByRM(boolean) - Method in class org.apache.hadoop.yarn.server.api.protocolrecords.impl.pb.RegisterNodeManagerResponsePBImpl

setAreNodeLabelsAcceptedByRM(boolean) - Method in class org.apache.hadoop.yarn.server.api.protocolrecords.NodeHeartbeatResponse

setAreNodeLabelsAcceptedByRM(boolean) - Method in class org.apache.hadoop.yarn.server.api.protocolrecords.RegisterNodeManagerResponse

setAuthFilterConfig(Configuration) - Method in class org.apache.hadoop.yarn.server.timeline.security.TimelineAuthenticationFilterInitializer

setBytes(ByteBuffer) - Method in class org.apache.hadoop.yarn.server.api.records.impl.pb.MasterKeyPBImpl

setBytes(ByteBuffer) - Method in interface org.apache.hadoop.yarn.server.api.records.MasterKey

setCapability(String) - Method in class org.apache.hadoop.yarn.server.federation.store.records.impl.pb.SubClusterHeartbeatRequestPBImpl

setCapability(String) - Method in class org.apache.hadoop.yarn.server.federation.store.records.impl.pb.SubClusterInfoPBImpl

setCapability(String) - Method in class org.apache.hadoop.yarn.server.federation.store.records.SubClusterHeartbeatRequest

Set the current capacity and utilization of the subCluster.

setCapability(String) - Method in class org.apache.hadoop.yarn.server.federation.store.records.SubClusterInfo

Set the current capacity and utilization of the subCluster.

setClientRMServiceAddress(String) - Method in class org.apache.hadoop.yarn.server.federation.store.records.impl.pb.SubClusterInfoPBImpl

setClientRMServiceAddress(String) - Method in class org.apache.hadoop.yarn.server.federation.store.records.SubClusterInfo

Set the URL of the client-RM service endpoint of the subcluster ResourceManager.

setCollectorAddr(String) - Method in class org.apache.hadoop.yarn.server.api.records.AppCollectorData

setCollectorAddr(String) - Method in class org.apache.hadoop.yarn.server.api.records.impl.pb.AppCollectorDataPBImpl

setCollectorToken(Token) - Method in class org.apache.hadoop.yarn.server.api.records.AppCollectorData

setCollectorToken(Token) - Method in class org.apache.hadoop.yarn.server.api.records.impl.pb.AppCollectorDataPBImpl

setConf(Configuration) - Method in class org.apache.hadoop.yarn.server.federation.resolver.DefaultSubClusterResolverImpl

setContainerExitStatus(int) - Method in class org.apache.hadoop.yarn.server.api.protocolrecords.impl.pb.NMContainerStatusPBImpl

setContainerExitStatus(int) - Method in class org.apache.hadoop.yarn.server.api.protocolrecords.NMContainerStatus

setContainerId(ContainerId) - Method in class org.apache.hadoop.yarn.server.api.protocolrecords.impl.pb.NMContainerStatusPBImpl

setContainerId(ContainerId) - Method in class org.apache.hadoop.yarn.server.api.protocolrecords.NMContainerStatus

setContainerIdGenerator(OpportunisticContainerAllocator.ContainerIdGenerator) - Method in class org.apache.hadoop.yarn.server.scheduler.OpportunisticContainerContext

setContainerIdStart(long) - Method in class org.apache.hadoop.yarn.server.api.protocolrecords.impl.pb.RegisterDistributedSchedulingAMResponsePBImpl

setContainerIdStart(long) - Method in class org.apache.hadoop.yarn.server.api.protocolrecords.RegisterDistributedSchedulingAMResponse

setContainerQueuingLimit(ContainerQueuingLimit) - Method in class org.apache.hadoop.yarn.server.api.protocolrecords.impl.pb.NodeHeartbeatResponsePBImpl

setContainerQueuingLimit(ContainerQueuingLimit) - Method in class org.apache.hadoop.yarn.server.api.protocolrecords.NodeHeartbeatResponse

setContainersStatuses(List<ContainerStatus>) - Method in class org.apache.hadoop.yarn.server.api.records.impl.pb.NodeStatusPBImpl

setContainersStatuses(List<ContainerStatus>) - Method in class org.apache.hadoop.yarn.server.api.records.NodeStatus

setContainerState(ContainerState) - Method in class org.apache.hadoop.yarn.server.api.protocolrecords.impl.pb.NMContainerStatusPBImpl

setContainerState(ContainerState) - Method in class org.apache.hadoop.yarn.server.api.protocolrecords.NMContainerStatus

setContainerStatuses(List<NMContainerStatus>) - Method in class org.apache.hadoop.yarn.server.api.protocolrecords.impl.pb.RegisterNodeManagerRequestPBImpl

setContainerStatuses(List<NMContainerStatus>) - Method in class org.apache.hadoop.yarn.server.api.protocolrecords.RegisterNodeManagerRequest

setContainersUtilization(ResourceUtilization) - Method in class org.apache.hadoop.yarn.server.api.records.impl.pb.NodeStatusPBImpl

setContainersUtilization(ResourceUtilization) - Method in class org.apache.hadoop.yarn.server.api.records.NodeStatus

setContainerTokenExpiryInterval(int) - Method in class org.apache.hadoop.yarn.server.api.protocolrecords.impl.pb.RegisterDistributedSchedulingAMResponsePBImpl

setContainerTokenExpiryInterval(int) - Method in class org.apache.hadoop.yarn.server.api.protocolrecords.RegisterDistributedSchedulingAMResponse

setContainerTokenExpiryInterval(int) - Method in class org.apache.hadoop.yarn.server.scheduler.OpportunisticContainerAllocator.AllocationParams

Set Container Token Expiry time in ms.

setContainerTokenMasterKey(MasterKey) - Method in class org.apache.hadoop.yarn.server.api.protocolrecords.impl.pb.NodeHeartbeatResponsePBImpl

setContainerTokenMasterKey(MasterKey) - Method in class org.apache.hadoop.yarn.server.api.protocolrecords.impl.pb.RegisterNodeManagerResponsePBImpl

setContainerTokenMasterKey(MasterKey) - Method in class org.apache.hadoop.yarn.server.api.protocolrecords.NodeHeartbeatResponse

setContainerTokenMasterKey(MasterKey) - Method in class org.apache.hadoop.yarn.server.api.protocolrecords.RegisterNodeManagerResponse

setCreationTime(long) - Method in class org.apache.hadoop.yarn.server.api.protocolrecords.impl.pb.NMContainerStatusPBImpl

setCreationTime(long) - Method in class org.apache.hadoop.yarn.server.api.protocolrecords.NMContainerStatus

setDelegationTokenSecretManager(AbstractDelegationTokenSecretManager<?>) - Static method in class org.apache.hadoop.yarn.server.security.http.RMAuthenticationFilter

setDiagnosticMessage(String) - Method in class org.apache.hadoop.yarn.server.api.protocolrecords.impl.pb.LogAggregationReportPBImpl

setDiagnosticMessage(String) - Method in class org.apache.hadoop.yarn.server.api.protocolrecords.LogAggregationReport

setDiagnostics(String) - Method in class org.apache.hadoop.yarn.server.api.protocolrecords.impl.pb.NMContainerStatusPBImpl

setDiagnostics(String) - Method in class org.apache.hadoop.yarn.server.api.protocolrecords.NMContainerStatus

setDiagnosticsMessage(String) - Method in class org.apache.hadoop.yarn.server.api.protocolrecords.impl.pb.NodeHeartbeatResponsePBImpl

setDiagnosticsMessage(String) - Method in class org.apache.hadoop.yarn.server.api.protocolrecords.impl.pb.RegisterNodeManagerResponsePBImpl

setDiagnosticsMessage(String) - Method in class org.apache.hadoop.yarn.server.api.protocolrecords.NodeHeartbeatResponse

setDiagnosticsMessage(String) - Method in class org.apache.hadoop.yarn.server.api.protocolrecords.RegisterNodeManagerResponse

setEstimatedQueueWaitTime(int) - Method in class org.apache.hadoop.yarn.server.api.records.impl.pb.OpportunisticContainersStatusPBImpl

setEstimatedQueueWaitTime(int) - Method in class org.apache.hadoop.yarn.server.api.records.OpportunisticContainersStatus

Sets the estimated time that a container will have to wait if added to the queue of the node.

setExecutionType(ExecutionType) - Method in class org.apache.hadoop.yarn.server.api.protocolrecords.impl.pb.NMContainerStatusPBImpl

setExecutionType(ExecutionType) - Method in class org.apache.hadoop.yarn.server.api.protocolrecords.NMContainerStatus

setFederationStateStoreFacade(FederationStateStoreFacade) - Method in class org.apache.hadoop.yarn.server.federation.policies.FederationPolicyInitializationContext

Setter for the FederationStateStoreFacade.

setFederationSubclusterResolver(SubClusterResolver) - Method in class org.apache.hadoop.yarn.server.federation.policies.FederationPolicyInitializationContext

Setter for the SubClusterResolver.

setFilename(String) - Method in class org.apache.hadoop.yarn.server.api.protocolrecords.impl.pb.SCMUploaderNotifyRequestPBImpl

setFilename(String) - Method in class org.apache.hadoop.yarn.server.api.protocolrecords.SCMUploaderNotifyRequest

Set the filename of the resource that was just uploaded to the shared cache.

setFilterInactiveSubClusters(boolean) - Method in class org.apache.hadoop.yarn.server.federation.store.records.GetSubClustersInfoRequest

Set the flag that indicates whether only active sub-clusters should be returned.

setFilterInactiveSubClusters(boolean) - Method in class org.apache.hadoop.yarn.server.federation.store.records.impl.pb.GetSubClustersInfoRequestPBImpl

setFlowName(String) - Method in class org.apache.hadoop.yarn.server.api.protocolrecords.GetTimelineCollectorContextResponse

setFlowName(String) - Method in class org.apache.hadoop.yarn.server.api.protocolrecords.impl.pb.GetTimelineCollectorContextResponsePBImpl

setFlowRunId(long) - Method in class org.apache.hadoop.yarn.server.api.protocolrecords.GetTimelineCollectorContextResponse

setFlowRunId(long) - Method in class org.apache.hadoop.yarn.server.api.protocolrecords.impl.pb.GetTimelineCollectorContextResponsePBImpl

setFlowVersion(String) - Method in class org.apache.hadoop.yarn.server.api.protocolrecords.GetTimelineCollectorContextResponse

setFlowVersion(String) - Method in class org.apache.hadoop.yarn.server.api.protocolrecords.impl.pb.GetTimelineCollectorContextResponsePBImpl

setHeadroomAlpha(float) - Method in class org.apache.hadoop.yarn.server.federation.policies.dao.WeightedPolicyInfo

Set the parameter headroomAlpha, used by policies that balance weight-based and load-based considerations in their decisions.

setHealthReport(String) - Method in class org.apache.hadoop.yarn.server.api.records.impl.pb.NodeHealthStatusPBImpl

setHealthReport(String) - Method in class org.apache.hadoop.yarn.server.api.records.NodeHealthStatus

setHomeSubcluster(SubClusterId) - Method in class org.apache.hadoop.yarn.server.federation.policies.FederationPolicyInitializationContext

Sets in the context the home sub-cluster.

setHomeSubCluster(SubClusterId) - Method in class org.apache.hadoop.yarn.server.federation.store.records.AddApplicationHomeSubClusterResponse

Set the home sub-cluster that this application has been assigned to.

setHomeSubCluster(SubClusterId) - Method in class org.apache.hadoop.yarn.server.federation.store.records.ApplicationHomeSubCluster

Set the SubClusterId representing the unique identifier of the home subcluster in which the ApplicationMaster of the application is running.

setHomeSubCluster(SubClusterId) - Method in class org.apache.hadoop.yarn.server.federation.store.records.impl.pb.AddApplicationHomeSubClusterResponsePBImpl

setHomeSubCluster(SubClusterId) - Method in class org.apache.hadoop.yarn.server.federation.store.records.impl.pb.ApplicationHomeSubClusterPBImpl

setHttpAddress(String) - Method in class org.apache.hadoop.yarn.server.api.protocolrecords.impl.pb.RemoteNodePBImpl

setHttpAddress(String) - Method in class org.apache.hadoop.yarn.server.api.protocolrecords.RemoteNode

Set HTTP address.

setHttpPort(int) - Method in class org.apache.hadoop.yarn.server.api.protocolrecords.impl.pb.RegisterNodeManagerRequestPBImpl

setHttpPort(int) - Method in class org.apache.hadoop.yarn.server.api.protocolrecords.RegisterNodeManagerRequest

setId(String) - Method in class org.apache.hadoop.yarn.server.federation.store.records.impl.pb.SubClusterIdPBImpl

setId(String) - Method in class org.apache.hadoop.yarn.server.federation.store.records.SubClusterId

Set the string identifier of the subcluster which is unique across the federated cluster.

setIncrContainerResource(Resource) - Method in class org.apache.hadoop.yarn.server.api.protocolrecords.impl.pb.RegisterDistributedSchedulingAMResponsePBImpl

setIncrContainerResource(Resource) - Method in class org.apache.hadoop.yarn.server.api.protocolrecords.RegisterDistributedSchedulingAMResponse

setIncreasedContainers(List<Container>) - Method in class org.apache.hadoop.yarn.server.api.records.impl.pb.NodeStatusPBImpl

setIncreasedContainers(List<Container>) - Method in class org.apache.hadoop.yarn.server.api.records.NodeStatus

setIncrementResource(Resource) - Method in class org.apache.hadoop.yarn.server.scheduler.OpportunisticContainerAllocator.AllocationParams

Set Incremental resource.

setIsNodeHealthy(boolean) - Method in class org.apache.hadoop.yarn.server.api.records.impl.pb.NodeHealthStatusPBImpl

setIsNodeHealthy(boolean) - Method in class org.apache.hadoop.yarn.server.api.records.NodeHealthStatus

setKeepAliveApplications(List<ApplicationId>) - Method in class org.apache.hadoop.yarn.server.api.records.impl.pb.NodeStatusPBImpl

setKeepAliveApplications(List<ApplicationId>) - Method in class org.apache.hadoop.yarn.server.api.records.NodeStatus

setKeyId(int) - Method in class org.apache.hadoop.yarn.server.api.records.impl.pb.MasterKeyPBImpl

setKeyId(int) - Method in interface org.apache.hadoop.yarn.server.api.records.MasterKey

setLastHealthReportTime(long) - Method in class org.apache.hadoop.yarn.server.api.records.impl.pb.NodeHealthStatusPBImpl

setLastHealthReportTime(long) - Method in class org.apache.hadoop.yarn.server.api.records.NodeHealthStatus

setLastHeartBeat(long) - Method in class org.apache.hadoop.yarn.server.federation.store.records.impl.pb.SubClusterHeartbeatRequestPBImpl

setLastHeartBeat(long) - Method in class org.apache.hadoop.yarn.server.federation.store.records.impl.pb.SubClusterInfoPBImpl

setLastHeartBeat(long) - Method in class org.apache.hadoop.yarn.server.federation.store.records.SubClusterHeartbeatRequest

Set the last heartbeat time of the subcluster.

setLastHeartBeat(long) - Method in class org.apache.hadoop.yarn.server.federation.store.records.SubClusterInfo

Set the last heartbeat time of the subcluster.

setLastKnownContainerTokenMasterKey(MasterKey) - Method in class org.apache.hadoop.yarn.server.api.protocolrecords.impl.pb.NodeHeartbeatRequestPBImpl

setLastKnownContainerTokenMasterKey(MasterKey) - Method in class org.apache.hadoop.yarn.server.api.protocolrecords.NodeHeartbeatRequest

setLastKnownNMTokenMasterKey(MasterKey) - Method in class org.apache.hadoop.yarn.server.api.protocolrecords.impl.pb.NodeHeartbeatRequestPBImpl

setLastKnownNMTokenMasterKey(MasterKey) - Method in class org.apache.hadoop.yarn.server.api.protocolrecords.NodeHeartbeatRequest

setLastStartTime(long) - Method in class org.apache.hadoop.yarn.server.federation.store.records.impl.pb.SubClusterInfoPBImpl

setLastStartTime(long) - Method in class org.apache.hadoop.yarn.server.federation.store.records.SubClusterInfo

Set the timestamp representing the last start time of the subcluster.

setLogAggregationReportsForApps(List<LogAggregationReport>) - Method in class org.apache.hadoop.yarn.server.api.protocolrecords.impl.pb.NodeHeartbeatRequestPBImpl

setLogAggregationReportsForApps(List<LogAggregationReport>) - Method in class org.apache.hadoop.yarn.server.api.protocolrecords.impl.pb.RegisterNodeManagerRequestPBImpl

setLogAggregationReportsForApps(List<LogAggregationReport>) - Method in class org.apache.hadoop.yarn.server.api.protocolrecords.NodeHeartbeatRequest

setLogAggregationReportsForApps(List<LogAggregationReport>) - Method in class org.apache.hadoop.yarn.server.api.protocolrecords.RegisterNodeManagerRequest

setLogAggregationStatus(LogAggregationStatus) - Method in class org.apache.hadoop.yarn.server.api.protocolrecords.impl.pb.LogAggregationReportPBImpl

setLogAggregationStatus(LogAggregationStatus) - Method in class org.apache.hadoop.yarn.server.api.protocolrecords.LogAggregationReport

setMajorVersion(int) - Method in class org.apache.hadoop.yarn.server.records.impl.pb.VersionPBImpl

setMajorVersion(int) - Method in class org.apache.hadoop.yarn.server.records.Version

setMaxAllocationsPerSchedulerKeyPerRound(int) - Method in class org.apache.hadoop.yarn.server.scheduler.OpportunisticContainerAllocator.AllocationParams

Set the Max Allocations per Scheduler Key per allocation round.

setMaxContainerResource(Resource) - Method in class org.apache.hadoop.yarn.server.api.protocolrecords.impl.pb.RegisterDistributedSchedulingAMResponsePBImpl

setMaxContainerResource(Resource) - Method in class org.apache.hadoop.yarn.server.api.protocolrecords.RegisterDistributedSchedulingAMResponse

setMaxQueueLength(int) - Method in class org.apache.hadoop.yarn.server.api.records.ContainerQueuingLimit

setMaxQueueLength(int) - Method in class org.apache.hadoop.yarn.server.api.records.impl.pb.ContainerQueuingLimitPBImpl

setMaxQueueWaitTimeInMs(int) - Method in class org.apache.hadoop.yarn.server.api.records.ContainerQueuingLimit

setMaxQueueWaitTimeInMs(int) - Method in class org.apache.hadoop.yarn.server.api.records.impl.pb.ContainerQueuingLimitPBImpl

setMaxResource(Resource) - Method in class org.apache.hadoop.yarn.server.scheduler.OpportunisticContainerAllocator.AllocationParams

Set Max Resource.

setMinContainerResource(Resource) - Method in class org.apache.hadoop.yarn.server.api.protocolrecords.impl.pb.RegisterDistributedSchedulingAMResponsePBImpl

setMinContainerResource(Resource) - Method in class org.apache.hadoop.yarn.server.api.protocolrecords.RegisterDistributedSchedulingAMResponse

setMinorVersion(int) - Method in class org.apache.hadoop.yarn.server.records.impl.pb.VersionPBImpl

setMinorVersion(int) - Method in class org.apache.hadoop.yarn.server.records.Version

setMinResource(Resource) - Method in class org.apache.hadoop.yarn.server.scheduler.OpportunisticContainerAllocator.AllocationParams

Set Min Resource.

setNextHeartBeatInterval(long) - Method in class org.apache.hadoop.yarn.server.api.protocolrecords.impl.pb.NodeHeartbeatResponsePBImpl

setNextHeartBeatInterval(long) - Method in class org.apache.hadoop.yarn.server.api.protocolrecords.NodeHeartbeatResponse

setNMTokenMasterKey(MasterKey) - Method in class org.apache.hadoop.yarn.server.api.protocolrecords.impl.pb.NodeHeartbeatResponsePBImpl

setNMTokenMasterKey(MasterKey) - Method in class org.apache.hadoop.yarn.server.api.protocolrecords.impl.pb.RegisterNodeManagerResponsePBImpl

setNMTokenMasterKey(MasterKey) - Method in class org.apache.hadoop.yarn.server.api.protocolrecords.NodeHeartbeatResponse

setNMTokenMasterKey(MasterKey) - Method in class org.apache.hadoop.yarn.server.api.protocolrecords.RegisterNodeManagerResponse

setNMVersion(String) - Method in class org.apache.hadoop.yarn.server.api.protocolrecords.impl.pb.RegisterNodeManagerRequestPBImpl

setNMVersion(String) - Method in class org.apache.hadoop.yarn.server.api.protocolrecords.RegisterNodeManagerRequest

setNodeAction(NodeAction) - Method in class org.apache.hadoop.yarn.server.api.protocolrecords.impl.pb.NodeHeartbeatResponsePBImpl

setNodeAction(NodeAction) - Method in class org.apache.hadoop.yarn.server.api.protocolrecords.impl.pb.RegisterNodeManagerResponsePBImpl

setNodeAction(NodeAction) - Method in class org.apache.hadoop.yarn.server.api.protocolrecords.NodeHeartbeatResponse

setNodeAction(NodeAction) - Method in class org.apache.hadoop.yarn.server.api.protocolrecords.RegisterNodeManagerResponse

setNodeHealthStatus(NodeHealthStatus) - Method in class org.apache.hadoop.yarn.server.api.records.impl.pb.NodeStatusPBImpl

setNodeHealthStatus(NodeHealthStatus) - Method in class org.apache.hadoop.yarn.server.api.records.NodeStatus

setNodeId(NodeId) - Method in class org.apache.hadoop.yarn.server.api.protocolrecords.impl.pb.RegisterNodeManagerRequestPBImpl

setNodeId(NodeId) - Method in class org.apache.hadoop.yarn.server.api.protocolrecords.impl.pb.RemoteNodePBImpl

setNodeId(NodeId) - Method in class org.apache.hadoop.yarn.server.api.protocolrecords.impl.pb.UnRegisterNodeManagerRequestPBImpl

setNodeId(NodeId) - Method in class org.apache.hadoop.yarn.server.api.protocolrecords.RegisterNodeManagerRequest

setNodeId(NodeId) - Method in class org.apache.hadoop.yarn.server.api.protocolrecords.RemoteNode

Set NodeId.

setNodeId(NodeId) - Method in class org.apache.hadoop.yarn.server.api.protocolrecords.UnRegisterNodeManagerRequest

setNodeId(NodeId) - Method in class org.apache.hadoop.yarn.server.api.records.impl.pb.NodeStatusPBImpl

setNodeId(NodeId) - Method in class org.apache.hadoop.yarn.server.api.records.NodeStatus

setNodeLabelExpression(String) - Method in class org.apache.hadoop.yarn.server.api.protocolrecords.impl.pb.NMContainerStatusPBImpl

setNodeLabelExpression(String) - Method in class org.apache.hadoop.yarn.server.api.protocolrecords.NMContainerStatus

setNodeLabels(Set<NodeLabel>) - Method in class org.apache.hadoop.yarn.server.api.protocolrecords.impl.pb.NodeHeartbeatRequestPBImpl

setNodeLabels(Set<NodeLabel>) - Method in class org.apache.hadoop.yarn.server.api.protocolrecords.impl.pb.RegisterNodeManagerRequestPBImpl

setNodeLabels(Set<NodeLabel>) - Method in class org.apache.hadoop.yarn.server.api.protocolrecords.NodeHeartbeatRequest

setNodeLabels(Set<NodeLabel>) - Method in class org.apache.hadoop.yarn.server.api.protocolrecords.RegisterNodeManagerRequest

setNodesForScheduling(List<RemoteNode>) - Method in class org.apache.hadoop.yarn.server.api.protocolrecords.DistributedSchedulingAllocateResponse

setNodesForScheduling(List<RemoteNode>) - Method in class org.apache.hadoop.yarn.server.api.protocolrecords.impl.pb.DistributedSchedulingAllocateResponsePBImpl

setNodesForScheduling(List<RemoteNode>) - Method in class org.apache.hadoop.yarn.server.api.protocolrecords.impl.pb.RegisterDistributedSchedulingAMResponsePBImpl

setNodesForScheduling(List<RemoteNode>) - Method in class org.apache.hadoop.yarn.server.api.protocolrecords.RegisterDistributedSchedulingAMResponse

setNodeStatus(NodeStatus) - Method in class org.apache.hadoop.yarn.server.api.protocolrecords.impl.pb.NodeHeartbeatRequestPBImpl

setNodeStatus(NodeStatus) - Method in class org.apache.hadoop.yarn.server.api.protocolrecords.NodeHeartbeatRequest

setNodeUtilization(ResourceUtilization) - Method in class org.apache.hadoop.yarn.server.api.records.impl.pb.NodeStatusPBImpl

setNodeUtilization(ResourceUtilization) - Method in class org.apache.hadoop.yarn.server.api.records.NodeStatus

setOpportCoresUsed(int) - Method in class org.apache.hadoop.yarn.server.api.records.impl.pb.OpportunisticContainersStatusPBImpl

setOpportCoresUsed(int) - Method in class org.apache.hadoop.yarn.server.api.records.OpportunisticContainersStatus

Sets the CPU cores used on the node for running opportunistic containers.

setOpportMemoryUsed(long) - Method in class org.apache.hadoop.yarn.server.api.records.impl.pb.OpportunisticContainersStatusPBImpl

setOpportMemoryUsed(long) - Method in class org.apache.hadoop.yarn.server.api.records.OpportunisticContainersStatus

Sets the memory used on the node for running opportunistic containers.

setOpportQueueCapacity(int) - Method in class org.apache.hadoop.yarn.server.api.records.impl.pb.OpportunisticContainersStatusPBImpl

setOpportQueueCapacity(int) - Method in class org.apache.hadoop.yarn.server.api.records.OpportunisticContainersStatus

Sets the capacity of the opportunistic containers queue on the node.

setOpportunisticContainersStatus(OpportunisticContainersStatus) - Method in class org.apache.hadoop.yarn.server.api.records.impl.pb.NodeStatusPBImpl

setOpportunisticContainersStatus(OpportunisticContainersStatus) - Method in class org.apache.hadoop.yarn.server.api.records.NodeStatus

setParams(ByteBuffer) - Method in class org.apache.hadoop.yarn.server.federation.store.records.impl.pb.SubClusterPolicyConfigurationPBImpl

setParams(ByteBuffer) - Method in class org.apache.hadoop.yarn.server.federation.store.records.SubClusterPolicyConfiguration

Set the policy parameters.

setPassword(HikariDataSource, String) - Static method in class org.apache.hadoop.yarn.server.federation.store.utils.FederationStateStoreUtils

Sets a specific password for HikariDataSource SQL connections.

setPhysicalResource(Resource) - Method in class org.apache.hadoop.yarn.server.api.protocolrecords.impl.pb.RegisterNodeManagerRequestPBImpl

setPhysicalResource(Resource) - Method in class org.apache.hadoop.yarn.server.api.protocolrecords.RegisterNodeManagerRequest

Set the physical resources in the node to properly estimate resource utilization.

setPoliciesConfigs(List<SubClusterPolicyConfiguration>) - Method in class org.apache.hadoop.yarn.server.federation.store.records.GetSubClusterPoliciesConfigurationsResponse

Sets all the policies configured in the system.

setPoliciesConfigs(List<SubClusterPolicyConfiguration>) - Method in class org.apache.hadoop.yarn.server.federation.store.records.impl.pb.GetSubClusterPoliciesConfigurationsResponsePBImpl

setPolicyConfiguration(SetSubClusterPolicyConfigurationRequest) - Method in interface org.apache.hadoop.yarn.server.federation.store.FederationPolicyStore

Set the policy configuration for a given queue.

setPolicyConfiguration(SetSubClusterPolicyConfigurationRequest) - Method in class org.apache.hadoop.yarn.server.federation.store.impl.MemoryFederationStateStore

setPolicyConfiguration(SetSubClusterPolicyConfigurationRequest) - Method in class org.apache.hadoop.yarn.server.federation.store.impl.SQLFederationStateStore

setPolicyConfiguration(SetSubClusterPolicyConfigurationRequest) - Method in class org.apache.hadoop.yarn.server.federation.store.impl.ZookeeperFederationStateStore

setPolicyConfiguration(SubClusterPolicyConfiguration) - Method in class org.apache.hadoop.yarn.server.federation.store.records.GetSubClusterPolicyConfigurationResponse

Sets the policyConfiguration configuration.

setPolicyConfiguration(SubClusterPolicyConfiguration) - Method in class org.apache.hadoop.yarn.server.federation.store.records.impl.pb.GetSubClusterPolicyConfigurationResponsePBImpl

setPolicyConfiguration(SubClusterPolicyConfiguration) - Method in class org.apache.hadoop.yarn.server.federation.store.records.impl.pb.SetSubClusterPolicyConfigurationRequestPBImpl

setPolicyConfiguration(SubClusterPolicyConfiguration) - Method in class org.apache.hadoop.yarn.server.federation.store.records.SetSubClusterPolicyConfigurationRequest

Set the policyConfiguration configuration for the queue.

setPolicyContext(FederationPolicyInitializationContext) - Method in class org.apache.hadoop.yarn.server.federation.policies.AbstractConfigurableFederationPolicy

Setter method for the FederationPolicyInitializationContext.

setPolicyInfo(WeightedPolicyInfo) - Method in class org.apache.hadoop.yarn.server.federation.policies.AbstractConfigurableFederationPolicy

Setter method for the configuration weights.

setPriority(Priority) - Method in class org.apache.hadoop.yarn.server.api.protocolrecords.impl.pb.NMContainerStatusPBImpl

setPriority(Priority) - Method in class org.apache.hadoop.yarn.server.api.protocolrecords.NMContainerStatus

setProperty(HikariDataSource, String, String) - Static method in class org.apache.hadoop.yarn.server.federation.store.utils.FederationStateStoreUtils

Sets a specific value for a specific property of HikariDataSource SQL connections.

setQueue(String) - Method in class org.apache.hadoop.yarn.server.federation.policies.manager.AbstractPolicyManager

setQueue(String) - Method in interface org.apache.hadoop.yarn.server.federation.policies.manager.FederationPolicyManager

This methods provides a setter for the queue this policy is specified for.

setQueue(String) - Method in class org.apache.hadoop.yarn.server.federation.store.records.GetSubClusterPolicyConfigurationRequest

Sets the name of the queue for which we are requesting a policy configuration.

setQueue(String) - Method in class org.apache.hadoop.yarn.server.federation.store.records.impl.pb.GetSubClusterPolicyConfigurationRequestPBImpl

setQueue(String) - Method in class org.apache.hadoop.yarn.server.federation.store.records.impl.pb.SubClusterPolicyConfigurationPBImpl

setQueue(String) - Method in class org.apache.hadoop.yarn.server.federation.store.records.SubClusterPolicyConfiguration

Sets the name of the queue for which we are configuring a policy.

setQueuedOpportContainers(int) - Method in class org.apache.hadoop.yarn.server.api.records.impl.pb.OpportunisticContainersStatusPBImpl

setQueuedOpportContainers(int) - Method in class org.apache.hadoop.yarn.server.api.records.OpportunisticContainersStatus

Sets the number of queued opportunistic containers on the node.

setRackName(String) - Method in class org.apache.hadoop.yarn.server.api.protocolrecords.impl.pb.RemoteNodePBImpl

setRackName(String) - Method in class org.apache.hadoop.yarn.server.api.protocolrecords.RemoteNode

Set Rack Name.

setRegisteringCollectors(Map<ApplicationId, AppCollectorData>) - Method in class org.apache.hadoop.yarn.server.api.protocolrecords.impl.pb.NodeHeartbeatRequestPBImpl

setRegisteringCollectors(Map<ApplicationId, AppCollectorData>) - Method in class org.apache.hadoop.yarn.server.api.protocolrecords.NodeHeartbeatRequest

setRegisterResponse(RegisterApplicationMasterResponse) - Method in class org.apache.hadoop.yarn.server.api.protocolrecords.impl.pb.RegisterDistributedSchedulingAMResponsePBImpl

setRegisterResponse(RegisterApplicationMasterResponse) - Method in class org.apache.hadoop.yarn.server.api.protocolrecords.RegisterDistributedSchedulingAMResponse

setResource(Resource) - Method in class org.apache.hadoop.yarn.server.api.protocolrecords.impl.pb.NodeHeartbeatResponsePBImpl

setResource(Resource) - Method in class org.apache.hadoop.yarn.server.api.protocolrecords.impl.pb.RegisterNodeManagerRequestPBImpl

setResource(Resource) - Method in class org.apache.hadoop.yarn.server.api.protocolrecords.impl.pb.RegisterNodeManagerResponsePBImpl

setResource(Resource) - Method in class org.apache.hadoop.yarn.server.api.protocolrecords.NodeHeartbeatResponse

setResource(Resource) - Method in class org.apache.hadoop.yarn.server.api.protocolrecords.RegisterNodeManagerRequest

setResource(Resource) - Method in class org.apache.hadoop.yarn.server.api.protocolrecords.RegisterNodeManagerResponse

setResourceKey(String) - Method in class org.apache.hadoop.yarn.server.api.protocolrecords.impl.pb.SCMUploaderCanUploadRequestPBImpl

setResourceKey(String) - Method in class org.apache.hadoop.yarn.server.api.protocolrecords.impl.pb.SCMUploaderNotifyRequestPBImpl

setResourceKey(String) - Method in class org.apache.hadoop.yarn.server.api.protocolrecords.SCMUploaderCanUploadRequest

Set the key of the resource that would be uploaded to the shared cache.

setResourceKey(String) - Method in class org.apache.hadoop.yarn.server.api.protocolrecords.SCMUploaderNotifyRequest

Set the key of the resource that was just uploaded to the shared cache.

setResponseId(int) - Method in class org.apache.hadoop.yarn.server.api.protocolrecords.impl.pb.NodeHeartbeatResponsePBImpl

setResponseId(int) - Method in class org.apache.hadoop.yarn.server.api.protocolrecords.NodeHeartbeatResponse

setResponseId(int) - Method in class org.apache.hadoop.yarn.server.api.records.impl.pb.NodeStatusPBImpl

setResponseId(int) - Method in class org.apache.hadoop.yarn.server.api.records.NodeStatus

setRMAdminServiceAddress(String) - Method in class org.apache.hadoop.yarn.server.federation.store.records.impl.pb.SubClusterInfoPBImpl

setRMAdminServiceAddress(String) - Method in class org.apache.hadoop.yarn.server.federation.store.records.SubClusterInfo

Set the URL of the ResourceManager administration service.

setRMIdentifier(long) - Method in class org.apache.hadoop.yarn.server.api.protocolrecords.impl.pb.RegisterNodeManagerResponsePBImpl

setRMIdentifier(long) - Method in class org.apache.hadoop.yarn.server.api.protocolrecords.RegisterNodeManagerResponse

setRMIdentifier(long) - Method in class org.apache.hadoop.yarn.server.api.records.AppCollectorData

setRMIdentifier(long) - Method in class org.apache.hadoop.yarn.server.api.records.impl.pb.AppCollectorDataPBImpl

setRMVersion(String) - Method in class org.apache.hadoop.yarn.server.api.protocolrecords.impl.pb.RegisterNodeManagerResponsePBImpl

setRMVersion(String) - Method in class org.apache.hadoop.yarn.server.api.protocolrecords.RegisterNodeManagerResponse

setRMWebServiceAddress(String) - Method in class org.apache.hadoop.yarn.server.federation.store.records.impl.pb.SubClusterInfoPBImpl

setRMWebServiceAddress(String) - Method in class org.apache.hadoop.yarn.server.federation.store.records.SubClusterInfo

Set the URL of the ResourceManager web application interface.

setRouterPolicyWeights(Map<SubClusterIdInfo, Float>) - Method in class org.apache.hadoop.yarn.server.federation.policies.dao.WeightedPolicyInfo

Setter method for Router weights.

setRunningApplications(List<ApplicationId>) - Method in class org.apache.hadoop.yarn.server.api.protocolrecords.impl.pb.RegisterNodeManagerRequestPBImpl

setRunningApplications(List<ApplicationId>) - Method in class org.apache.hadoop.yarn.server.api.protocolrecords.RegisterNodeManagerRequest

Setter for RegisterNodeManagerRequest.getRunningApplications()

setRunningOpportContainers(int) - Method in class org.apache.hadoop.yarn.server.api.records.impl.pb.OpportunisticContainersStatusPBImpl

setRunningOpportContainers(int) - Method in class org.apache.hadoop.yarn.server.api.records.OpportunisticContainersStatus

Sets the number of running opportunistic containers.

setState(SubClusterState) - Method in class org.apache.hadoop.yarn.server.federation.store.records.impl.pb.SubClusterDeregisterRequestPBImpl

setState(SubClusterState) - Method in class org.apache.hadoop.yarn.server.federation.store.records.impl.pb.SubClusterHeartbeatRequestPBImpl

setState(SubClusterState) - Method in class org.apache.hadoop.yarn.server.federation.store.records.impl.pb.SubClusterInfoPBImpl

setState(SubClusterState) - Method in class org.apache.hadoop.yarn.server.federation.store.records.SubClusterDeregisterRequest

Set the SubClusterState of the subcluster.

setState(SubClusterState) - Method in class org.apache.hadoop.yarn.server.federation.store.records.SubClusterHeartbeatRequest

Set the SubClusterState of the subcluster.

setState(SubClusterState) - Method in class org.apache.hadoop.yarn.server.federation.store.records.SubClusterInfo

Set the SubClusterState of the subcluster.

setSubClusterId(SubClusterId) - Method in class org.apache.hadoop.yarn.server.federation.store.records.GetSubClusterInfoRequest

Set the SubClusterId representing the unique identifier of the subcluster.

setSubClusterId(SubClusterId) - Method in class org.apache.hadoop.yarn.server.federation.store.records.impl.pb.GetSubClusterInfoRequestPBImpl

setSubClusterId(SubClusterId) - Method in class org.apache.hadoop.yarn.server.federation.store.records.impl.pb.SubClusterDeregisterRequestPBImpl

setSubClusterId(SubClusterId) - Method in class org.apache.hadoop.yarn.server.federation.store.records.impl.pb.SubClusterHeartbeatRequestPBImpl

setSubClusterId(SubClusterId) - Method in class org.apache.hadoop.yarn.server.federation.store.records.impl.pb.SubClusterInfoPBImpl

setSubClusterId(SubClusterId) - Method in class org.apache.hadoop.yarn.server.federation.store.records.SubClusterDeregisterRequest

Set the SubClusterId representing the unique identifier of the subcluster.

setSubClusterId(SubClusterId) - Method in class org.apache.hadoop.yarn.server.federation.store.records.SubClusterHeartbeatRequest

Set the SubClusterId representing the unique identifier of the subCluster.

setSubClusterId(SubClusterId) - Method in class org.apache.hadoop.yarn.server.federation.store.records.SubClusterInfo

Set the SubClusterId representing the unique identifier of the subCluster.

setSubClusterInfo(SubClusterInfo) - Method in class org.apache.hadoop.yarn.server.federation.store.records.GetSubClusterInfoResponse

Set the SubClusterInfo encapsulating the information about the sub-cluster.

setSubClusterInfo(SubClusterInfo) - Method in class org.apache.hadoop.yarn.server.federation.store.records.impl.pb.GetSubClusterInfoResponsePBImpl

setSubClusterInfo(SubClusterInfo) - Method in class org.apache.hadoop.yarn.server.federation.store.records.impl.pb.SubClusterRegisterRequestPBImpl

setSubClusterInfo(SubClusterInfo) - Method in class org.apache.hadoop.yarn.server.federation.store.records.SubClusterRegisterRequest

Set the SubClusterInfo encapsulating the information about the sub-cluster.

setSubClusterPolicyConfiguration(SubClusterPolicyConfiguration) - Method in class org.apache.hadoop.yarn.server.federation.policies.FederationPolicyInitializationContext

Setter for the SubClusterPolicyConfiguration.

SetSubClusterPolicyConfigurationRequest - Class in org.apache.hadoop.yarn.server.federation.store.records

SetSubClusterPolicyConfigurationRequest is a request to the FederationPolicyStore to set the policy configuration corresponding to a queue.

SetSubClusterPolicyConfigurationRequest() - Constructor for class org.apache.hadoop.yarn.server.federation.store.records.SetSubClusterPolicyConfigurationRequest

SetSubClusterPolicyConfigurationRequestPBImpl - Class in org.apache.hadoop.yarn.server.federation.store.records.impl.pb

Protocol buffer based implementation of SetSubClusterPolicyConfigurationRequest.

SetSubClusterPolicyConfigurationRequestPBImpl() - Constructor for class org.apache.hadoop.yarn.server.federation.store.records.impl.pb.SetSubClusterPolicyConfigurationRequestPBImpl

SetSubClusterPolicyConfigurationRequestPBImpl(YarnServerFederationProtos.SetSubClusterPolicyConfigurationRequestProto) - Constructor for class org.apache.hadoop.yarn.server.federation.store.records.impl.pb.SetSubClusterPolicyConfigurationRequestPBImpl

SetSubClusterPolicyConfigurationResponse - Class in org.apache.hadoop.yarn.server.federation.store.records

SetSubClusterPolicyConfigurationResponse contains the answer from the FederationPolicyStore to a request to set for a policy configuration for a given queue.

SetSubClusterPolicyConfigurationResponse() - Constructor for class org.apache.hadoop.yarn.server.federation.store.records.SetSubClusterPolicyConfigurationResponse

SetSubClusterPolicyConfigurationResponsePBImpl - Class in org.apache.hadoop.yarn.server.federation.store.records.impl.pb

Protocol buffer based implementation of SetSubClusterPolicyConfigurationResponse.

SetSubClusterPolicyConfigurationResponsePBImpl() - Constructor for class org.apache.hadoop.yarn.server.federation.store.records.impl.pb.SetSubClusterPolicyConfigurationResponsePBImpl

SetSubClusterPolicyConfigurationResponsePBImpl(YarnServerFederationProtos.SetSubClusterPolicyConfigurationResponseProto) - Constructor for class org.apache.hadoop.yarn.server.federation.store.records.impl.pb.SetSubClusterPolicyConfigurationResponsePBImpl

setSubClusters(List<SubClusterInfo>) - Method in class org.apache.hadoop.yarn.server.federation.store.records.GetSubClustersInfoResponse

Set the list of SubClusterInfo representing the information about all sub-clusters that are currently participating in Federation.

setSubClusters(List<SubClusterInfo>) - Method in class org.apache.hadoop.yarn.server.federation.store.records.impl.pb.GetSubClustersInfoResponsePBImpl

setSystemCredentialsForApps(Map<ApplicationId, ByteBuffer>) - Method in class org.apache.hadoop.yarn.server.api.protocolrecords.impl.pb.NodeHeartbeatResponsePBImpl

setSystemCredentialsForApps(Map<ApplicationId, ByteBuffer>) - Method in class org.apache.hadoop.yarn.server.api.protocolrecords.NodeHeartbeatResponse

setTimelineDelegationTokenSecretManager(AbstractDelegationTokenSecretManager<TimelineDelegationTokenIdentifier>) - Static method in class org.apache.hadoop.yarn.server.timeline.security.TimelineAuthenticationFilter

setTimelineFilters(Configuration, String, Set<String>) - Static method in class org.apache.hadoop.yarn.server.util.timeline.TimelineServerUtils

Sets filter initializers configuration based on existing configuration and default filters added by timeline service(such as timeline auth filter and CORS filter).

setType(String) - Method in class org.apache.hadoop.yarn.server.federation.store.records.impl.pb.SubClusterPolicyConfigurationPBImpl

setType(String) - Method in class org.apache.hadoop.yarn.server.federation.store.records.SubClusterPolicyConfiguration

Sets the type of the policy.

setUploadable(boolean) - Method in class org.apache.hadoop.yarn.server.api.protocolrecords.impl.pb.SCMUploaderCanUploadResponsePBImpl

setUploadable(boolean) - Method in class org.apache.hadoop.yarn.server.api.protocolrecords.SCMUploaderCanUploadResponse

Set whether or not the node manager can upload the resource to the shared cache.

setUserId(String) - Method in class org.apache.hadoop.yarn.server.api.protocolrecords.GetTimelineCollectorContextResponse

setUserId(String) - Method in class org.apache.hadoop.yarn.server.api.protocolrecords.impl.pb.GetTimelineCollectorContextResponsePBImpl

setUsername(HikariDataSource, String) - Static method in class org.apache.hadoop.yarn.server.federation.store.utils.FederationStateStoreUtils

Sets a specific username for HikariDataSource SQL connections.

setVersion(int) - Method in class org.apache.hadoop.yarn.server.api.protocolrecords.impl.pb.NMContainerStatusPBImpl

setVersion(int) - Method in class org.apache.hadoop.yarn.server.api.protocolrecords.NMContainerStatus

setVersion(long) - Method in class org.apache.hadoop.yarn.server.api.records.AppCollectorData

setVersion(long) - Method in class org.apache.hadoop.yarn.server.api.records.impl.pb.AppCollectorDataPBImpl

setWaitQueueLength(int) - Method in class org.apache.hadoop.yarn.server.api.records.impl.pb.OpportunisticContainersStatusPBImpl

setWaitQueueLength(int) - Method in class org.apache.hadoop.yarn.server.api.records.OpportunisticContainersStatus

Sets the length of the containers queue on the node.

setWeightedPolicyInfo(WeightedPolicyInfo) - Method in class org.apache.hadoop.yarn.server.federation.policies.manager.PriorityBroadcastPolicyManager

setWeightedPolicyInfo(WeightedPolicyInfo) - Method in class org.apache.hadoop.yarn.server.federation.policies.manager.WeightedLocalityPolicyManager

SharedCacheUtil - Class in org.apache.hadoop.yarn.server.sharedcache

A utility class that contains helper methods for dealing with the internal shared cache structure.

SharedCacheUtil() - Constructor for class org.apache.hadoop.yarn.server.sharedcache.SharedCacheUtil

shutdown() - Method in class org.apache.hadoop.yarn.server.uam.UnmanagedApplicationManager.AMRequestHandlerThread

Shutdown the thread.

splitResourceRequests(List<ResourceRequest>) - Method in class org.apache.hadoop.yarn.server.federation.policies.amrmproxy.BroadcastAMRMProxyPolicy

splitResourceRequests(List<ResourceRequest>) - Method in interface org.apache.hadoop.yarn.server.federation.policies.amrmproxy.FederationAMRMProxyPolicy

Splits the ResourceRequests from the client across one or more sub-clusters based on the policy semantics (e.g., broadcast, load-based).

splitResourceRequests(List<ResourceRequest>) - Method in class org.apache.hadoop.yarn.server.federation.policies.amrmproxy.LocalityMulticastAMRMProxyPolicy

splitResourceRequests(List<ResourceRequest>) - Method in class org.apache.hadoop.yarn.server.federation.policies.amrmproxy.RejectAMRMProxyPolicy

SQLFederationStateStore - Class in org.apache.hadoop.yarn.server.federation.store.impl

SQL implementation of FederationStateStore.

SQLFederationStateStore() - Constructor for class org.apache.hadoop.yarn.server.federation.store.impl.SQLFederationStateStore

startedTime - Variable in class org.apache.hadoop.yarn.server.webapp.dao.AppAttemptInfo

startedTime - Variable in class org.apache.hadoop.yarn.server.webapp.dao.AppInfo

startedTime - Variable in class org.apache.hadoop.yarn.server.webapp.dao.ContainerInfo

STATE_EVENT_INFO - Static variable in class org.apache.hadoop.yarn.server.metrics.ApplicationMetricsConstants

STATE_INFO - Static variable in class org.apache.hadoop.yarn.server.metrics.AppAttemptMetricsConstants

STATE_INFO - Static variable in class org.apache.hadoop.yarn.server.metrics.ContainerMetricsConstants

STATE_UPDATED_EVENT_TYPE - Static variable in class org.apache.hadoop.yarn.server.metrics.ApplicationMetricsConstants

SubClusterDeregisterRequest - Class in org.apache.hadoop.yarn.server.federation.store.records

The request sent to set the state of a subcluster to either SC_DECOMMISSIONED, SC_LOST, or SC_DEREGISTERED.

SubClusterDeregisterRequest() - Constructor for class org.apache.hadoop.yarn.server.federation.store.records.SubClusterDeregisterRequest

SubClusterDeregisterRequestPBImpl - Class in org.apache.hadoop.yarn.server.federation.store.records.impl.pb

Protocol buffer based implementation of SubClusterDeregisterRequest.

SubClusterDeregisterRequestPBImpl() - Constructor for class org.apache.hadoop.yarn.server.federation.store.records.impl.pb.SubClusterDeregisterRequestPBImpl

SubClusterDeregisterRequestPBImpl(YarnServerFederationProtos.SubClusterDeregisterRequestProto) - Constructor for class org.apache.hadoop.yarn.server.federation.store.records.impl.pb.SubClusterDeregisterRequestPBImpl

SubClusterDeregisterResponse - Class in org.apache.hadoop.yarn.server.federation.store.records

SubClusterDeregisterResponse contains the answer from the FederationMembershipStateStore to a request to deregister the sub cluster.

SubClusterDeregisterResponse() - Constructor for class org.apache.hadoop.yarn.server.federation.store.records.SubClusterDeregisterResponse

SubClusterDeregisterResponsePBImpl - Class in org.apache.hadoop.yarn.server.federation.store.records.impl.pb

Protocol buffer based implementation of SubClusterDeregisterResponse.

SubClusterDeregisterResponsePBImpl() - Constructor for class org.apache.hadoop.yarn.server.federation.store.records.impl.pb.SubClusterDeregisterResponsePBImpl

SubClusterDeregisterResponsePBImpl(YarnServerFederationProtos.SubClusterDeregisterResponseProto) - Constructor for class org.apache.hadoop.yarn.server.federation.store.records.impl.pb.SubClusterDeregisterResponsePBImpl

subClusterHeartbeat(SubClusterHeartbeatRequest) - Method in interface org.apache.hadoop.yarn.server.federation.store.FederationMembershipStateStore

Periodic heartbeat from a ResourceManager participating in federation to indicate liveliness.

subClusterHeartbeat(SubClusterHeartbeatRequest) - Method in class org.apache.hadoop.yarn.server.federation.store.impl.MemoryFederationStateStore

subClusterHeartbeat(SubClusterHeartbeatRequest) - Method in class org.apache.hadoop.yarn.server.federation.store.impl.SQLFederationStateStore

subClusterHeartbeat(SubClusterHeartbeatRequest) - Method in class org.apache.hadoop.yarn.server.federation.store.impl.ZookeeperFederationStateStore

SubClusterHeartbeatRequest - Class in org.apache.hadoop.yarn.server.federation.store.records

SubClusterHeartbeatRequest is a report of the runtime information of the subcluster that is participating in federation.

SubClusterHeartbeatRequest() - Constructor for class org.apache.hadoop.yarn.server.federation.store.records.SubClusterHeartbeatRequest

SubClusterHeartbeatRequestPBImpl - Class in org.apache.hadoop.yarn.server.federation.store.records.impl.pb

Protocol buffer based implementation of SubClusterHeartbeatRequest.

SubClusterHeartbeatRequestPBImpl() - Constructor for class org.apache.hadoop.yarn.server.federation.store.records.impl.pb.SubClusterHeartbeatRequestPBImpl

SubClusterHeartbeatRequestPBImpl(YarnServerFederationProtos.SubClusterHeartbeatRequestProto) - Constructor for class org.apache.hadoop.yarn.server.federation.store.records.impl.pb.SubClusterHeartbeatRequestPBImpl

SubClusterHeartbeatResponse - Class in org.apache.hadoop.yarn.server.federation.store.records

SubClusterHeartbeatResponse contains the response from the FederationMembershipStateStore to a periodic heartbeat to indicate liveliness from a ResourceManager participating in federation.

SubClusterHeartbeatResponse() - Constructor for class org.apache.hadoop.yarn.server.federation.store.records.SubClusterHeartbeatResponse

SubClusterHeartbeatResponsePBImpl - Class in org.apache.hadoop.yarn.server.federation.store.records.impl.pb

Protocol buffer based implementation of SubClusterHeartbeatResponse.

SubClusterHeartbeatResponsePBImpl() - Constructor for class org.apache.hadoop.yarn.server.federation.store.records.impl.pb.SubClusterHeartbeatResponsePBImpl

SubClusterHeartbeatResponsePBImpl(YarnServerFederationProtos.SubClusterHeartbeatResponseProto) - Constructor for class org.apache.hadoop.yarn.server.federation.store.records.impl.pb.SubClusterHeartbeatResponsePBImpl

SubClusterId - Class in org.apache.hadoop.yarn.server.federation.store.records

SubClusterId represents the globally unique identifier for a subcluster that is participating in federation.

SubClusterId() - Constructor for class org.apache.hadoop.yarn.server.federation.store.records.SubClusterId

SubClusterIdInfo - Class in org.apache.hadoop.yarn.server.federation.store.records

This class represent a sub-cluster identifier in the JSON representation of the policy configuration.

SubClusterIdInfo() - Constructor for class org.apache.hadoop.yarn.server.federation.store.records.SubClusterIdInfo

SubClusterIdInfo(String) - Constructor for class org.apache.hadoop.yarn.server.federation.store.records.SubClusterIdInfo

SubClusterIdInfo(SubClusterId) - Constructor for class org.apache.hadoop.yarn.server.federation.store.records.SubClusterIdInfo

SubClusterIdPBImpl - Class in org.apache.hadoop.yarn.server.federation.store.records.impl.pb

Protocol buffer based implementation of SubClusterId.

SubClusterIdPBImpl() - Constructor for class org.apache.hadoop.yarn.server.federation.store.records.impl.pb.SubClusterIdPBImpl

SubClusterIdPBImpl(YarnServerFederationProtos.SubClusterIdProto) - Constructor for class org.apache.hadoop.yarn.server.federation.store.records.impl.pb.SubClusterIdPBImpl

SubClusterInfo - Class in org.apache.hadoop.yarn.server.federation.store.records

SubClusterInfo is a report of the runtime information of the subcluster that is participating in federation.

SubClusterInfo() - Constructor for class org.apache.hadoop.yarn.server.federation.store.records.SubClusterInfo

SubClusterInfoPBImpl - Class in org.apache.hadoop.yarn.server.federation.store.records.impl.pb

Protocol buffer based implementation of SubClusterInfo.

SubClusterInfoPBImpl() - Constructor for class org.apache.hadoop.yarn.server.federation.store.records.impl.pb.SubClusterInfoPBImpl

SubClusterInfoPBImpl(YarnServerFederationProtos.SubClusterInfoProto) - Constructor for class org.apache.hadoop.yarn.server.federation.store.records.impl.pb.SubClusterInfoPBImpl

SubClusterPolicyConfiguration - Class in org.apache.hadoop.yarn.server.federation.store.records

SubClusterPolicyConfiguration is a class that represents a configuration of a policy.

SubClusterPolicyConfiguration() - Constructor for class org.apache.hadoop.yarn.server.federation.store.records.SubClusterPolicyConfiguration

SubClusterPolicyConfigurationPBImpl - Class in org.apache.hadoop.yarn.server.federation.store.records.impl.pb

Protobuf based implementation of SubClusterPolicyConfiguration.

SubClusterPolicyConfigurationPBImpl() - Constructor for class org.apache.hadoop.yarn.server.federation.store.records.impl.pb.SubClusterPolicyConfigurationPBImpl

SubClusterPolicyConfigurationPBImpl(YarnServerFederationProtos.SubClusterPolicyConfigurationProto) - Constructor for class org.apache.hadoop.yarn.server.federation.store.records.impl.pb.SubClusterPolicyConfigurationPBImpl

SubClusterRegisterRequest - Class in org.apache.hadoop.yarn.server.federation.store.records

SubClusterRegisterRequest is a request by a sub-cluster ResourceManager to participate in federation.

SubClusterRegisterRequest() - Constructor for class org.apache.hadoop.yarn.server.federation.store.records.SubClusterRegisterRequest

SubClusterRegisterRequestPBImpl - Class in org.apache.hadoop.yarn.server.federation.store.records.impl.pb

Protocol buffer based implementation of SubClusterRegisterRequest.

SubClusterRegisterRequestPBImpl() - Constructor for class org.apache.hadoop.yarn.server.federation.store.records.impl.pb.SubClusterRegisterRequestPBImpl

SubClusterRegisterRequestPBImpl(YarnServerFederationProtos.SubClusterRegisterRequestProto) - Constructor for class org.apache.hadoop.yarn.server.federation.store.records.impl.pb.SubClusterRegisterRequestPBImpl

SubClusterRegisterResponse - Class in org.apache.hadoop.yarn.server.federation.store.records

SubClusterRegisterResponse contains the response from the FederationMembershipStateStore to a registration request from a ResourceManager to participate in federation.

SubClusterRegisterResponse() - Constructor for class org.apache.hadoop.yarn.server.federation.store.records.SubClusterRegisterResponse

SubClusterRegisterResponsePBImpl - Class in org.apache.hadoop.yarn.server.federation.store.records.impl.pb

Protocol buffer based implementation of SubClusterRegisterResponse.

SubClusterRegisterResponsePBImpl() - Constructor for class org.apache.hadoop.yarn.server.federation.store.records.impl.pb.SubClusterRegisterResponsePBImpl

SubClusterRegisterResponsePBImpl(YarnServerFederationProtos.SubClusterRegisterResponseProto) - Constructor for class org.apache.hadoop.yarn.server.federation.store.records.impl.pb.SubClusterRegisterResponsePBImpl

SubClusterResolver - Interface in org.apache.hadoop.yarn.server.federation.resolver

An utility that helps to determine the sub-cluster that a specified node or rack belongs to.

SubClusterState - Enum in org.apache.hadoop.yarn.server.federation.store.records

State of a SubCluster.

SUBMITTED_TIME_ENTITY_INFO - Static variable in class org.apache.hadoop.yarn.server.metrics.ApplicationMetricsConstants

submittedTime - Variable in class org.apache.hadoop.yarn.server.webapp.dao.AppInfo

succeededStateStoreCall(long) - Static method in class org.apache.hadoop.yarn.server.federation.store.metrics.FederationStateStoreClientMetrics

T

TimelineAuthenticationFilter - Class in org.apache.hadoop.yarn.server.timeline.security

Timeline authentication filter provides delegation token support for ATSv1 and ATSv2.

TimelineAuthenticationFilter() - Constructor for class org.apache.hadoop.yarn.server.timeline.security.TimelineAuthenticationFilter

TimelineAuthenticationFilterInitializer - Class in org.apache.hadoop.yarn.server.timeline.security

Initializes TimelineAuthenticationFilter which provides support for Kerberos HTTP SPNEGO authentication.

TimelineAuthenticationFilterInitializer() - Constructor for class org.apache.hadoop.yarn.server.timeline.security.TimelineAuthenticationFilterInitializer

TimelineDelgationTokenSecretManagerService - Class in org.apache.hadoop.yarn.server.timeline.security

Abstract implementation of delegation token manager service for different versions of timeline service.

TimelineDelgationTokenSecretManagerService(String) - Constructor for class org.apache.hadoop.yarn.server.timeline.security.TimelineDelgationTokenSecretManagerService

TimelineServerUtils - Class in org.apache.hadoop.yarn.server.util.timeline

Set of utility methods to be used across timeline reader and collector.

toByteBuffer() - Method in class org.apache.hadoop.yarn.server.federation.policies.dao.WeightedPolicyInfo

Converts the policy into a byte array representation in the input ByteBuffer.

toId() - Method in class org.apache.hadoop.yarn.server.federation.store.records.SubClusterIdInfo

Get the sub-cluster identifier as SubClusterId.

toString() - Method in class org.apache.hadoop.yarn.server.api.protocolrecords.impl.pb.GetTimelineCollectorContextRequestPBImpl

toString() - Method in class org.apache.hadoop.yarn.server.api.protocolrecords.impl.pb.GetTimelineCollectorContextResponsePBImpl

toString() - Method in class org.apache.hadoop.yarn.server.api.protocolrecords.impl.pb.LogAggregationReportPBImpl

toString() - Method in class org.apache.hadoop.yarn.server.api.protocolrecords.impl.pb.NMContainerStatusPBImpl

toString() - Method in class org.apache.hadoop.yarn.server.api.protocolrecords.impl.pb.RegisterDistributedSchedulingAMResponsePBImpl

toString() - Method in class org.apache.hadoop.yarn.server.api.protocolrecords.impl.pb.ReportNewCollectorInfoResponsePBImpl

toString() - Method in class org.apache.hadoop.yarn.server.api.protocolrecords.RemoteNode

toString() - Method in class org.apache.hadoop.yarn.server.api.records.impl.pb.AppCollectorDataPBImpl

toString() - Method in class org.apache.hadoop.yarn.server.api.records.impl.pb.NodeHealthStatusPBImpl

toString() - Method in class org.apache.hadoop.yarn.server.federation.policies.dao.WeightedPolicyInfo

toString() - Method in class org.apache.hadoop.yarn.server.federation.store.records.ApplicationHomeSubCluster

toString() - Method in class org.apache.hadoop.yarn.server.federation.store.records.impl.pb.AddApplicationHomeSubClusterRequestPBImpl

toString() - Method in class org.apache.hadoop.yarn.server.federation.store.records.impl.pb.AddApplicationHomeSubClusterResponsePBImpl

toString() - Method in class org.apache.hadoop.yarn.server.federation.store.records.impl.pb.ApplicationHomeSubClusterPBImpl

toString() - Method in class org.apache.hadoop.yarn.server.federation.store.records.impl.pb.DeleteApplicationHomeSubClusterRequestPBImpl

toString() - Method in class org.apache.hadoop.yarn.server.federation.store.records.impl.pb.DeleteApplicationHomeSubClusterResponsePBImpl

toString() - Method in class org.apache.hadoop.yarn.server.federation.store.records.impl.pb.GetApplicationHomeSubClusterRequestPBImpl

toString() - Method in class org.apache.hadoop.yarn.server.federation.store.records.impl.pb.GetApplicationHomeSubClusterResponsePBImpl

toString() - Method in class org.apache.hadoop.yarn.server.federation.store.records.impl.pb.GetApplicationsHomeSubClusterRequestPBImpl

toString() - Method in class org.apache.hadoop.yarn.server.federation.store.records.impl.pb.GetApplicationsHomeSubClusterResponsePBImpl

toString() - Method in class org.apache.hadoop.yarn.server.federation.store.records.impl.pb.GetSubClusterInfoRequestPBImpl

toString() - Method in class org.apache.hadoop.yarn.server.federation.store.records.impl.pb.GetSubClusterInfoResponsePBImpl

toString() - Method in class org.apache.hadoop.yarn.server.federation.store.records.impl.pb.GetSubClusterPoliciesConfigurationsRequestPBImpl

toString() - Method in class org.apache.hadoop.yarn.server.federation.store.records.impl.pb.GetSubClusterPoliciesConfigurationsResponsePBImpl

toString() - Method in class org.apache.hadoop.yarn.server.federation.store.records.impl.pb.GetSubClusterPolicyConfigurationRequestPBImpl

toString() - Method in class org.apache.hadoop.yarn.server.federation.store.records.impl.pb.GetSubClusterPolicyConfigurationResponsePBImpl

toString() - Method in class org.apache.hadoop.yarn.server.federation.store.records.impl.pb.GetSubClustersInfoRequestPBImpl

toString() - Method in class org.apache.hadoop.yarn.server.federation.store.records.impl.pb.GetSubClustersInfoResponsePBImpl

toString() - Method in class org.apache.hadoop.yarn.server.federation.store.records.impl.pb.SetSubClusterPolicyConfigurationRequestPBImpl

toString() - Method in class org.apache.hadoop.yarn.server.federation.store.records.impl.pb.SetSubClusterPolicyConfigurationResponsePBImpl

toString() - Method in class org.apache.hadoop.yarn.server.federation.store.records.impl.pb.SubClusterDeregisterRequestPBImpl

toString() - Method in class org.apache.hadoop.yarn.server.federation.store.records.impl.pb.SubClusterDeregisterResponsePBImpl

toString() - Method in class org.apache.hadoop.yarn.server.federation.store.records.impl.pb.SubClusterHeartbeatRequestPBImpl

toString() - Method in class org.apache.hadoop.yarn.server.federation.store.records.impl.pb.SubClusterHeartbeatResponsePBImpl

toString() - Method in class org.apache.hadoop.yarn.server.federation.store.records.impl.pb.SubClusterInfoPBImpl

toString() - Method in class org.apache.hadoop.yarn.server.federation.store.records.impl.pb.SubClusterPolicyConfigurationPBImpl

toString() - Method in class org.apache.hadoop.yarn.server.federation.store.records.impl.pb.SubClusterRegisterRequestPBImpl

toString() - Method in class org.apache.hadoop.yarn.server.federation.store.records.impl.pb.SubClusterRegisterResponsePBImpl

toString() - Method in class org.apache.hadoop.yarn.server.federation.store.records.impl.pb.UpdateApplicationHomeSubClusterRequestPBImpl

toString() - Method in class org.apache.hadoop.yarn.server.federation.store.records.impl.pb.UpdateApplicationHomeSubClusterResponsePBImpl

toString() - Method in class org.apache.hadoop.yarn.server.federation.store.records.SubClusterHeartbeatRequest

toString() - Method in class org.apache.hadoop.yarn.server.federation.store.records.SubClusterId

toString() - Method in class org.apache.hadoop.yarn.server.federation.store.records.SubClusterInfo

toString() - Method in class org.apache.hadoop.yarn.server.federation.store.records.SubClusterPolicyConfiguration

toString() - Method in class org.apache.hadoop.yarn.server.records.Version

toString() - Method in class org.apache.hadoop.yarn.server.scheduler.SchedulerRequestKey

TRACKING_URL_INFO - Static variable in class org.apache.hadoop.yarn.server.metrics.AppAttemptMetricsConstants

trackingUrl - Variable in class org.apache.hadoop.yarn.server.webapp.dao.AppAttemptInfo

trackingUrl - Variable in class org.apache.hadoop.yarn.server.webapp.dao.AppInfo

type - Variable in class org.apache.hadoop.yarn.server.webapp.dao.AppInfo

TYPE_ENTITY_INFO - Static variable in class org.apache.hadoop.yarn.server.metrics.ApplicationMetricsConstants

U

uncaughtException(Thread, Throwable) - Method in class org.apache.hadoop.yarn.server.uam.UnmanagedApplicationManager.HeartBeatThreadUncaughtExceptionHandler

UniformBroadcastPolicyManager - Class in org.apache.hadoop.yarn.server.federation.policies.manager

This class represents a simple implementation of a FederationPolicyManager.

UniformBroadcastPolicyManager() - Constructor for class org.apache.hadoop.yarn.server.federation.policies.manager.UniformBroadcastPolicyManager

UniformRandomRouterPolicy - Class in org.apache.hadoop.yarn.server.federation.policies.router

This simple policy picks at uniform random among any of the currently active subclusters.

UniformRandomRouterPolicy() - Constructor for class org.apache.hadoop.yarn.server.federation.policies.router.UniformRandomRouterPolicy

UnknownSubclusterException - Exception in org.apache.hadoop.yarn.server.federation.policies.exceptions

This exception is thrown whenever a policy is given a SubClusterId that is unknown.

UnknownSubclusterException(String) - Constructor for exception org.apache.hadoop.yarn.server.federation.policies.exceptions.UnknownSubclusterException

UNMANAGED_APPLICATION_ENTITY_INFO - Static variable in class org.apache.hadoop.yarn.server.metrics.ApplicationMetricsConstants

UnmanagedAMPoolManager - Class in org.apache.hadoop.yarn.server.uam

A service that manages a pool of UAM managers in UnmanagedApplicationManager.

UnmanagedAMPoolManager(ExecutorService) - Constructor for class org.apache.hadoop.yarn.server.uam.UnmanagedAMPoolManager

unmanagedApplication - Variable in class org.apache.hadoop.yarn.server.webapp.dao.AppInfo

UnmanagedApplicationManager - Class in org.apache.hadoop.yarn.server.uam

UnmanagedApplicationManager is used to register unmanaged application and negotiate for resources from resource managers.

UnmanagedApplicationManager(Configuration, ApplicationId, String, String, String, boolean) - Constructor for class org.apache.hadoop.yarn.server.uam.UnmanagedApplicationManager

Constructor.

UnmanagedApplicationManager.AMRequestHandlerThread - Class in org.apache.hadoop.yarn.server.uam

Extends Thread and provides an implementation that is used for processing the AM heart beat request asynchronously and sending back the response using the callback method registered with the system.

UnmanagedApplicationManager.AsyncAllocateRequestInfo - Class in org.apache.hadoop.yarn.server.uam

Data structure that encapsulates AllocateRequest and AsyncCallback instance.

UnmanagedApplicationManager.HeartBeatThreadUncaughtExceptionHandler - Class in org.apache.hadoop.yarn.server.uam

Uncaught exception handler for the background heartbeat thread.

unRegisterNodeManager(UnRegisterNodeManagerRequest) - Method in class org.apache.hadoop.yarn.server.api.impl.pb.client.ResourceTrackerPBClientImpl

unRegisterNodeManager(RpcController, YarnServerCommonServiceProtos.UnRegisterNodeManagerRequestProto) - Method in class org.apache.hadoop.yarn.server.api.impl.pb.service.ResourceTrackerPBServiceImpl

unRegisterNodeManager(UnRegisterNodeManagerRequest) - Method in interface org.apache.hadoop.yarn.server.api.ResourceTracker

UnRegisterNodeManagerRequest - Class in org.apache.hadoop.yarn.server.api.protocolrecords

Node Manager's unregister request.

UnRegisterNodeManagerRequest() - Constructor for class org.apache.hadoop.yarn.server.api.protocolrecords.UnRegisterNodeManagerRequest

UnRegisterNodeManagerRequestPBImpl - Class in org.apache.hadoop.yarn.server.api.protocolrecords.impl.pb

PBImpl class for UnRegisterNodeManagerRequest.

UnRegisterNodeManagerRequestPBImpl() - Constructor for class org.apache.hadoop.yarn.server.api.protocolrecords.impl.pb.UnRegisterNodeManagerRequestPBImpl

UnRegisterNodeManagerRequestPBImpl(YarnServerCommonServiceProtos.UnRegisterNodeManagerRequestProto) - Constructor for class org.apache.hadoop.yarn.server.api.protocolrecords.impl.pb.UnRegisterNodeManagerRequestPBImpl

UnRegisterNodeManagerResponse - Class in org.apache.hadoop.yarn.server.api.protocolrecords

Node Manager's unregister response.

UnRegisterNodeManagerResponse() - Constructor for class org.apache.hadoop.yarn.server.api.protocolrecords.UnRegisterNodeManagerResponse

UnRegisterNodeManagerResponsePBImpl - Class in org.apache.hadoop.yarn.server.api.protocolrecords.impl.pb

PBImpl class for UnRegisterNodeManagerResponse.

UnRegisterNodeManagerResponsePBImpl() - Constructor for class org.apache.hadoop.yarn.server.api.protocolrecords.impl.pb.UnRegisterNodeManagerResponsePBImpl

UnRegisterNodeManagerResponsePBImpl(YarnServerCommonServiceProtos.UnRegisterNodeManagerResponseProto) - Constructor for class org.apache.hadoop.yarn.server.api.protocolrecords.impl.pb.UnRegisterNodeManagerResponsePBImpl

unregisterService(String) - Method in class org.apache.hadoop.yarn.lib.ZKClient

unregister the service.

updateAllocationParams(Resource, Resource, Resource, int) - Method in class org.apache.hadoop.yarn.server.scheduler.OpportunisticContainerContext

updateAMRMToken(Token, UserGroupInformation, Configuration) - Static method in class org.apache.hadoop.yarn.server.utils.YarnServerSecurityUtils

Update the new AMRMToken into the ugi used for RM proxy.

updateApplicationHomeSubCluster(UpdateApplicationHomeSubClusterRequest) - Method in interface org.apache.hadoop.yarn.server.federation.store.FederationApplicationHomeSubClusterStore

Update the home SubClusterId of a previously submitted ApplicationId.

updateApplicationHomeSubCluster(UpdateApplicationHomeSubClusterRequest) - Method in class org.apache.hadoop.yarn.server.federation.store.impl.MemoryFederationStateStore

updateApplicationHomeSubCluster(UpdateApplicationHomeSubClusterRequest) - Method in class org.apache.hadoop.yarn.server.federation.store.impl.SQLFederationStateStore

updateApplicationHomeSubCluster(UpdateApplicationHomeSubClusterRequest) - Method in class org.apache.hadoop.yarn.server.federation.store.impl.ZookeeperFederationStateStore

updateApplicationHomeSubCluster(ApplicationHomeSubCluster) - Method in class org.apache.hadoop.yarn.server.federation.utils.FederationStateStoreFacade

Updates the home SubClusterId for the specified ApplicationId.

UpdateApplicationHomeSubClusterRequest - Class in org.apache.hadoop.yarn.server.federation.store.records

The request sent by the Router to Federation state store to update the home subcluster of a newly submitted application.

UpdateApplicationHomeSubClusterRequest() - Constructor for class org.apache.hadoop.yarn.server.federation.store.records.UpdateApplicationHomeSubClusterRequest

UpdateApplicationHomeSubClusterRequestPBImpl - Class in org.apache.hadoop.yarn.server.federation.store.records.impl.pb

Protocol buffer based implementation of UpdateApplicationHomeSubClusterRequest .

UpdateApplicationHomeSubClusterRequestPBImpl() - Constructor for class org.apache.hadoop.yarn.server.federation.store.records.impl.pb.UpdateApplicationHomeSubClusterRequestPBImpl

UpdateApplicationHomeSubClusterRequestPBImpl(YarnServerFederationProtos.UpdateApplicationHomeSubClusterRequestProto) - Constructor for class org.apache.hadoop.yarn.server.federation.store.records.impl.pb.UpdateApplicationHomeSubClusterRequestPBImpl

UpdateApplicationHomeSubClusterResponse - Class in org.apache.hadoop.yarn.server.federation.store.records

UpdateApplicationHomeSubClusterResponse contains the answer from the FederationApplicationHomeSubClusterStore to a request to register the home subcluster of a submitted application.

UpdateApplicationHomeSubClusterResponse() - Constructor for class org.apache.hadoop.yarn.server.federation.store.records.UpdateApplicationHomeSubClusterResponse

UpdateApplicationHomeSubClusterResponsePBImpl - Class in org.apache.hadoop.yarn.server.federation.store.records.impl.pb

Protocol buffer based implementation of UpdateApplicationHomeSubClusterResponse.

UpdateApplicationHomeSubClusterResponsePBImpl() - Constructor for class org.apache.hadoop.yarn.server.federation.store.records.impl.pb.UpdateApplicationHomeSubClusterResponsePBImpl

UpdateApplicationHomeSubClusterResponsePBImpl(YarnServerFederationProtos.UpdateApplicationHomeSubClusterResponseProto) - Constructor for class org.apache.hadoop.yarn.server.federation.store.records.impl.pb.UpdateApplicationHomeSubClusterResponsePBImpl

updateConfForFederation(Configuration, String) - Static method in class org.apache.hadoop.yarn.server.federation.failover.FederationProxyProviderUtil

Updating the conf with Federation as long as certain subclusterId.

UPDATED_EVENT_TYPE - Static variable in class org.apache.hadoop.yarn.server.metrics.ApplicationMetricsConstants

updateNodeList(List<RemoteNode>) - Method in class org.apache.hadoop.yarn.server.scheduler.OpportunisticContainerContext

user - Variable in class org.apache.hadoop.yarn.server.webapp.dao.AppInfo

USER_ENTITY_INFO - Static variable in class org.apache.hadoop.yarn.server.metrics.ApplicationMetricsConstants

V

validate(WeightedPolicyInfo) - Method in class org.apache.hadoop.yarn.server.federation.policies.AbstractConfigurableFederationPolicy

Overridable validation step for the policy configuration.

validate(WeightedPolicyInfo) - Method in class org.apache.hadoop.yarn.server.federation.policies.amrmproxy.AbstractAMRMProxyPolicy

validate(FederationPolicyInitializationContext, String) - Static method in class org.apache.hadoop.yarn.server.federation.policies.FederationPolicyInitializationContextValidator

validate(WeightedPolicyInfo) - Method in class org.apache.hadoop.yarn.server.federation.policies.router.AbstractRouterPolicy

validate(ApplicationSubmissionContext) - Method in class org.apache.hadoop.yarn.server.federation.policies.router.AbstractRouterPolicy

validate(AddApplicationHomeSubClusterRequest) - Static method in class org.apache.hadoop.yarn.server.federation.store.utils.FederationApplicationHomeSubClusterStoreInputValidator

Quick validation on the input to check some obvious fail conditions (fail fast).

validate(UpdateApplicationHomeSubClusterRequest) - Static method in class org.apache.hadoop.yarn.server.federation.store.utils.FederationApplicationHomeSubClusterStoreInputValidator

Quick validation on the input to check some obvious fail conditions (fail fast).

validate(GetApplicationHomeSubClusterRequest) - Static method in class org.apache.hadoop.yarn.server.federation.store.utils.FederationApplicationHomeSubClusterStoreInputValidator

Quick validation on the input to check some obvious fail conditions (fail fast).

validate(DeleteApplicationHomeSubClusterRequest) - Static method in class org.apache.hadoop.yarn.server.federation.store.utils.FederationApplicationHomeSubClusterStoreInputValidator

Quick validation on the input to check some obvious fail conditions (fail fast).

validate(SubClusterRegisterRequest) - Static method in class org.apache.hadoop.yarn.server.federation.store.utils.FederationMembershipStateStoreInputValidator

Quick validation on the input to check some obvious fail conditions (fail fast).

validate(SubClusterDeregisterRequest) - Static method in class org.apache.hadoop.yarn.server.federation.store.utils.FederationMembershipStateStoreInputValidator

Quick validation on the input to check some obvious fail conditions (fail fast).

validate(SubClusterHeartbeatRequest) - Static method in class org.apache.hadoop.yarn.server.federation.store.utils.FederationMembershipStateStoreInputValidator

Quick validation on the input to check some obvious fail conditions (fail fast).

validate(GetSubClusterInfoRequest) - Static method in class org.apache.hadoop.yarn.server.federation.store.utils.FederationMembershipStateStoreInputValidator

Quick validation on the input to check some obvious fail conditions (fail fast).

validate(GetSubClusterPolicyConfigurationRequest) - Static method in class org.apache.hadoop.yarn.server.federation.store.utils.FederationPolicyStoreInputValidator

Quick validation on the input to check some obvious fail conditions (fail fast).

validate(SetSubClusterPolicyConfigurationRequest) - Static method in class org.apache.hadoop.yarn.server.federation.store.utils.FederationPolicyStoreInputValidator

Quick validation on the input to check some obvious fail conditions (fail fast).

validateIds(ApplicationId, ApplicationAttemptId, ContainerId) - Method in class org.apache.hadoop.yarn.server.webapp.WebServices

validateSubClusterAvailability(List<SubClusterId>, List<SubClusterId>) - Static method in class org.apache.hadoop.yarn.server.federation.policies.FederationPolicyUtils

Validate if there is any active subcluster that is not blacklisted, it will throw an exception if there are no usable subclusters.

valueOf(String) - Static method in enum org.apache.hadoop.yarn.server.api.records.NodeAction

Returns the enum constant of this type with the specified name.

valueOf(String) - Static method in enum org.apache.hadoop.yarn.server.federation.store.records.SubClusterState

Returns the enum constant of this type with the specified name.

values() - Static method in enum org.apache.hadoop.yarn.server.api.records.NodeAction

Returns an array containing the constants of this enum type, in the order they are declared.

values() - Static method in enum org.apache.hadoop.yarn.server.federation.store.records.SubClusterState

Returns an array containing the constants of this enum type, in the order they are declared.

Version - Class in org.apache.hadoop.yarn.server.records

The version information for state get stored in YARN components, i.e.

Version() - Constructor for class org.apache.hadoop.yarn.server.records.Version

VersionPBImpl - Class in org.apache.hadoop.yarn.server.records.impl.pb

VersionPBImpl() - Constructor for class org.apache.hadoop.yarn.server.records.impl.pb.VersionPBImpl

VersionPBImpl(YarnServerCommonProtos.VersionProto) - Constructor for class org.apache.hadoop.yarn.server.records.impl.pb.VersionPBImpl

W

WebPageUtils - Class in org.apache.hadoop.yarn.server.webapp

WebPageUtils() - Constructor for class org.apache.hadoop.yarn.server.webapp.WebPageUtils

WebServices - Class in org.apache.hadoop.yarn.server.webapp

WebServices(ApplicationBaseProtocol) - Constructor for class org.apache.hadoop.yarn.server.webapp.WebServices

WeightedLocalityPolicyManager - Class in org.apache.hadoop.yarn.server.federation.policies.manager

Policy that allows operator to configure "weights" for routing.

WeightedLocalityPolicyManager() - Constructor for class org.apache.hadoop.yarn.server.federation.policies.manager.WeightedLocalityPolicyManager

WeightedPolicyInfo - Class in org.apache.hadoop.yarn.server.federation.policies.dao

This is a DAO class for the configuration of parameteres for federation policies.

WeightedPolicyInfo() - Constructor for class org.apache.hadoop.yarn.server.federation.policies.dao.WeightedPolicyInfo

WeightedRandomRouterPolicy - Class in org.apache.hadoop.yarn.server.federation.policies.router

This policy implements a weighted random sample among currently active sub-clusters.

WeightedRandomRouterPolicy() - Constructor for class org.apache.hadoop.yarn.server.federation.policies.router.WeightedRandomRouterPolicy

writeAMRMTokenForUAM(ApplicationId, String, Token<AMRMTokenIdentifier>) - Method in class org.apache.hadoop.yarn.server.federation.utils.FederationRegistryClient

Write/update the UAM token for an application and a sub-cluster.

writeLock - Variable in class org.apache.hadoop.yarn.server.security.BaseContainerTokenSecretManager

writeLock - Variable in class org.apache.hadoop.yarn.server.security.BaseNMTokenSecretManager

Y

YARN_APP_CALLER_CONTEXT - Static variable in class org.apache.hadoop.yarn.server.metrics.ApplicationMetricsConstants

YARN_APP_CALLER_SIGNATURE - Static variable in class org.apache.hadoop.yarn.server.metrics.ApplicationMetricsConstants

YarnServerBuilderUtils - Class in org.apache.hadoop.yarn.server.utils

Server Builder utilities to construct various objects.

YarnServerBuilderUtils() - Constructor for class org.apache.hadoop.yarn.server.utils.YarnServerBuilderUtils

YarnServerSecurityUtils - Class in org.apache.hadoop.yarn.server.utils

Utility class that contains commonly used server methods.

YarnWebServiceParams - Interface in org.apache.hadoop.yarn.server.webapp

Common web service parameters which could be used in RM/NM/AHS WebService.

Z

ZKClient - Class in org.apache.hadoop.yarn.lib

ZK Registration Library currently does not use any authorization

ZKClient(String) - Constructor for class org.apache.hadoop.yarn.lib.ZKClient

the zookeeper client library to talk to zookeeper

ZookeeperFederationStateStore - Class in org.apache.hadoop.yarn.server.federation.store.impl

ZooKeeper implementation of FederationStateStore.

ZookeeperFederationStateStore() - Constructor for class org.apache.hadoop.yarn.server.federation.store.impl.ZookeeperFederationStateStore

A B C D E F G H I L M N O P Q R S T U V W Y Z