A C D F G I K L M N O R S U Y

A

AM_CONTAINER_PRIORITY - Static variable in class org.apache.hadoop.mapred.YARNRunner

C

cancelDelegationToken(CancelDelegationTokenRequest) - Method in class org.apache.hadoop.mapred.NotRunningJob

cancelDelegationToken(Token<DelegationTokenIdentifier>) - Method in class org.apache.hadoop.mapred.YARNRunner

client - Variable in class org.apache.hadoop.mapred.ResourceMgrDelegate

ClientCache - Class in org.apache.hadoop.mapred

ClientCache(Configuration, ResourceMgrDelegate) - Constructor for class org.apache.hadoop.mapred.ClientCache

ClientServiceDelegate - Class in org.apache.hadoop.mapred

ClientServiceDelegate(Configuration, ResourceMgrDelegate, JobID, MRClientProtocol) - Constructor for class org.apache.hadoop.mapred.ClientServiceDelegate

close() - Method in class org.apache.hadoop.mapred.ClientCache

close() - Method in class org.apache.hadoop.mapred.ClientServiceDelegate

close(ClientProtocol) - Method in class org.apache.hadoop.mapred.YarnClientProtocolProvider

close() - Method in class org.apache.hadoop.mapred.YARNRunner

create(Configuration) - Method in class org.apache.hadoop.mapred.YarnClientProtocolProvider

create(InetSocketAddress, Configuration) - Method in class org.apache.hadoop.mapred.YarnClientProtocolProvider

createApplication() - Method in class org.apache.hadoop.mapred.ResourceMgrDelegate

createApplicationSubmissionContext(Configuration, String, Credentials) - Method in class org.apache.hadoop.mapred.YARNRunner

Constructs all the necessary information to start the MR AM.

createReservation() - Method in class org.apache.hadoop.mapred.ResourceMgrDelegate

D

deleteReservation(ReservationDeleteRequest) - Method in class org.apache.hadoop.mapred.ResourceMgrDelegate

F

failApplicationAttempt(ApplicationAttemptId) - Method in class org.apache.hadoop.mapred.ResourceMgrDelegate

failTaskAttempt(FailTaskAttemptRequest) - Method in class org.apache.hadoop.mapred.NotRunningJob

G

getActiveTrackers() - Method in class org.apache.hadoop.mapred.ResourceMgrDelegate

getActiveTrackers() - Method in class org.apache.hadoop.mapred.YARNRunner

getAllJobs() - Method in class org.apache.hadoop.mapred.ResourceMgrDelegate

getAllJobs() - Method in class org.apache.hadoop.mapred.YARNRunner

getAllQueues() - Method in class org.apache.hadoop.mapred.ResourceMgrDelegate

getAMRMToken(ApplicationId) - Method in class org.apache.hadoop.mapred.ResourceMgrDelegate

getApplicationAttemptReport(ApplicationAttemptId) - Method in class org.apache.hadoop.mapred.ResourceMgrDelegate

getApplicationAttempts(ApplicationId) - Method in class org.apache.hadoop.mapred.ResourceMgrDelegate

getApplicationId() - Method in class org.apache.hadoop.mapred.ResourceMgrDelegate

getApplicationReport(ApplicationId) - Method in class org.apache.hadoop.mapred.ResourceMgrDelegate

getApplications() - Method in class org.apache.hadoop.mapred.ResourceMgrDelegate

getApplications(Set<String>) - Method in class org.apache.hadoop.mapred.ResourceMgrDelegate

getApplications(EnumSet<YarnApplicationState>) - Method in class org.apache.hadoop.mapred.ResourceMgrDelegate

getApplications(Set<String>, EnumSet<YarnApplicationState>) - Method in class org.apache.hadoop.mapred.ResourceMgrDelegate

getApplications(Set<String>, EnumSet<YarnApplicationState>, Set<String>) - Method in class org.apache.hadoop.mapred.ResourceMgrDelegate

