A B C E G H I K L M N O P R S T U V Y

A

addContainerRequest(T) - Method in class org.apache.hadoop.yarn.client.api.AMRMClient

Request containers for resources before calling allocate

addContainerRequest(T) - Method in class org.apache.hadoop.yarn.client.api.async.AMRMClientAsync

Request containers for resources before calling allocate

addContainerRequest(T) - Method in class org.apache.hadoop.yarn.client.api.async.impl.AMRMClientAsyncImpl

Request containers for resources before calling allocate

addContainerRequest(T) - Method in class org.apache.hadoop.yarn.client.api.impl.AMRMClientImpl

allocate(float) - Method in class org.apache.hadoop.yarn.client.api.AMRMClient

Request additional containers and receive new container allocations.

allocate(float) - Method in class org.apache.hadoop.yarn.client.api.impl.AMRMClientImpl

AMRMClient<T extends AMRMClient.ContainerRequest> - Class in org.apache.hadoop.yarn.client.api

AMRMClient(String) - Constructor for class org.apache.hadoop.yarn.client.api.AMRMClient

AMRMClient.ContainerRequest - Class in org.apache.hadoop.yarn.client.api

Object to represent a single container request for resources.

AMRMClient.ContainerRequest(Resource, String[], String[], Priority) - Constructor for class org.apache.hadoop.yarn.client.api.AMRMClient.ContainerRequest

Instantiates a AMRMClient.ContainerRequest with the given constraints and locality relaxation enabled.

AMRMClient.ContainerRequest(Resource, String[], String[], Priority, boolean) - Constructor for class org.apache.hadoop.yarn.client.api.AMRMClient.ContainerRequest

Instantiates a AMRMClient.ContainerRequest with the given constraints.

AMRMClientAsync<T extends AMRMClient.ContainerRequest> - Class in org.apache.hadoop.yarn.client.api.async

AMRMClientAsync handles communication with the ResourceManager and provides asynchronous updates on events such as container allocations and completions.

AMRMClientAsync(int, AMRMClientAsync.CallbackHandler) - Constructor for class org.apache.hadoop.yarn.client.api.async.AMRMClientAsync

AMRMClientAsync(AMRMClient<T>, int, AMRMClientAsync.CallbackHandler) - Constructor for class org.apache.hadoop.yarn.client.api.async.AMRMClientAsync

AMRMClientAsync.CallbackHandler - Interface in org.apache.hadoop.yarn.client.api.async

AMRMClientAsyncImpl<T extends AMRMClient.ContainerRequest> - Class in org.apache.hadoop.yarn.client.api.async.impl

AMRMClientAsyncImpl(int, AMRMClientAsync.CallbackHandler) - Constructor for class org.apache.hadoop.yarn.client.api.async.impl.AMRMClientAsyncImpl

AMRMClientAsyncImpl(AMRMClient<T>, int, AMRMClientAsync.CallbackHandler) - Constructor for class org.apache.hadoop.yarn.client.api.async.impl.AMRMClientAsyncImpl

AMRMClientImpl<T extends AMRMClient.ContainerRequest> - Class in org.apache.hadoop.yarn.client.api.impl

AMRMClientImpl() - Constructor for class org.apache.hadoop.yarn.client.api.impl.AMRMClientImpl

ApplicationCLI - Class in org.apache.hadoop.yarn.client.cli

ApplicationCLI() - Constructor for class org.apache.hadoop.yarn.client.cli.ApplicationCLI

ask - Variable in class org.apache.hadoop.yarn.client.api.impl.AMRMClientImpl

B

blacklistAdditions - Variable in class org.apache.hadoop.yarn.client.api.impl.AMRMClientImpl

blacklistRemovals - Variable in class org.apache.hadoop.yarn.client.api.impl.AMRMClientImpl

C

callbackHandler - Variable in class org.apache.hadoop.yarn.client.api.async.NMClientAsync

cleanupRunningContainers() - Method in class org.apache.hadoop.yarn.client.api.impl.NMClientImpl

cleanupRunningContainersOnStop(boolean) - Method in class org.apache.hadoop.yarn.client.api.impl.NMClientImpl

cleanupRunningContainersOnStop(boolean) - Method in class org.apache.hadoop.yarn.client.api.NMClient

Set whether the containers that are started by this client, and are still running should be stopped when the client stops.

clearCache() - Method in class org.apache.hadoop.yarn.client.api.NMTokenCache

It will remove all the nm tokens from its cache

client - Variable in class org.apache.hadoop.yarn.client.api.async.AMRMClientAsync

client - Variable in class org.apache.hadoop.yarn.client.api.async.NMClientAsync

client - Variable in class org.apache.hadoop.yarn.client.cli.YarnCLI

ClientRMProxy<T> - Class in org.apache.hadoop.yarn.client

ClientRMProxy() - Constructor for class org.apache.hadoop.yarn.client.ClientRMProxy

clusterAvailableResources - Variable in class org.apache.hadoop.yarn.client.api.impl.AMRMClientImpl

clusterNodeCount - Variable in class org.apache.hadoop.yarn.client.api.impl.AMRMClientImpl

ContainerManagementProtocolProxy - Class in org.apache.hadoop.yarn.client.api.impl

Helper class to manage container manager proxies

ContainerManagementProtocolProxy(Configuration) - Constructor for class org.apache.hadoop.yarn.client.api.impl.ContainerManagementProtocolProxy

