Index
All Classes and Interfaces|All Packages
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() - Method in class org.apache.hadoop.mapred.YARNRunner
- close(ClientProtocol) - Method in class org.apache.hadoop.mapred.YarnClientProtocolProvider
- create(InetSocketAddress, Configuration) - Method in class org.apache.hadoop.mapred.YarnClientProtocolProvider
- create(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(EnumSet<YarnApplicationState>) - Method in class org.apache.hadoop.mapred.ResourceMgrDelegate
- getApplications(Set<String>) - 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
- getAttributesToNodes(Set<NodeAttributeKey>) - 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
- getClusterAttributes() - Method in class org.apache.hadoop.mapred.ResourceMgrDelegate
- 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(Text) - Method in class org.apache.hadoop.mapred.ResourceMgrDelegate
- getDelegationToken(Text) - Method in class org.apache.hadoop.mapred.YARNRunner
- getDelegationToken(GetDelegationTokenRequest) - Method in class org.apache.hadoop.mapred.NotRunningJob
- 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
- getNodeToAttributes(Set<String>) - 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
- getQueueInfo(String, 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
- getResourceProfile(String) - Method in class org.apache.hadoop.mapred.ResourceMgrDelegate
- getResourceProfiles() - Method in class org.apache.hadoop.mapred.ResourceMgrDelegate
- 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(JobID, TaskType) - Method in class org.apache.hadoop.mapred.YARNRunner
- getTaskReports(GetTaskReportsRequest) - Method in class org.apache.hadoop.mapred.NotRunningJob
- 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(JobID) - Method in class org.apache.hadoop.mapred.YARNRunner
- killJob(KillJobRequest) - Method in class org.apache.hadoop.mapred.NotRunningJob
- killTask(TaskAttemptID, boolean) - Method in class org.apache.hadoop.mapred.ClientServiceDelegate
- killTask(TaskAttemptID, boolean) - Method in class org.apache.hadoop.mapred.YARNRunner
- killTask(KillTaskRequest) - Method in class org.apache.hadoop.mapred.NotRunningJob
- 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
- shellToContainer(ContainerId, ShellContainerCommand) - Method in class org.apache.hadoop.mapred.ResourceMgrDelegate
- 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(Configuration)but allowing injectingResourceMgrDelegate. - YARNRunner(Configuration, ResourceMgrDelegate, ClientCache) - Constructor for class org.apache.hadoop.mapred.YARNRunner
-
Similar to
YARNRunner(Configuration, ResourceMgrDelegate)but allowing injectingClientCache.
All Classes and Interfaces|All Packages