getApplications(Set<String>, Set<String>, Set<String>, EnumSet<YarnApplicationState>) - Method in class org.apache.hadoop.mapred.ResourceMgrDelegate

getBlacklistedTrackers() - Method in class org.apache.hadoop.mapred.ResourceMgrDelegate

getBlacklistedTrackers() - Method in class org.apache.hadoop.mapred.YARNRunner

getChildQueueInfos(String) - Method in class org.apache.hadoop.mapred.ResourceMgrDelegate

getChildQueues(String) - Method in class org.apache.hadoop.mapred.ResourceMgrDelegate

getChildQueues(String) - Method in class org.apache.hadoop.mapred.YARNRunner

getClient(JobID) - Method in class org.apache.hadoop.mapred.ClientCache

getClusterMetrics() - Method in class org.apache.hadoop.mapred.ResourceMgrDelegate

getClusterMetrics() - Method in class org.apache.hadoop.mapred.YARNRunner

getClusterNodeLabels() - Method in class org.apache.hadoop.mapred.ResourceMgrDelegate

getConnectAddress() - Method in class org.apache.hadoop.mapred.NotRunningJob

getContainerReport(ContainerId) - Method in class org.apache.hadoop.mapred.ResourceMgrDelegate

getContainers(ApplicationAttemptId) - Method in class org.apache.hadoop.mapred.ResourceMgrDelegate

getCounters(GetCountersRequest) - Method in class org.apache.hadoop.mapred.NotRunningJob

getDelegationToken(GetDelegationTokenRequest) - Method in class org.apache.hadoop.mapred.NotRunningJob

getDelegationToken(Text) - Method in class org.apache.hadoop.mapred.ResourceMgrDelegate

getDelegationToken(Text) - Method in class org.apache.hadoop.mapred.YARNRunner

getDiagnostics(GetDiagnosticsRequest) - Method in class org.apache.hadoop.mapred.NotRunningJob

getFilesystemName() - Method in class org.apache.hadoop.mapred.ResourceMgrDelegate

getFilesystemName() - Method in class org.apache.hadoop.mapred.YARNRunner

getInitializedHSProxy() - Method in class org.apache.hadoop.mapred.ClientCache

getJobCounters(JobID) - Method in class org.apache.hadoop.mapred.ClientServiceDelegate

getJobCounters(JobID) - Method in class org.apache.hadoop.mapred.YARNRunner

getJobHistoryDir() - Method in class org.apache.hadoop.mapred.YARNRunner

getJobReport(GetJobReportRequest) - Method in class org.apache.hadoop.mapred.NotRunningJob

getJobStatus(JobID) - Method in class org.apache.hadoop.mapred.ClientServiceDelegate

getJobStatus(JobID) - Method in class org.apache.hadoop.mapred.YARNRunner

getJobTrackerStatus() - Method in class org.apache.hadoop.mapred.YARNRunner

getLabelsToNodes() - Method in class org.apache.hadoop.mapred.ResourceMgrDelegate

getLabelsToNodes(Set<String>) - Method in class org.apache.hadoop.mapred.ResourceMgrDelegate

getLogFileParams(JobID, TaskAttemptID) - Method in class org.apache.hadoop.mapred.YARNRunner

getLogFilePath(JobID, TaskAttemptID) - Method in class org.apache.hadoop.mapred.ClientServiceDelegate

getMaxClientRetry() - Method in class org.apache.hadoop.mapred.ClientServiceDelegate

getNewJobID() - Method in class org.apache.hadoop.mapred.ResourceMgrDelegate

getNewJobID() - Method in class org.apache.hadoop.mapred.YARNRunner

getNodeReports(NodeState...) - Method in class org.apache.hadoop.mapred.ResourceMgrDelegate

getNodeToLabels() - Method in class org.apache.hadoop.mapred.ResourceMgrDelegate

getProtocolSignature(String, long, int) - Method in class org.apache.hadoop.mapred.YARNRunner

getProtocolVersion(String, long) - Method in class org.apache.hadoop.mapred.ResourceMgrDelegate