ContainerManagementProtocolProxy(Configuration, NMTokenCache) - Constructor for class org.apache.hadoop.yarn.client.api.impl.ContainerManagementProtocolProxy

ContainerManagementProtocolProxy.ContainerManagementProtocolProxyData - Class in org.apache.hadoop.yarn.client.api.impl

ContainerManagementProtocolProxy.ContainerManagementProtocolProxyData(YarnRPC, String, ContainerId, Token) - Constructor for class org.apache.hadoop.yarn.client.api.impl.ContainerManagementProtocolProxy.ContainerManagementProtocolProxyData

containers - Variable in class org.apache.hadoop.yarn.client.api.async.impl.NMClientAsyncImpl

containsToken(String) - Method in class org.apache.hadoop.yarn.client.api.NMTokenCache

Returns true if NMToken is present in cache.

createAMRMClient() - Static method in class org.apache.hadoop.yarn.client.api.AMRMClient

Create a new instance of AMRMClient.

createAMRMClientAsync(int, AMRMClientAsync.CallbackHandler) - Static method in class org.apache.hadoop.yarn.client.api.async.AMRMClientAsync

createAMRMClientAsync(AMRMClient<T>, int, AMRMClientAsync.CallbackHandler) - Static method in class org.apache.hadoop.yarn.client.api.async.AMRMClientAsync

createApplication() - Method in class org.apache.hadoop.yarn.client.api.impl.YarnClientImpl

createApplication() - Method in class org.apache.hadoop.yarn.client.api.YarnClient

Obtain a YarnClientApplication for a new application, which in turn contains the ApplicationSubmissionContext and GetNewApplicationResponse objects.

createNMClient() - Static method in class org.apache.hadoop.yarn.client.api.NMClient

Create a new instance of NMClient.

createNMClient(String) - Static method in class org.apache.hadoop.yarn.client.api.NMClient

Create a new instance of NMClient.

createNMClientAsync(NMClientAsync.CallbackHandler) - Static method in class org.apache.hadoop.yarn.client.api.async.NMClientAsync

createRMProxy(Configuration, Class<T>) - Static method in class org.apache.hadoop.yarn.client.ClientRMProxy

createStartedContainer(Container) - Method in class org.apache.hadoop.yarn.client.api.impl.NMClientImpl

createYarnClient() - Static method in class org.apache.hadoop.yarn.client.api.YarnClient

Create a new instance of YarnClient.

createYarnClient() - Method in class org.apache.hadoop.yarn.client.cli.LogsCLI

E

event - Variable in class org.apache.hadoop.yarn.client.api.async.impl.NMClientAsyncImpl.ContainerEventProcessor

eventDispatcherThread - Variable in class org.apache.hadoop.yarn.client.api.async.impl.NMClientAsyncImpl

events - Variable in class org.apache.hadoop.yarn.client.api.async.impl.NMClientAsyncImpl

G

getAllQueues() - Method in class org.apache.hadoop.yarn.client.api.impl.YarnClientImpl

getAllQueues() - Method in class org.apache.hadoop.yarn.client.api.YarnClient

Get information (QueueInfo) about all queues, recursively if there is a hierarchy

getAMRMToken(ApplicationId) - Method in class org.apache.hadoop.yarn.client.api.impl.YarnClientImpl

getAMRMToken(ApplicationId) - Method in class org.apache.hadoop.yarn.client.api.YarnClient

Get the AMRM token of the application.

getApplicationReport(ApplicationId) - Method in class org.apache.hadoop.yarn.client.api.impl.YarnClientImpl

getApplicationReport(ApplicationId) - Method in class org.apache.hadoop.yarn.client.api.YarnClient

Get a report of the given Application.

getApplications() - Method in class org.apache.hadoop.yarn.client.api.impl.YarnClientImpl

getApplications(Set<String>) - Method in class org.apache.hadoop.yarn.client.api.impl.YarnClientImpl

getApplications(EnumSet<YarnApplicationState>) - Method in class org.apache.hadoop.yarn.client.api.impl.YarnClientImpl

getApplications(Set<String>, EnumSet<YarnApplicationState>) - Method in class org.apache.hadoop.yarn.client.api.impl.YarnClientImpl

getApplications() - Method in class org.apache.hadoop.yarn.client.api.YarnClient

Get a report (ApplicationReport) of all Applications in the cluster.

getApplications(Set<String>) - Method in class org.apache.hadoop.yarn.client.api.YarnClient

Get a report (ApplicationReport) of Applications matching the given application types in the cluster.

getApplications(EnumSet<YarnApplicationState>) - Method in class org.apache.hadoop.yarn.client.api.YarnClient

Get a report (ApplicationReport) of Applications matching the given application states in the cluster.

getApplications(Set<String>, EnumSet<YarnApplicationState>) - Method in class org.apache.hadoop.yarn.client.api.YarnClient

Get a report (ApplicationReport) of Applications matching the given application types and application states in the cluster.

getApplicationSubmissionContext() - Method in class org.apache.hadoop.yarn.client.api.YarnClientApplication

getAvailableResources() - Method in class org.apache.hadoop.yarn.client.api.AMRMClient

Get the currently available resources in the cluster.

getAvailableResources() - Method in class org.apache.hadoop.yarn.client.api.async.AMRMClientAsync

Get the currently available resources in the cluster.