getProtocolVersion(String, long) - Method in class org.apache.hadoop.mapred.YARNRunner

getQueue(String) - Method in class org.apache.hadoop.mapred.ResourceMgrDelegate

getQueue(String) - Method in class org.apache.hadoop.mapred.YARNRunner

getQueueAclsForCurrentUser() - Method in class org.apache.hadoop.mapred.ResourceMgrDelegate

getQueueAclsForCurrentUser() - Method in class org.apache.hadoop.mapred.YARNRunner

getQueueAclsInfo() - Method in class org.apache.hadoop.mapred.ResourceMgrDelegate

getQueueAdmins(String) - Method in class org.apache.hadoop.mapred.YARNRunner

getQueueInfo(String) - Method in class org.apache.hadoop.mapred.ResourceMgrDelegate

getQueues() - Method in class org.apache.hadoop.mapred.ResourceMgrDelegate

getQueues() - Method in class org.apache.hadoop.mapred.YARNRunner

getResourceTypeInfo() - Method in class org.apache.hadoop.mapred.ResourceMgrDelegate

getRMDelegationToken(Text) - Method in class org.apache.hadoop.mapred.ResourceMgrDelegate

getRMDelegationTokenService() - Method in class org.apache.hadoop.mapred.ResourceMgrDelegate

getRootQueueInfos() - Method in class org.apache.hadoop.mapred.ResourceMgrDelegate

getRootQueues() - Method in class org.apache.hadoop.mapred.ResourceMgrDelegate

getRootQueues() - Method in class org.apache.hadoop.mapred.YARNRunner

getStagingAreaDir() - Method in class org.apache.hadoop.mapred.ResourceMgrDelegate

getStagingAreaDir() - Method in class org.apache.hadoop.mapred.YARNRunner

getSystemDir() - Method in class org.apache.hadoop.mapred.ResourceMgrDelegate

getSystemDir() - Method in class org.apache.hadoop.mapred.YARNRunner

getTaskAttemptCompletionEvents(GetTaskAttemptCompletionEventsRequest) - Method in class org.apache.hadoop.mapred.NotRunningJob

getTaskAttemptReport(GetTaskAttemptReportRequest) - Method in class org.apache.hadoop.mapred.NotRunningJob

getTaskCompletionEvents(JobID, int, int) - Method in class org.apache.hadoop.mapred.ClientServiceDelegate

getTaskCompletionEvents(JobID, int, int) - Method in class org.apache.hadoop.mapred.YARNRunner

getTaskDiagnostics(TaskAttemptID) - Method in class org.apache.hadoop.mapred.ClientServiceDelegate

getTaskDiagnostics(TaskAttemptID) - Method in class org.apache.hadoop.mapred.YARNRunner

getTaskReport(GetTaskReportRequest) - Method in class org.apache.hadoop.mapred.NotRunningJob

getTaskReports(JobID, TaskType) - Method in class org.apache.hadoop.mapred.ClientServiceDelegate

getTaskReports(GetTaskReportsRequest) - Method in class org.apache.hadoop.mapred.NotRunningJob

getTaskReports(JobID, TaskType) - Method in class org.apache.hadoop.mapred.YARNRunner

getTaskTrackerExpiryInterval() - Method in class org.apache.hadoop.mapred.ResourceMgrDelegate

getTaskTrackerExpiryInterval() - Method in class org.apache.hadoop.mapred.YARNRunner

getYarnClusterMetrics() - Method in class org.apache.hadoop.mapred.ResourceMgrDelegate

I

instantiateHistoryProxy() - Method in class org.apache.hadoop.mapred.ClientCache

K

killApplication(ApplicationId) - Method in class org.apache.hadoop.mapred.ResourceMgrDelegate

killApplication(ApplicationId, String) - Method in class org.apache.hadoop.mapred.ResourceMgrDelegate

killJob(JobID) - Method in class org.apache.hadoop.mapred.ClientServiceDelegate

killJob(KillJobRequest) - Method in class org.apache.hadoop.mapred.NotRunningJob

killJob(JobID) - Method in class org.apache.hadoop.mapred.YARNRunner

killTask(TaskAttemptID, boolean) - Method in class org.apache.hadoop.mapred.ClientServiceDelegate

killTask(KillTaskRequest) - Method in class org.apache.hadoop.mapred.NotRunningJob

killTask(TaskAttemptID, boolean) - Method in class org.apache.hadoop.mapred.YARNRunner

killTaskAttempt(KillTaskAttemptRequest) - Method in class org.apache.hadoop.mapred.NotRunningJob

L

listReservations(ReservationListRequest) - Method in class org.apache.hadoop.mapred.ResourceMgrDelegate

M

moveApplicationAcrossQueues(ApplicationId, String) - Method in class org.apache.hadoop.mapred.ResourceMgrDelegate

N

NotRunningJob - Class in org.apache.hadoop.mapred

O

org.apache.hadoop.mapred - package org.apache.hadoop.mapred

R

renewDelegationToken(RenewDelegationTokenRequest) - Method in class org.apache.hadoop.mapred.NotRunningJob

renewDelegationToken(Token<DelegationTokenIdentifier>) - Method in class org.apache.hadoop.mapred.YARNRunner

ResourceMgrDelegate - Class in org.apache.hadoop.mapred

ResourceMgrDelegate(YarnConfiguration) - Constructor for class org.apache.hadoop.mapred.ResourceMgrDelegate

Delegate responsible for communicating with the Resource Manager's ApplicationClientProtocol.

S

serviceInit(Configuration) - Method in class org.apache.hadoop.mapred.ResourceMgrDelegate

serviceStart() - Method in class org.apache.hadoop.mapred.ResourceMgrDelegate

serviceStop() - Method in class org.apache.hadoop.mapred.ResourceMgrDelegate

setJobPriority(JobID, String) - Method in class org.apache.hadoop.mapred.ResourceMgrDelegate

setJobPriority(JobID, String) - Method in class org.apache.hadoop.mapred.YARNRunner

setResourceMgrDelegate(ResourceMgrDelegate) - Method in class org.apache.hadoop.mapred.YARNRunner

signalToContainer(ContainerId, SignalContainerCommand) - Method in class org.apache.hadoop.mapred.ResourceMgrDelegate

submitApplication(ApplicationSubmissionContext) - Method in class org.apache.hadoop.mapred.ResourceMgrDelegate

submitJob(JobID, String, Credentials) - Method in class org.apache.hadoop.mapred.YARNRunner

submitReservation(ReservationSubmissionRequest) - Method in class org.apache.hadoop.mapred.ResourceMgrDelegate

U

updateApplicationPriority(ApplicationId, Priority) - Method in class org.apache.hadoop.mapred.ResourceMgrDelegate

updateReservation(ReservationUpdateRequest) - Method in class org.apache.hadoop.mapred.ResourceMgrDelegate

Y

YarnClientProtocolProvider - Class in org.apache.hadoop.mapred

YarnClientProtocolProvider() - Constructor for class org.apache.hadoop.mapred.YarnClientProtocolProvider

YARNRunner - Class in org.apache.hadoop.mapred

This class enables the current JobClient (0.22 hadoop) to run on YARN.

YARNRunner(Configuration) - Constructor for class org.apache.hadoop.mapred.YARNRunner

Yarn runner incapsulates the client interface of yarn

YARNRunner(Configuration, ResourceMgrDelegate) - Constructor for class org.apache.hadoop.mapred.YARNRunner

Similar to YARNRunner.YARNRunner(Configuration) but allowing injecting ResourceMgrDelegate.

YARNRunner(Configuration, ResourceMgrDelegate, ClientCache) - Constructor for class org.apache.hadoop.mapred.YARNRunner

Similar to YARNRunner.YARNRunner(Configuration, ResourceMgrDelegate) but allowing injecting ClientCache.

A C D F G I K L M N O R S U Y