getAvailableResources() - Method in class org.apache.hadoop.yarn.client.api.async.impl.AMRMClientAsyncImpl

Get the currently available resources in the cluster.

getAvailableResources() - Method in class org.apache.hadoop.yarn.client.api.impl.AMRMClientImpl

getCallbackHandler() - Method in class org.apache.hadoop.yarn.client.api.async.NMClientAsync

getCapability() - Method in class org.apache.hadoop.yarn.client.api.AMRMClient.ContainerRequest

getChildQueueInfos(String) - Method in class org.apache.hadoop.yarn.client.api.impl.YarnClientImpl

getChildQueueInfos(String) - Method in class org.apache.hadoop.yarn.client.api.YarnClient

Get information (QueueInfo) about all the immediate children queues of the given queue

getCleanupRunningContainers() - Method in class org.apache.hadoop.yarn.client.api.impl.NMClientImpl

getClient() - Method in class org.apache.hadoop.yarn.client.api.async.NMClientAsync

getClient() - Method in class org.apache.hadoop.yarn.client.cli.YarnCLI

getClusterNodeCount() - Method in class org.apache.hadoop.yarn.client.api.AMRMClient

Get the current number of nodes in the cluster.

getClusterNodeCount() - Method in class org.apache.hadoop.yarn.client.api.async.AMRMClientAsync

Get the current number of nodes in the cluster.

getClusterNodeCount() - Method in class org.apache.hadoop.yarn.client.api.async.impl.AMRMClientAsyncImpl

Get the current number of nodes in the cluster.

getClusterNodeCount() - Method in class org.apache.hadoop.yarn.client.api.impl.AMRMClientImpl

getContainer() - Method in class org.apache.hadoop.yarn.client.api.async.impl.NMClientAsyncImpl.StartContainerEvent

getContainerEventProcessor(NMClientAsyncImpl.ContainerEvent) - Method in class org.apache.hadoop.yarn.client.api.async.impl.NMClientAsyncImpl

getContainerId() - Method in class org.apache.hadoop.yarn.client.api.async.impl.NMClientAsyncImpl.ContainerEvent

getContainerId() - Method in class org.apache.hadoop.yarn.client.api.async.impl.NMClientAsyncImpl.StatefulContainer

getContainerId() - Method in class org.apache.hadoop.yarn.client.api.impl.NMClientImpl.StartedContainer

getContainerLaunchContext() - Method in class org.apache.hadoop.yarn.client.api.async.impl.NMClientAsyncImpl.StartContainerEvent

getContainerManagementProtocol() - Method in class org.apache.hadoop.yarn.client.api.impl.ContainerManagementProtocolProxy.ContainerManagementProtocolProxyData

getContainerStatus(ContainerId, NodeId) - Method in class org.apache.hadoop.yarn.client.api.impl.NMClientImpl

getContainerStatus(ContainerId, NodeId) - Method in class org.apache.hadoop.yarn.client.api.NMClient

Query the status of a container.

getContainerStatusAsync(ContainerId, NodeId) - Method in class org.apache.hadoop.yarn.client.api.async.impl.NMClientAsyncImpl

getContainerStatusAsync(ContainerId, NodeId) - Method in class org.apache.hadoop.yarn.client.api.async.NMClientAsync

getContainerToken() - Method in class org.apache.hadoop.yarn.client.api.async.impl.NMClientAsyncImpl.ContainerEvent

getMatchingRequests(Priority, String, Resource) - Method in class org.apache.hadoop.yarn.client.api.AMRMClient

Get outstanding ContainerRequests matching the given parameters.

getMatchingRequests(Priority, String, Resource) - Method in class org.apache.hadoop.yarn.client.api.async.AMRMClientAsync

getMatchingRequests(Priority, String, Resource) - Method in class org.apache.hadoop.yarn.client.api.async.impl.AMRMClientAsyncImpl

getMatchingRequests(Priority, String, Resource) - Method in class org.apache.hadoop.yarn.client.api.impl.AMRMClientImpl

getNewApplicationResponse() - Method in class org.apache.hadoop.yarn.client.api.YarnClientApplication

getNMToken(String) - Static method in class org.apache.hadoop.yarn.client.api.NMTokenCache

Returns NMToken, null if absent.

getNMTokenCache() - Method in class org.apache.hadoop.yarn.client.api.AMRMClient

Get the NM token cache of the AMRMClient.

getNMTokenCache() - Method in class org.apache.hadoop.yarn.client.api.NMClient

Get the NM token cache of the NMClient.

getNodeId() - Method in class org.apache.hadoop.yarn.client.api.async.impl.NMClientAsyncImpl.ContainerEvent

getNodeId() - Method in class org.apache.hadoop.yarn.client.api.impl.NMClientImpl.StartedContainer

getNodeReports(NodeState...) - Method in class org.apache.hadoop.yarn.client.api.impl.YarnClientImpl

getNodeReports(NodeState...) - Method in class org.apache.hadoop.yarn.client.api.YarnClient

Get a report of nodes (NodeReport) in the cluster.

getNodes() - Method in class org.apache.hadoop.yarn.client.api.AMRMClient.ContainerRequest

getPriority() - Method in class org.apache.hadoop.yarn.client.api.AMRMClient.ContainerRequest

getProgress() - Method in interface org.apache.hadoop.yarn.client.api.async.AMRMClientAsync.CallbackHandler

getProxy(String, ContainerId) - Method in class org.apache.hadoop.yarn.client.api.impl.ContainerManagementProtocolProxy

getQueueAclsInfo() - Method in class org.apache.hadoop.yarn.client.api.impl.YarnClientImpl

getQueueAclsInfo() - Method in class org.apache.hadoop.yarn.client.api.YarnClient

Get information about acls for current user on all the existing queues.

getQueueInfo(String) - Method in class org.apache.hadoop.yarn.client.api.impl.YarnClientImpl

getQueueInfo(String) - Method in class org.apache.hadoop.yarn.client.api.YarnClient

Get information (QueueInfo) about a given queue.

getRacks() - Method in class org.apache.hadoop.yarn.client.api.AMRMClient.ContainerRequest

getRelaxLocality() - Method in class org.apache.hadoop.yarn.client.api.AMRMClient.ContainerRequest

getRMDelegationToken(Text) - Method in class org.apache.hadoop.yarn.client.api.impl.YarnClientImpl

getRMDelegationToken(Text) - Method in class org.apache.hadoop.yarn.client.api.YarnClient

Get a delegation token so as to be able to talk to YARN using those tokens.

getRootQueueInfos() - Method in class org.apache.hadoop.yarn.client.api.impl.YarnClientImpl

getRootQueueInfos() - Method in class org.apache.hadoop.yarn.client.api.YarnClient

Get information (QueueInfo) about top level queues.

getSingleton() - Static method in class org.apache.hadoop.yarn.client.api.NMTokenCache

Returns the singleton NM token cache.

getStartedContainer(ContainerId) - Method in class org.apache.hadoop.yarn.client.api.impl.NMClientImpl

getState() - Method in class org.apache.hadoop.yarn.client.api.async.impl.NMClientAsyncImpl.StatefulContainer

getToken(String) - Method in class org.apache.hadoop.yarn.client.api.NMTokenCache

Returns NMToken, null if absent

getYarnClusterMetrics() - Method in class org.apache.hadoop.yarn.client.api.impl.YarnClientImpl

getYarnClusterMetrics() - Method in class org.apache.hadoop.yarn.client.api.YarnClient

Get metrics (YarnClusterMetrics) about the cluster.

H

handle(NMClientAsyncImpl.ContainerEvent) - Method in class org.apache.hadoop.yarn.client.api.async.impl.NMClientAsyncImpl.StatefulContainer

handler - Variable in class org.apache.hadoop.yarn.client.api.async.AMRMClientAsync

heartbeatIntervalMs - Variable in class org.apache.hadoop.yarn.client.api.async.AMRMClientAsync

HELP_CMD - Static variable in class org.apache.hadoop.yarn.client.cli.YarnCLI

I

INITIAL_THREAD_POOL_SIZE - Static variable in class org.apache.hadoop.yarn.client.api.async.impl.NMClientAsyncImpl

InvalidContainerRequestException - Exception in org.apache.hadoop.yarn.client.api

Thrown when an arguments are combined to construct a AMRMClient.ContainerRequest in an invalid way.

InvalidContainerRequestException(Throwable) - Constructor for exception org.apache.hadoop.yarn.client.api.InvalidContainerRequestException

InvalidContainerRequestException(String) - Constructor for exception org.apache.hadoop.yarn.client.api.InvalidContainerRequestException

InvalidContainerRequestException(String, Throwable) - Constructor for exception org.apache.hadoop.yarn.client.api.InvalidContainerRequestException

isCompletelyDone(NMClientAsyncImpl.StatefulContainer) - Method in class org.apache.hadoop.yarn.client.api.async.impl.NMClientAsyncImpl

K

KILL_CMD - Static variable in class org.apache.hadoop.yarn.client.cli.YarnCLI

killApplication(ApplicationId) - Method in class org.apache.hadoop.yarn.client.api.impl.YarnClientImpl

killApplication(ApplicationId) - Method in class org.apache.hadoop.yarn.client.api.YarnClient

Kill an application identified by given ID.

L

LIST_CMD - Static variable in class org.apache.hadoop.yarn.client.cli.YarnCLI

LogsCLI - Class in org.apache.hadoop.yarn.client.cli

LogsCLI() - Constructor for class org.apache.hadoop.yarn.client.cli.LogsCLI

M

main(String[]) - Static method in class org.apache.hadoop.yarn.client.cli.ApplicationCLI

main(String[]) - Static method in class org.apache.hadoop.yarn.client.cli.LogsCLI

main(String[]) - Static method in class org.apache.hadoop.yarn.client.cli.NodeCLI

main(String[]) - Static method in class org.apache.hadoop.yarn.client.cli.RMAdminCLI

maxThreadPoolSize - Variable in class org.apache.hadoop.yarn.client.api.async.impl.NMClientAsyncImpl

mayBeCloseProxy(ContainerManagementProtocolProxy.ContainerManagementProtocolProxyData) - Method in class org.apache.hadoop.yarn.client.api.impl.ContainerManagementProtocolProxy

N

newProxy(YarnRPC, String, ContainerId, Token) - Method in class org.apache.hadoop.yarn.client.api.impl.ContainerManagementProtocolProxy.ContainerManagementProtocolProxyData

NMClient - Class in org.apache.hadoop.yarn.client.api

NMClient(String) - Constructor for class org.apache.hadoop.yarn.client.api.NMClient

NMClientAsync - Class in org.apache.hadoop.yarn.client.api.async

NMClientAsync handles communication with all the NodeManagers and provides asynchronous updates on getting responses from them.

NMClientAsync(NMClientAsync.CallbackHandler) - Constructor for class org.apache.hadoop.yarn.client.api.async.NMClientAsync

NMClientAsync(String, NMClientAsync.CallbackHandler) - Constructor for class org.apache.hadoop.yarn.client.api.async.NMClientAsync

NMClientAsync(String, NMClient, NMClientAsync.CallbackHandler) - Constructor for class org.apache.hadoop.yarn.client.api.async.NMClientAsync

NMClientAsync.CallbackHandler - Interface in org.apache.hadoop.yarn.client.api.async

The callback interface needs to be implemented by NMClientAsync users.

NMClientAsyncImpl - Class in org.apache.hadoop.yarn.client.api.async.impl

NMClientAsyncImpl(NMClientAsync.CallbackHandler) - Constructor for class org.apache.hadoop.yarn.client.api.async.impl.NMClientAsyncImpl

NMClientAsyncImpl(String, NMClientAsync.CallbackHandler) - Constructor for class org.apache.hadoop.yarn.client.api.async.impl.NMClientAsyncImpl

NMClientAsyncImpl(String, NMClient, NMClientAsync.CallbackHandler) - Constructor for class org.apache.hadoop.yarn.client.api.async.impl.NMClientAsyncImpl

NMClientAsyncImpl.ContainerEvent - Class in org.apache.hadoop.yarn.client.api.async.impl

NMClientAsyncImpl.ContainerEvent(ContainerId, NodeId, Token, NMClientAsyncImpl.ContainerEventType) - Constructor for class org.apache.hadoop.yarn.client.api.async.impl.NMClientAsyncImpl.ContainerEvent

NMClientAsyncImpl.ContainerEventProcessor - Class in org.apache.hadoop.yarn.client.api.async.impl

NMClientAsyncImpl.ContainerEventProcessor(NMClientAsyncImpl.ContainerEvent) - Constructor for class org.apache.hadoop.yarn.client.api.async.impl.NMClientAsyncImpl.ContainerEventProcessor

NMClientAsyncImpl.ContainerEventType - Enum in org.apache.hadoop.yarn.client.api.async.impl

The type of the event of interacting with a container

NMClientAsyncImpl.ContainerState - Enum in org.apache.hadoop.yarn.client.api.async.impl

NMClientAsyncImpl.StartContainerEvent - Class in org.apache.hadoop.yarn.client.api.async.impl

NMClientAsyncImpl.StartContainerEvent(Container, ContainerLaunchContext) - Constructor for class org.apache.hadoop.yarn.client.api.async.impl.NMClientAsyncImpl.StartContainerEvent

NMClientAsyncImpl.StatefulContainer - Class in org.apache.hadoop.yarn.client.api.async.impl

NMClientAsyncImpl.StatefulContainer(NMClientAsync, ContainerId) - Constructor for class org.apache.hadoop.yarn.client.api.async.impl.NMClientAsyncImpl.StatefulContainer

NMClientAsyncImpl.StatefulContainer.OutOfOrderTransition - Class in org.apache.hadoop.yarn.client.api.async.impl

NMClientAsyncImpl.StatefulContainer.OutOfOrderTransition() - Constructor for class org.apache.hadoop.yarn.client.api.async.impl.NMClientAsyncImpl.StatefulContainer.OutOfOrderTransition

NMClientAsyncImpl.StatefulContainer.StartContainerTransition - Class in org.apache.hadoop.yarn.client.api.async.impl

NMClientAsyncImpl.StatefulContainer.StartContainerTransition() - Constructor for class org.apache.hadoop.yarn.client.api.async.impl.NMClientAsyncImpl.StatefulContainer.StartContainerTransition

NMClientAsyncImpl.StatefulContainer.StopContainerTransition - Class in org.apache.hadoop.yarn.client.api.async.impl

NMClientAsyncImpl.StatefulContainer.StopContainerTransition() - Constructor for class org.apache.hadoop.yarn.client.api.async.impl.NMClientAsyncImpl.StatefulContainer.StopContainerTransition

NMClientImpl - Class in org.apache.hadoop.yarn.client.api.impl

This class implements NMClient.

NMClientImpl() - Constructor for class org.apache.hadoop.yarn.client.api.impl.NMClientImpl

NMClientImpl(String) - Constructor for class org.apache.hadoop.yarn.client.api.impl.NMClientImpl

NMClientImpl.StartedContainer - Class in org.apache.hadoop.yarn.client.api.impl

NMClientImpl.StartedContainer(ContainerId, NodeId, Token) - Constructor for class org.apache.hadoop.yarn.client.api.impl.NMClientImpl.StartedContainer

NMTokenCache - Class in org.apache.hadoop.yarn.client.api

NMTokenCache manages NMTokens required for an Application Master communicating with individual NodeManagers.

NMTokenCache() - Constructor for class org.apache.hadoop.yarn.client.api.NMTokenCache

Creates a NM token cache instance.

NodeCLI - Class in org.apache.hadoop.yarn.client.cli

NodeCLI() - Constructor for class org.apache.hadoop.yarn.client.cli.NodeCLI

numberOfTokensInCache() - Method in class org.apache.hadoop.yarn.client.api.NMTokenCache

Returns the number of NMTokens present in cache.

O

onContainersAllocated(List<Container>) - Method in interface org.apache.hadoop.yarn.client.api.async.AMRMClientAsync.CallbackHandler

Called when the ResourceManager responds to a heartbeat with allocated containers.

onContainersCompleted(List<ContainerStatus>) - Method in interface org.apache.hadoop.yarn.client.api.async.AMRMClientAsync.CallbackHandler

Called when the ResourceManager responds to a heartbeat with completed containers.

onContainerStarted(ContainerId, Map<String, ByteBuffer>) - Method in interface org.apache.hadoop.yarn.client.api.async.NMClientAsync.CallbackHandler

The API is called when NodeManager responds to indicate its acceptance of the starting container request

onContainerStatusReceived(ContainerId, ContainerStatus) - Method in interface org.apache.hadoop.yarn.client.api.async.NMClientAsync.CallbackHandler

The API is called when NodeManager responds with the status of the container

onContainerStopped(ContainerId) - Method in interface org.apache.hadoop.yarn.client.api.async.NMClientAsync.CallbackHandler

The API is called when NodeManager responds to indicate the container is stopped.

onError(Throwable) - Method in interface org.apache.hadoop.yarn.client.api.async.AMRMClientAsync.CallbackHandler

Called when error comes from RM communications as well as from errors in the callback itself from the app.

onGetContainerStatusError(ContainerId, Throwable) - Method in interface org.apache.hadoop.yarn.client.api.async.NMClientAsync.CallbackHandler

The API is called when an exception is raised in the process of querying the status of a container

onNodesUpdated(List<NodeReport>) - Method in interface org.apache.hadoop.yarn.client.api.async.AMRMClientAsync.CallbackHandler

Called when nodes tracked by the ResourceManager have changed in health, availability etc.

onShutdownRequest() - Method in interface org.apache.hadoop.yarn.client.api.async.AMRMClientAsync.CallbackHandler

Called when the ResourceManager wants the ApplicationMaster to shutdown for being out of sync etc.

onStartContainerError(ContainerId, Throwable) - Method in interface org.apache.hadoop.yarn.client.api.async.NMClientAsync.CallbackHandler

The API is called when an exception is raised in the process of starting a container

onStopContainerError(ContainerId, Throwable) - Method in interface org.apache.hadoop.yarn.client.api.async.NMClientAsync.CallbackHandler

The API is called when an exception is raised in the process of stopping a container

org.apache.hadoop.yarn.client - package org.apache.hadoop.yarn.client

org.apache.hadoop.yarn.client.api - package org.apache.hadoop.yarn.client.api

org.apache.hadoop.yarn.client.api.async - package org.apache.hadoop.yarn.client.api.async

org.apache.hadoop.yarn.client.api.async.impl - package org.apache.hadoop.yarn.client.api.async.impl

org.apache.hadoop.yarn.client.api.impl - package org.apache.hadoop.yarn.client.api.impl

org.apache.hadoop.yarn.client.cli - package org.apache.hadoop.yarn.client.cli

P

populateNMTokens(AllocateResponse) - Method in class org.apache.hadoop.yarn.client.api.impl.AMRMClientImpl

R

registerApplicationMaster(String, int, String) - Method in class org.apache.hadoop.yarn.client.api.AMRMClient

Register the application master.

registerApplicationMaster(String, int, String) - Method in class org.apache.hadoop.yarn.client.api.async.AMRMClientAsync

Registers this application master with the resource manager.

registerApplicationMaster(String, int, String) - Method in class org.apache.hadoop.yarn.client.api.async.impl.AMRMClientAsyncImpl

Registers this application master with the resource manager.

registerApplicationMaster(String, int, String) - Method in class org.apache.hadoop.yarn.client.api.impl.AMRMClientImpl

release - Variable in class org.apache.hadoop.yarn.client.api.impl.AMRMClientImpl

releaseAssignedContainer(ContainerId) - Method in class org.apache.hadoop.yarn.client.api.AMRMClient

Release containers assigned by the Resource Manager.

releaseAssignedContainer(ContainerId) - Method in class org.apache.hadoop.yarn.client.api.async.AMRMClientAsync

Release containers assigned by the Resource Manager.

releaseAssignedContainer(ContainerId) - Method in class org.apache.hadoop.yarn.client.api.async.impl.AMRMClientAsyncImpl

Release containers assigned by the Resource Manager.

releaseAssignedContainer(ContainerId) - Method in class org.apache.hadoop.yarn.client.api.impl.AMRMClientImpl

remoteRequestsTable - Variable in class org.apache.hadoop.yarn.client.api.impl.AMRMClientImpl

removeContainerRequest(T) - Method in class org.apache.hadoop.yarn.client.api.AMRMClient

Remove previous container request.

removeContainerRequest(T) - Method in class org.apache.hadoop.yarn.client.api.async.AMRMClientAsync

Remove previous container request.

removeContainerRequest(T) - Method in class org.apache.hadoop.yarn.client.api.async.impl.AMRMClientAsyncImpl

Remove previous container request.

removeContainerRequest(T) - Method in class org.apache.hadoop.yarn.client.api.impl.AMRMClientImpl

removeStartedContainer(NMClientImpl.StartedContainer) - Method in class org.apache.hadoop.yarn.client.api.impl.NMClientImpl

removeToken(String) - Method in class org.apache.hadoop.yarn.client.api.NMTokenCache

Removes NMToken for specified node manager

rmAddress - Variable in class org.apache.hadoop.yarn.client.api.impl.YarnClientImpl

RMAdminCLI - Class in org.apache.hadoop.yarn.client.cli

RMAdminCLI() - Constructor for class org.apache.hadoop.yarn.client.cli.RMAdminCLI

RMAdminCLI(Configuration) - Constructor for class org.apache.hadoop.yarn.client.cli.RMAdminCLI

rmClient - Variable in class org.apache.hadoop.yarn.client.api.impl.AMRMClientImpl

rmClient - Variable in class org.apache.hadoop.yarn.client.api.impl.YarnClientImpl

run() - Method in class org.apache.hadoop.yarn.client.api.async.impl.NMClientAsyncImpl.ContainerEventProcessor

run(String[]) - Method in class org.apache.hadoop.yarn.client.cli.ApplicationCLI

run(String[]) - Method in class org.apache.hadoop.yarn.client.cli.LogsCLI

run(String[]) - Method in class org.apache.hadoop.yarn.client.cli.NodeCLI

run(String[]) - Method in class org.apache.hadoop.yarn.client.cli.RMAdminCLI

S

serviceInit(Configuration) - Method in class org.apache.hadoop.yarn.client.api.async.impl.AMRMClientAsyncImpl

serviceInit(Configuration) - Method in class org.apache.hadoop.yarn.client.api.async.impl.NMClientAsyncImpl

serviceInit(Configuration) - Method in class org.apache.hadoop.yarn.client.api.impl.AMRMClientImpl

serviceInit(Configuration) - Method in class org.apache.hadoop.yarn.client.api.impl.NMClientImpl

serviceInit(Configuration) - Method in class org.apache.hadoop.yarn.client.api.impl.YarnClientImpl

serviceStart() - Method in class org.apache.hadoop.yarn.client.api.async.impl.AMRMClientAsyncImpl

serviceStart() - Method in class org.apache.hadoop.yarn.client.api.async.impl.NMClientAsyncImpl

serviceStart() - Method in class org.apache.hadoop.yarn.client.api.impl.AMRMClientImpl

serviceStart() - Method in class org.apache.hadoop.yarn.client.api.impl.YarnClientImpl

serviceStop() - Method in class org.apache.hadoop.yarn.client.api.async.impl.AMRMClientAsyncImpl

Tells the heartbeat and handler threads to stop and waits for them to terminate.

serviceStop() - Method in class org.apache.hadoop.yarn.client.api.async.impl.NMClientAsyncImpl

serviceStop() - Method in class org.apache.hadoop.yarn.client.api.impl.AMRMClientImpl

serviceStop() - Method in class org.apache.hadoop.yarn.client.api.impl.NMClientImpl

serviceStop() - Method in class org.apache.hadoop.yarn.client.api.impl.YarnClientImpl

setCallbackHandler(NMClientAsync.CallbackHandler) - Method in class org.apache.hadoop.yarn.client.api.async.NMClientAsync

setClient(NMClient) - Method in class org.apache.hadoop.yarn.client.api.async.NMClientAsync

setClient(YarnClient) - Method in class org.apache.hadoop.yarn.client.cli.YarnCLI

setHeartbeatInterval(int) - Method in class org.apache.hadoop.yarn.client.api.async.AMRMClientAsync

setHeartbeatInterval(int) - Method in class org.apache.hadoop.yarn.client.api.async.impl.AMRMClientAsyncImpl

setNMToken(String, Token) - Static method in class org.apache.hadoop.yarn.client.api.NMTokenCache

Sets the NMToken for node address only in the singleton obtained from NMTokenCache.getSingleton().

setNMTokenCache(NMTokenCache) - Method in class org.apache.hadoop.yarn.client.api.AMRMClient

Set the NM token cache for the AMRMClient.

setNMTokenCache(NMTokenCache) - Method in class org.apache.hadoop.yarn.client.api.NMClient

Set the NM Token cache of the NMClient.

setRMClient(ApplicationClientProtocol) - Method in class org.apache.hadoop.yarn.client.api.impl.YarnClientImpl

setSysErrPrintStream(PrintStream) - Method in class org.apache.hadoop.yarn.client.cli.YarnCLI

setSysOutPrintStream(PrintStream) - Method in class org.apache.hadoop.yarn.client.cli.YarnCLI

setToken(String, Token) - Method in class org.apache.hadoop.yarn.client.api.NMTokenCache

Sets the NMToken for node address

startContainer(Container, ContainerLaunchContext) - Method in class org.apache.hadoop.yarn.client.api.impl.NMClientImpl

startContainer(Container, ContainerLaunchContext) - Method in class org.apache.hadoop.yarn.client.api.NMClient

Start an allocated container.

startContainerAsync(Container, ContainerLaunchContext) - Method in class org.apache.hadoop.yarn.client.api.async.impl.NMClientAsyncImpl

startContainerAsync(Container, ContainerLaunchContext) - Method in class org.apache.hadoop.yarn.client.api.async.NMClientAsync

startedContainers - Variable in class org.apache.hadoop.yarn.client.api.impl.NMClientImpl

stateMachineFactory - Static variable in class org.apache.hadoop.yarn.client.api.async.impl.NMClientAsyncImpl.StatefulContainer

statePollIntervalMillis - Variable in class org.apache.hadoop.yarn.client.api.impl.YarnClientImpl

STATUS_CMD - Static variable in class org.apache.hadoop.yarn.client.cli.YarnCLI

stop() - Method in class org.apache.hadoop.yarn.client.cli.YarnCLI

STOP_BEFORE_START_ERROR_MSG - Static variable in class org.apache.hadoop.yarn.client.api.async.impl.NMClientAsyncImpl.StatefulContainer.OutOfOrderTransition

stopAllProxies() - Method in class org.apache.hadoop.yarn.client.api.impl.ContainerManagementProtocolProxy

stopContainer(ContainerId, NodeId) - Method in class org.apache.hadoop.yarn.client.api.impl.NMClientImpl

stopContainer(ContainerId, NodeId) - Method in class org.apache.hadoop.yarn.client.api.NMClient

Stop an started container.

stopContainerAsync(ContainerId, NodeId) - Method in class org.apache.hadoop.yarn.client.api.async.impl.NMClientAsyncImpl

stopContainerAsync(ContainerId, NodeId) - Method in class org.apache.hadoop.yarn.client.api.async.NMClientAsync

stopped - Variable in class org.apache.hadoop.yarn.client.api.async.impl.NMClientAsyncImpl

submitApplication(ApplicationSubmissionContext) - Method in class org.apache.hadoop.yarn.client.api.impl.YarnClientImpl

submitApplication(ApplicationSubmissionContext) - Method in class org.apache.hadoop.yarn.client.api.YarnClient

Submit a new application to YARN. It is a blocking call, such that it will not return ApplicationId until the submitted application has been submitted and accepted by the ResourceManager.

syserr - Variable in class org.apache.hadoop.yarn.client.cli.YarnCLI

sysout - Variable in class org.apache.hadoop.yarn.client.cli.YarnCLI

T

threadPool - Variable in class org.apache.hadoop.yarn.client.api.async.impl.NMClientAsyncImpl

toString() - Method in class org.apache.hadoop.yarn.client.api.AMRMClient.ContainerRequest

transition(NMClientAsyncImpl.StatefulContainer, NMClientAsyncImpl.ContainerEvent) - Method in class org.apache.hadoop.yarn.client.api.async.impl.NMClientAsyncImpl.StatefulContainer.OutOfOrderTransition

transition(NMClientAsyncImpl.StatefulContainer, NMClientAsyncImpl.ContainerEvent) - Method in class org.apache.hadoop.yarn.client.api.async.impl.NMClientAsyncImpl.StatefulContainer.StartContainerTransition

transition(NMClientAsyncImpl.StatefulContainer, NMClientAsyncImpl.ContainerEvent) - Method in class org.apache.hadoop.yarn.client.api.async.impl.NMClientAsyncImpl.StatefulContainer.StopContainerTransition

U

unregisterApplicationMaster(FinalApplicationStatus, String, String) - Method in class org.apache.hadoop.yarn.client.api.AMRMClient

Unregister the application master.

unregisterApplicationMaster(FinalApplicationStatus, String, String) - Method in class org.apache.hadoop.yarn.client.api.async.AMRMClientAsync

Unregister the application master.

unregisterApplicationMaster(FinalApplicationStatus, String, String) - Method in class org.apache.hadoop.yarn.client.api.async.impl.AMRMClientAsyncImpl

Unregister the application master.

unregisterApplicationMaster(FinalApplicationStatus, String, String) - Method in class org.apache.hadoop.yarn.client.api.impl.AMRMClientImpl

updateBlacklist(List<String>, List<String>) - Method in class org.apache.hadoop.yarn.client.api.AMRMClient

Update application's blacklist with addition or removal resources.

updateBlacklist(List<String>, List<String>) - Method in class org.apache.hadoop.yarn.client.api.impl.AMRMClientImpl

V

valueOf(String) - Static method in enum org.apache.hadoop.yarn.client.api.async.impl.NMClientAsyncImpl.ContainerEventType

Returns the enum constant of this type with the specified name.

valueOf(String) - Static method in enum org.apache.hadoop.yarn.client.api.async.impl.NMClientAsyncImpl.ContainerState

Returns the enum constant of this type with the specified name.

values() - Static method in enum org.apache.hadoop.yarn.client.api.async.impl.NMClientAsyncImpl.ContainerEventType

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.client.api.async.impl.NMClientAsyncImpl.ContainerState

Returns an array containing the constants of this enum type, in the order they are declared.

Y

YarnCLI - Class in org.apache.hadoop.yarn.client.cli

YarnCLI() - Constructor for class org.apache.hadoop.yarn.client.cli.YarnCLI

YarnClient - Class in org.apache.hadoop.yarn.client.api

YarnClient(String) - Constructor for class org.apache.hadoop.yarn.client.api.YarnClient

YarnClientApplication - Class in org.apache.hadoop.yarn.client.api

YarnClientApplication(GetNewApplicationResponse, ApplicationSubmissionContext) - Constructor for class org.apache.hadoop.yarn.client.api.YarnClientApplication

YarnClientImpl - Class in org.apache.hadoop.yarn.client.api.impl

YarnClientImpl() - Constructor for class org.apache.hadoop.yarn.client.api.impl.YarnClientImpl

A B C E G H I K L M N O P R S T U V Y