Skip navigation links
A B C D E F G H I J K L M N O P Q R S T U V W Y 

A

abortJob(JobContext, int) - Method in class org.apache.hadoop.CustomOutputCommitter
 
abortTask(TaskAttemptContext) - Method in class org.apache.hadoop.CustomOutputCommitter
 
acls - Variable in class org.apache.hadoop.mapreduce.v2.app.webapp.dao.JobInfo
 
add(double) - Method in class org.apache.hadoop.mapreduce.v2.app.speculate.DataStatistics
 
add(AMAttemptInfo) - Method in class org.apache.hadoop.mapreduce.v2.app.webapp.dao.AMAttemptsInfo
 
add(JobInfo) - Method in class org.apache.hadoop.mapreduce.v2.app.webapp.dao.JobsInfo
 
add(TaskAttemptInfo) - Method in class org.apache.hadoop.mapreduce.v2.app.webapp.dao.TaskAttemptsInfo
 
add(TaskInfo) - Method in class org.apache.hadoop.mapreduce.v2.app.webapp.dao.TasksInfo
 
addContainerReq(RMContainerRequestor.ContainerRequest) - Method in class org.apache.hadoop.mapreduce.v2.app.rm.RMContainerRequestor
 
addCounterUpdate(Enum<?>, long) - Method in class org.apache.hadoop.mapreduce.v2.app.job.event.JobCounterUpdateEvent
 
addDiagnostic(String) - Method in class org.apache.hadoop.mapreduce.v2.app.job.impl.JobImpl
 
addOpportunisticResourceRequest(Priority, Resource) - Method in class org.apache.hadoop.mapreduce.v2.app.rm.RMContainerRequestor
 
addOutstandingRequestOnResync() - Method in class org.apache.hadoop.mapreduce.v2.app.rm.RMContainerRequestor
 
addSpeculativeAttempt(TaskId) - Method in class org.apache.hadoop.mapreduce.v2.app.speculate.DefaultSpeculator
 
addTask(Task) - Method in class org.apache.hadoop.mapreduce.v2.app.job.impl.JobImpl
 
AllocatorRunnable() - Constructor for class org.apache.hadoop.mapreduce.v2.app.rm.RMCommunicator.AllocatorRunnable
 
allocatorThread - Variable in class org.apache.hadoop.mapreduce.v2.app.rm.RMCommunicator
 
AMAttemptInfo - Class in org.apache.hadoop.mapreduce.v2.app.webapp.dao
 
AMAttemptInfo() - Constructor for class org.apache.hadoop.mapreduce.v2.app.webapp.dao.AMAttemptInfo
 
AMAttemptInfo(AMInfo, String, String) - Constructor for class org.apache.hadoop.mapreduce.v2.app.webapp.dao.AMAttemptInfo
 
AMAttemptsInfo - Class in org.apache.hadoop.mapreduce.v2.app.webapp.dao
 
AMAttemptsInfo() - Constructor for class org.apache.hadoop.mapreduce.v2.app.webapp.dao.AMAttemptsInfo
 
AMParams - Interface in org.apache.hadoop.mapreduce.v2.app.webapp
Params constants for the AM webapp and the history webapp.
AMPreemptionPolicy - Interface in org.apache.hadoop.mapreduce.v2.app.rm.preemption
Policy encoding the MRAppMaster response to preemption requests from the ResourceManager.
AMPreemptionPolicy.Context - Class in org.apache.hadoop.mapreduce.v2.app.rm.preemption
 
AMWebApp - Class in org.apache.hadoop.mapreduce.v2.app.webapp
Application master webapp
AMWebApp() - Constructor for class org.apache.hadoop.mapreduce.v2.app.webapp.AMWebApp
 
AMWebServices - Class in org.apache.hadoop.mapreduce.v2.app.webapp
 
AMWebServices(App, AppContext) - Constructor for class org.apache.hadoop.mapreduce.v2.app.webapp.AMWebServices
 
App - Class in org.apache.hadoop.mapreduce.v2.app.webapp
 
app - Variable in class org.apache.hadoop.mapreduce.v2.app.webapp.AppController
 
APP_ID - Static variable in interface org.apache.hadoop.mapreduce.v2.app.webapp.AMParams
 
AppContext - Interface in org.apache.hadoop.mapreduce.v2.app
Context interface for sharing information across components in YARN App.
appContext - Variable in class org.apache.hadoop.mapreduce.v2.app.job.impl.TaskImpl
 
AppController - Class in org.apache.hadoop.mapreduce.v2.app.webapp
This class renders the various pages that the web app supports.
AppController(App, Configuration, Controller.RequestContext, String) - Constructor for class org.apache.hadoop.mapreduce.v2.app.webapp.AppController
 
AppController(App, Configuration, Controller.RequestContext) - Constructor for class org.apache.hadoop.mapreduce.v2.app.webapp.AppController
 
appId - Variable in class org.apache.hadoop.mapreduce.v2.app.webapp.dao.AppInfo
 
AppInfo - Class in org.apache.hadoop.mapreduce.v2.app.webapp.dao
 
AppInfo() - Constructor for class org.apache.hadoop.mapreduce.v2.app.webapp.dao.AppInfo
 
AppInfo(App, AppContext) - Constructor for class org.apache.hadoop.mapreduce.v2.app.webapp.dao.AppInfo
 
applicationACLs - Variable in class org.apache.hadoop.mapreduce.v2.app.rm.RMCommunicator
 
applicationId - Variable in class org.apache.hadoop.mapreduce.v2.app.rm.RMCommunicator
 
AppView - Class in org.apache.hadoop.mapreduce.v2.app.webapp
 
AppView() - Constructor for class org.apache.hadoop.mapreduce.v2.app.webapp.AppView
 
assignedContainer - Variable in class org.apache.hadoop.mapreduce.v2.app.webapp.dao.TaskAttemptInfo
 
assignedContainerId - Variable in class org.apache.hadoop.mapreduce.v2.app.webapp.dao.TaskAttemptInfo
 
atsEventDispatcher - Variable in class org.apache.hadoop.mapreduce.jobhistory.JobHistoryEventHandler
 
attempt - Variable in class org.apache.hadoop.mapreduce.v2.app.webapp.dao.AMAttemptsInfo
 
ATTEMPT_STATE - Static variable in interface org.apache.hadoop.mapreduce.v2.app.webapp.AMParams
 
attemptEnrolledTime(TaskAttemptId) - Method in class org.apache.hadoop.mapreduce.v2.app.speculate.NullTaskRuntimesEngine
 
attemptEnrolledTime(TaskAttemptId) - Method in interface org.apache.hadoop.mapreduce.v2.app.speculate.TaskRuntimeEstimator
 
attempts() - Method in class org.apache.hadoop.mapreduce.v2.app.webapp.AppController
Render the attempts page
attemptsPage() - Method in class org.apache.hadoop.mapreduce.v2.app.webapp.AppController
 
AttemptsPage - Class in org.apache.hadoop.mapreduce.v2.app.webapp
 
AttemptsPage() - Constructor for class org.apache.hadoop.mapreduce.v2.app.webapp.AttemptsPage
 

B

BlacklistedNodesInfo - Class in org.apache.hadoop.mapreduce.v2.app.webapp.dao
 
BlacklistedNodesInfo() - Constructor for class org.apache.hadoop.mapreduce.v2.app.webapp.dao.BlacklistedNodesInfo
 
BlacklistedNodesInfo(AppContext) - Constructor for class org.apache.hadoop.mapreduce.v2.app.webapp.dao.BlacklistedNodesInfo
 
burst() - Method in class org.apache.hadoop.mapred.WrappedProgressSplitsBlock
 

C

canCommit(TaskAttemptID) - Method in class org.apache.hadoop.mapred.TaskAttemptListenerImpl
Child checking whether it can commit.
canCommit(TaskAttemptId) - Method in class org.apache.hadoop.mapreduce.v2.app.job.impl.TaskImpl
 
canCommit(TaskAttemptId) - Method in interface org.apache.hadoop.mapreduce.v2.app.job.Task
Can the output of the taskAttempt be committed.
checkAccess(UserGroupInformation, JobACL) - Method in class org.apache.hadoop.mapreduce.v2.app.job.impl.JobImpl
 
checkAccess(UserGroupInformation, JobACL) - Method in interface org.apache.hadoop.mapreduce.v2.app.job.Job
 
CheckpointAMPreemptionPolicy - Class in org.apache.hadoop.mapreduce.v2.app.rm.preemption
This policy works in combination with an implementation of task checkpointing.
CheckpointAMPreemptionPolicy() - Constructor for class org.apache.hadoop.mapreduce.v2.app.rm.preemption.CheckpointAMPreemptionPolicy
 
checkReadyForCommit() - Method in class org.apache.hadoop.mapreduce.v2.app.job.impl.JobImpl
 
cleanupStagingDir() - Method in class org.apache.hadoop.mapreduce.v2.app.MRAppMaster
clean up staging directories for the job.
ClientHSPolicyProvider - Class in org.apache.hadoop.mapreduce.v2.app.security.authorize
PolicyProvider for MapReduce history server protocols.
ClientHSPolicyProvider() - Constructor for class org.apache.hadoop.mapreduce.v2.app.security.authorize.ClientHSPolicyProvider
 
ClientService - Interface in org.apache.hadoop.mapreduce.v2.app.client
 
clock - Variable in class org.apache.hadoop.mapreduce.v2.app.job.impl.TaskImpl
 
closeEventWriter(JobId) - Method in class org.apache.hadoop.mapreduce.jobhistory.JobHistoryEventHandler
 
closeWriter(JobId) - Method in class org.apache.hadoop.mapreduce.jobhistory.JobHistoryEventHandler
Close the event writer for this id
ClusterInfo - Class in org.apache.hadoop.mapreduce.v2.app
 
ClusterInfo() - Constructor for class org.apache.hadoop.mapreduce.v2.app.ClusterInfo
 
ClusterInfo(Resource) - Constructor for class org.apache.hadoop.mapreduce.v2.app.ClusterInfo
 
commitJob(JobContext) - Method in class org.apache.hadoop.CustomOutputCommitter
 
commitPending(TaskAttemptID, TaskStatus) - Method in class org.apache.hadoop.mapred.TaskAttemptListenerImpl
TaskAttempt is reporting that it is in commit_pending and it is waiting for the commit Response
Commit it a two-phased protocol.
commitTask(TaskAttemptContext) - Method in class org.apache.hadoop.CustomOutputCommitter
 
CommitterEvent - Class in org.apache.hadoop.mapreduce.v2.app.commit
 
CommitterEvent(CommitterEventType) - Constructor for class org.apache.hadoop.mapreduce.v2.app.commit.CommitterEvent
 
CommitterEventHandler - Class in org.apache.hadoop.mapreduce.v2.app.commit
 
CommitterEventHandler(AppContext, OutputCommitter, RMHeartbeatHandler) - Constructor for class org.apache.hadoop.mapreduce.v2.app.commit.CommitterEventHandler
 
CommitterEventHandler(AppContext, OutputCommitter, RMHeartbeatHandler, ClassLoader) - Constructor for class org.apache.hadoop.mapreduce.v2.app.commit.CommitterEventHandler
 
CommitterEventType - Enum in org.apache.hadoop.mapreduce.v2.app.commit
 
CommitterJobAbortEvent - Class in org.apache.hadoop.mapreduce.v2.app.commit
 
CommitterJobAbortEvent(JobId, JobContext, JobStatus.State) - Constructor for class org.apache.hadoop.mapreduce.v2.app.commit.CommitterJobAbortEvent
 
CommitterJobCommitEvent - Class in org.apache.hadoop.mapreduce.v2.app.commit
 
CommitterJobCommitEvent(JobId, JobContext) - Constructor for class org.apache.hadoop.mapreduce.v2.app.commit.CommitterJobCommitEvent
 
CommitterJobSetupEvent - Class in org.apache.hadoop.mapreduce.v2.app.commit
 
CommitterJobSetupEvent(JobId, JobContext) - Constructor for class org.apache.hadoop.mapreduce.v2.app.commit.CommitterJobSetupEvent
 
CommitterTaskAbortEvent - Class in org.apache.hadoop.mapreduce.v2.app.commit
 
CommitterTaskAbortEvent(TaskAttemptId, TaskAttemptContext) - Constructor for class org.apache.hadoop.mapreduce.v2.app.commit.CommitterTaskAbortEvent
 
commonPreHead(Hamlet.HTML<HtmlPage.__>) - Method in class org.apache.hadoop.mapreduce.v2.app.webapp.AppView
 
completedJob(Job) - Method in class org.apache.hadoop.mapreduce.v2.app.metrics.MRAppMetrics
 
completedTask(Task) - Method in class org.apache.hadoop.mapreduce.v2.app.metrics.MRAppMetrics
 
computeAvailableContainers(Resource, Resource, EnumSet<YarnServiceProtos.SchedulerResourceTypes>) - Static method in class org.apache.hadoop.mapreduce.v2.app.rm.ResourceCalculatorUtils
 
computeIgnoreBlacklisting() - Method in class org.apache.hadoop.mapreduce.v2.app.rm.RMContainerRequestor
 
conf - Variable in class org.apache.hadoop.mapreduce.v2.app.job.impl.JobImpl
 
conf - Variable in class org.apache.hadoop.mapreduce.v2.app.job.impl.TaskAttemptImpl
 
conf - Variable in class org.apache.hadoop.mapreduce.v2.app.job.impl.TaskImpl
 
conf() - Method in class org.apache.hadoop.mapreduce.v2.app.webapp.AppController
Render the /conf page
ConfBlock - Class in org.apache.hadoop.mapreduce.v2.app.webapp
Render the configuration for this job.
ConfEntryInfo - Class in org.apache.hadoop.mapreduce.v2.app.webapp.dao
 
ConfEntryInfo() - Constructor for class org.apache.hadoop.mapreduce.v2.app.webapp.dao.ConfEntryInfo
 
ConfEntryInfo(String, String) - Constructor for class org.apache.hadoop.mapreduce.v2.app.webapp.dao.ConfEntryInfo
 
ConfEntryInfo(String, String, String[]) - Constructor for class org.apache.hadoop.mapreduce.v2.app.webapp.dao.ConfEntryInfo
 
ConfInfo - Class in org.apache.hadoop.mapreduce.v2.app.webapp.dao
 
ConfInfo() - Constructor for class org.apache.hadoop.mapreduce.v2.app.webapp.dao.ConfInfo
 
ConfInfo(Job) - Constructor for class org.apache.hadoop.mapreduce.v2.app.webapp.dao.ConfInfo
 
confPage() - Method in class org.apache.hadoop.mapreduce.v2.app.webapp.AppController
 
constructFinalFullcounters() - Method in class org.apache.hadoop.mapreduce.v2.app.job.impl.JobImpl
 
container - Variable in class org.apache.hadoop.mapreduce.v2.app.job.impl.TaskAttemptImpl
 
ContainerAllocator - Interface in org.apache.hadoop.mapreduce.v2.app.rm
 
ContainerAllocator.EventType - Enum in org.apache.hadoop.mapreduce.v2.app.rm
 
ContainerAllocatorEvent - Class in org.apache.hadoop.mapreduce.v2.app.rm
 
ContainerAllocatorEvent(TaskAttemptId, ContainerAllocator.EventType) - Constructor for class org.apache.hadoop.mapreduce.v2.app.rm.ContainerAllocatorEvent
 
ContainerFailedEvent - Class in org.apache.hadoop.mapreduce.v2.app.rm
 
ContainerFailedEvent(TaskAttemptId, String) - Constructor for class org.apache.hadoop.mapreduce.v2.app.rm.ContainerFailedEvent
 
containerFailedOnHost(String) - Method in class org.apache.hadoop.mapreduce.v2.app.rm.RMContainerRequestor
 
containerId - Variable in class org.apache.hadoop.mapreduce.v2.app.webapp.dao.AMAttemptInfo
 
ContainerLauncher - Interface in org.apache.hadoop.mapreduce.v2.app.launcher
 
ContainerLauncher.EventType - Enum in org.apache.hadoop.mapreduce.v2.app.launcher
 
ContainerLauncherEvent - Class in org.apache.hadoop.mapreduce.v2.app.launcher
 
ContainerLauncherEvent(TaskAttemptId, ContainerId, String, Token, ContainerLauncher.EventType) - Constructor for class org.apache.hadoop.mapreduce.v2.app.launcher.ContainerLauncherEvent
 
ContainerLauncherEvent(TaskAttemptId, ContainerId, String, Token, ContainerLauncher.EventType, boolean) - Constructor for class org.apache.hadoop.mapreduce.v2.app.launcher.ContainerLauncherEvent
 
ContainerLauncherImpl - Class in org.apache.hadoop.mapreduce.v2.app.launcher
This class is responsible for launching of containers.
ContainerLauncherImpl(AppContext) - Constructor for class org.apache.hadoop.mapreduce.v2.app.launcher.ContainerLauncherImpl
 
ContainerRemoteLaunchEvent - Class in org.apache.hadoop.mapreduce.v2.app.launcher
 
ContainerRemoteLaunchEvent(TaskAttemptId, ContainerLaunchContext, Container, Task) - Constructor for class org.apache.hadoop.mapreduce.v2.app.launcher.ContainerRemoteLaunchEvent
 
ContainerRequestEvent - Class in org.apache.hadoop.mapreduce.v2.app.rm
 
ContainerRequestEvent(TaskAttemptId, Resource, String[], String[]) - Constructor for class org.apache.hadoop.mapreduce.v2.app.rm.ContainerRequestEvent
 
containersNeededChange() - Method in class org.apache.hadoop.mapreduce.v2.app.speculate.SpeculatorEvent
 
content() - Method in class org.apache.hadoop.mapreduce.v2.app.webapp.AppView
 
content() - Method in class org.apache.hadoop.mapreduce.v2.app.webapp.AttemptsPage
 
content() - Method in class org.apache.hadoop.mapreduce.v2.app.webapp.CountersPage
 
content() - Method in class org.apache.hadoop.mapreduce.v2.app.webapp.InfoPage
 
content() - Method in class org.apache.hadoop.mapreduce.v2.app.webapp.JobConfPage
The body of this block is the configuration block.
content() - Method in class org.apache.hadoop.mapreduce.v2.app.webapp.JobPage
 
content() - Method in class org.apache.hadoop.mapreduce.v2.app.webapp.SingleCounterPage
The content of this page is the CountersBlock now.
content() - Method in class org.apache.hadoop.mapreduce.v2.app.webapp.TaskPage
 
content() - Method in class org.apache.hadoop.mapreduce.v2.app.webapp.TasksPage
 
Context() - Constructor for class org.apache.hadoop.mapreduce.v2.app.rm.preemption.AMPreemptionPolicy.Context
 
contextualize(Configuration, AppContext) - Method in class org.apache.hadoop.mapreduce.v2.app.speculate.ExponentiallySmoothedTaskRuntimeEstimator
 
contextualize(Configuration, AppContext) - Method in class org.apache.hadoop.mapreduce.v2.app.speculate.NullTaskRuntimesEngine
 
contextualize(Configuration, AppContext) - Method in class org.apache.hadoop.mapreduce.v2.app.speculate.SimpleExponentialTaskRuntimeEstimator
 
contextualize(Configuration, AppContext) - Method in interface org.apache.hadoop.mapreduce.v2.app.speculate.TaskRuntimeEstimator
 
count() - Method in class org.apache.hadoop.mapreduce.v2.app.speculate.DataStatistics
 
counter - Variable in class org.apache.hadoop.mapreduce.v2.app.webapp.dao.CounterGroupInfo
 
counter - Variable in class org.apache.hadoop.mapreduce.v2.app.webapp.dao.TaskCounterGroupInfo
 
COUNTER_GROUP - Static variable in interface org.apache.hadoop.mapreduce.v2.app.webapp.AMParams
 
COUNTER_NAME - Static variable in interface org.apache.hadoop.mapreduce.v2.app.webapp.AMParams
 
counterGroup - Variable in class org.apache.hadoop.mapreduce.v2.app.webapp.dao.JobCounterInfo
 
CounterGroupInfo - Class in org.apache.hadoop.mapreduce.v2.app.webapp.dao
 
CounterGroupInfo() - Constructor for class org.apache.hadoop.mapreduce.v2.app.webapp.dao.CounterGroupInfo
 
CounterGroupInfo(String, CounterGroup, CounterGroup, CounterGroup) - Constructor for class org.apache.hadoop.mapreduce.v2.app.webapp.dao.CounterGroupInfo
 
counterGroupName - Variable in class org.apache.hadoop.mapreduce.v2.app.webapp.dao.CounterGroupInfo
 
counterGroupName - Variable in class org.apache.hadoop.mapreduce.v2.app.webapp.dao.TaskCounterGroupInfo
 
CounterIncrementalUpdate(Enum<?>, long) - Constructor for class org.apache.hadoop.mapreduce.v2.app.job.event.JobCounterUpdateEvent.CounterIncrementalUpdate
 
CounterInfo - Class in org.apache.hadoop.mapreduce.v2.app.webapp.dao
 
CounterInfo() - Constructor for class org.apache.hadoop.mapreduce.v2.app.webapp.dao.CounterInfo
 
CounterInfo(Counter, Counter, Counter) - Constructor for class org.apache.hadoop.mapreduce.v2.app.webapp.dao.CounterInfo
 
counters - Variable in class org.apache.hadoop.mapreduce.v2.app.job.event.TaskAttemptStatusUpdateEvent.TaskAttemptStatus
 
CountersBlock - Class in org.apache.hadoop.mapreduce.v2.app.webapp
 
countersPage() - Method in class org.apache.hadoop.mapreduce.v2.app.webapp.AppController
 
CountersPage - Class in org.apache.hadoop.mapreduce.v2.app.webapp
 
CountersPage() - Constructor for class org.apache.hadoop.mapreduce.v2.app.webapp.CountersPage
 
create() - Static method in class org.apache.hadoop.mapreduce.v2.app.metrics.MRAppMetrics
 
create(MetricsSystem) - Static method in class org.apache.hadoop.mapreduce.v2.app.metrics.MRAppMetrics
 
createAssignedRequests() - Method in class org.apache.hadoop.mapreduce.v2.app.rm.RMContainerAllocator
 
createAttempt() - Method in class org.apache.hadoop.mapreduce.v2.app.job.impl.MapTaskImpl
 
createAttempt() - Method in class org.apache.hadoop.mapreduce.v2.app.job.impl.ReduceTaskImpl
 
createAttempt() - Method in class org.apache.hadoop.mapreduce.v2.app.job.impl.TaskImpl
 
createClientService(AppContext) - Method in class org.apache.hadoop.mapreduce.v2.app.MRAppMaster
 
createCommitterEventHandler(AppContext, OutputCommitter) - Method in class org.apache.hadoop.mapreduce.v2.app.MRAppMaster
 
createContainerAllocator(ClientService, AppContext) - Method in class org.apache.hadoop.mapreduce.v2.app.MRAppMaster
 
createContainerFinishedEvent(ContainerStatus, TaskAttemptId) - Method in class org.apache.hadoop.mapreduce.v2.app.rm.RMContainerAllocator
 
createContainerLauncher(AppContext) - Method in class org.apache.hadoop.mapreduce.v2.app.MRAppMaster
 
createContainerRequestEventForFailedContainer(TaskAttemptId, Resource) - Static method in class org.apache.hadoop.mapreduce.v2.app.rm.ContainerRequestEvent
 
createDispatcher() - Method in class org.apache.hadoop.mapreduce.jobhistory.JobHistoryEventHandler
 
createDispatcher() - Method in class org.apache.hadoop.mapreduce.v2.app.MRAppMaster
 
createEventProcessor(ContainerLauncherEvent) - Method in class org.apache.hadoop.mapreduce.v2.app.launcher.ContainerLauncherImpl
 
createEventWriter(Path) - Method in class org.apache.hadoop.mapreduce.jobhistory.JobHistoryEventHandler
 
createForecast(long, int, long, long) - Static method in class org.apache.hadoop.mapreduce.v2.app.speculate.forecast.SimpleExponentialSmoothing
 
createJob(Configuration, JobStateInternal, String) - Method in class org.apache.hadoop.mapreduce.v2.app.MRAppMaster
Create and initialize (but don't start) a single job.
createJobFinishEventHandler() - Method in class org.apache.hadoop.mapreduce.v2.app.MRAppMaster
create an event handler that handles the job finish event.
createJobHistoryHandler(AppContext) - Method in class org.apache.hadoop.mapreduce.v2.app.MRAppMaster
 
createPreemptionPolicy(Configuration) - Method in class org.apache.hadoop.mapreduce.v2.app.MRAppMaster
 
createRemoteTask() - Method in class org.apache.hadoop.mapred.MapTaskAttemptImpl
 
createRemoteTask() - Method in class org.apache.hadoop.mapred.ReduceTaskAttemptImpl
 
createRemoteTask() - Method in class org.apache.hadoop.mapreduce.v2.app.job.impl.TaskAttemptImpl
 
createSchedulerProxy() - Method in class org.apache.hadoop.mapreduce.v2.app.rm.RMCommunicator
 
createSpeculator(Configuration, AppContext) - Method in class org.apache.hadoop.mapreduce.v2.app.MRAppMaster
 
createSplits(JobImpl, JobId) - Method in class org.apache.hadoop.mapreduce.v2.app.job.impl.JobImpl.InitTransition
 
createStagingDirCleaningService() - Method in class org.apache.hadoop.mapreduce.v2.app.MRAppMaster
 
createTaskAttemptFinishingMonitor(EventHandler) - Method in class org.apache.hadoop.mapreduce.v2.app.MRAppMaster
 
createTaskAttemptListener(AppContext, AMPreemptionPolicy) - Method in class org.apache.hadoop.mapreduce.v2.app.MRAppMaster
 
credentials - Variable in class org.apache.hadoop.mapreduce.v2.app.job.impl.TaskImpl
 
currentUser - Variable in class org.apache.hadoop.mapreduce.v2.app.MRAppMaster
 
CustomOutputCommitter - Class in org.apache.hadoop
 
CustomOutputCommitter() - Constructor for class org.apache.hadoop.CustomOutputCommitter
 

D

dataLocalHosts - Variable in class org.apache.hadoop.mapreduce.v2.app.job.impl.TaskAttemptImpl
 
dataLocalRacks - Variable in class org.apache.hadoop.mapreduce.v2.app.job.impl.TaskAttemptImpl
 
DataStatistics - Class in org.apache.hadoop.mapreduce.v2.app.speculate
 
DataStatistics() - Constructor for class org.apache.hadoop.mapreduce.v2.app.speculate.DataStatistics
 
DataStatistics(double) - Constructor for class org.apache.hadoop.mapreduce.v2.app.speculate.DataStatistics
 
decContainerReq(RMContainerRequestor.ContainerRequest) - Method in class org.apache.hadoop.mapreduce.v2.app.rm.RMContainerRequestor
 
DEFAULT_COMPLETED_MAPS_PERCENT_FOR_REDUCE_SLOWSTART - Static variable in class org.apache.hadoop.mapreduce.v2.app.rm.RMContainerAllocator
 
DefaultSpeculator - Class in org.apache.hadoop.mapreduce.v2.app.speculate
 
DefaultSpeculator(Configuration, AppContext) - Constructor for class org.apache.hadoop.mapreduce.v2.app.speculate.DefaultSpeculator
 
DefaultSpeculator(Configuration, AppContext, Clock) - Constructor for class org.apache.hadoop.mapreduce.v2.app.speculate.DefaultSpeculator
 
DefaultSpeculator(Configuration, AppContext, TaskRuntimeEstimator, Clock) - Constructor for class org.apache.hadoop.mapreduce.v2.app.speculate.DefaultSpeculator
 
diagnostics - Variable in class org.apache.hadoop.mapreduce.v2.app.webapp.dao.JobInfo
 
diagnostics - Variable in class org.apache.hadoop.mapreduce.v2.app.webapp.dao.TaskAttemptInfo
 
divideAndCeil(long, long) - Static method in class org.apache.hadoop.mapreduce.v2.app.rm.ResourceCalculatorUtils
 
divideAndCeilContainers(Resource, Resource, EnumSet<YarnServiceProtos.SchedulerResourceTypes>) - Static method in class org.apache.hadoop.mapreduce.v2.app.rm.ResourceCalculatorUtils
 
done(TaskAttemptID) - Method in class org.apache.hadoop.mapred.TaskAttemptListenerImpl
 
doUnregistration() - Method in class org.apache.hadoop.mapreduce.v2.app.rm.RMCommunicator
 
downloadConf() - Method in class org.apache.hadoop.mapreduce.v2.app.webapp.AppController
Handle requests to download the job configuration.

E

elapsedMergeTime - Variable in class org.apache.hadoop.mapreduce.v2.app.webapp.dao.ReduceTaskAttemptInfo
 
elapsedReduceTime - Variable in class org.apache.hadoop.mapreduce.v2.app.webapp.dao.ReduceTaskAttemptInfo
 
elapsedShuffleTime - Variable in class org.apache.hadoop.mapreduce.v2.app.webapp.dao.ReduceTaskAttemptInfo
 
elapsedTime - Variable in class org.apache.hadoop.mapreduce.v2.app.webapp.dao.AppInfo
 
elapsedTime - Variable in class org.apache.hadoop.mapreduce.v2.app.webapp.dao.JobInfo
 
elapsedTime - Variable in class org.apache.hadoop.mapreduce.v2.app.webapp.dao.TaskAttemptInfo
 
elapsedTime - Variable in class org.apache.hadoop.mapreduce.v2.app.webapp.dao.TaskInfo
 
encryptedShuffle - Variable in class org.apache.hadoop.mapreduce.v2.app.job.impl.TaskImpl
 
endPreparingJob(Job) - Method in class org.apache.hadoop.mapreduce.v2.app.metrics.MRAppMetrics
 
endRunningJob(Job) - Method in class org.apache.hadoop.mapreduce.v2.app.metrics.MRAppMetrics
 
endRunningTask(Task) - Method in class org.apache.hadoop.mapreduce.v2.app.metrics.MRAppMetrics
 
endWaitingTask(Task) - Method in class org.apache.hadoop.mapreduce.v2.app.metrics.MRAppMetrics
 
enrollAttempt(TaskAttemptStatusUpdateEvent.TaskAttemptStatus, long) - Method in class org.apache.hadoop.mapreduce.v2.app.speculate.NullTaskRuntimesEngine
 
enrollAttempt(TaskAttemptStatusUpdateEvent.TaskAttemptStatus, long) - Method in interface org.apache.hadoop.mapreduce.v2.app.speculate.TaskRuntimeEstimator
 
equals(Object) - Method in class org.apache.hadoop.mapreduce.v2.app.launcher.ContainerLauncherEvent
 
equals(Object) - Method in class org.apache.hadoop.mapreduce.v2.app.launcher.ContainerRemoteLaunchEvent
 
escapeString(String) - Static method in class org.apache.hadoop.mapreduce.v2.app.job.impl.JobImpl
 
estimatedNewAttemptRuntime(TaskId) - Method in class org.apache.hadoop.mapreduce.v2.app.speculate.NullTaskRuntimesEngine
 
estimatedNewAttemptRuntime(TaskId) - Method in class org.apache.hadoop.mapreduce.v2.app.speculate.SimpleExponentialTaskRuntimeEstimator
 
estimatedNewAttemptRuntime(TaskId) - Method in interface org.apache.hadoop.mapreduce.v2.app.speculate.TaskRuntimeEstimator
Estimates how long a new attempt on this task will take if we start one now
estimatedRuntime(TaskAttemptId) - Method in class org.apache.hadoop.mapreduce.v2.app.speculate.ExponentiallySmoothedTaskRuntimeEstimator
 
estimatedRuntime(TaskAttemptId) - Method in class org.apache.hadoop.mapreduce.v2.app.speculate.LegacyTaskRuntimeEstimator
 
estimatedRuntime(TaskAttemptId) - Method in class org.apache.hadoop.mapreduce.v2.app.speculate.NullTaskRuntimesEngine
 
estimatedRuntime(TaskAttemptId) - Method in class org.apache.hadoop.mapreduce.v2.app.speculate.SimpleExponentialTaskRuntimeEstimator
 
estimatedRuntime(TaskAttemptId) - Method in interface org.apache.hadoop.mapreduce.v2.app.speculate.TaskRuntimeEstimator
Estimate a task attempt's total runtime.
eventHandler - Variable in class org.apache.hadoop.mapreduce.v2.app.job.impl.TaskAttemptImpl
 
eventHandler - Variable in class org.apache.hadoop.mapreduce.v2.app.job.impl.TaskImpl
 
eventHandler - Variable in class org.apache.hadoop.mapreduce.v2.app.rm.RMCommunicator
 
eventHandlingThread - Variable in class org.apache.hadoop.mapreduce.jobhistory.JobHistoryEventHandler
 
eventQueue - Variable in class org.apache.hadoop.mapreduce.jobhistory.JobHistoryEventHandler
 
eventQueue - Variable in class org.apache.hadoop.mapreduce.v2.app.launcher.ContainerLauncherImpl
 
eventQueue - Variable in class org.apache.hadoop.mapreduce.v2.app.rm.RMContainerAllocator
 
eventQueueEmpty() - Method in class org.apache.hadoop.mapreduce.v2.app.speculate.DefaultSpeculator
 
expire(TaskAttemptId) - Method in class org.apache.hadoop.mapreduce.v2.app.TaskAttemptFinishingMonitor
 
ExponentiallySmoothedTaskRuntimeEstimator - Class in org.apache.hadoop.mapreduce.v2.app.speculate
This estimator exponentially smooths the rate of progress versus wallclock time.
ExponentiallySmoothedTaskRuntimeEstimator() - Constructor for class org.apache.hadoop.mapreduce.v2.app.speculate.ExponentiallySmoothedTaskRuntimeEstimator
 
ExponentiallySmoothedTaskRuntimeEstimator.SmoothedValue - Enum in org.apache.hadoop.mapreduce.v2.app.speculate
 
extend(double, int) - Method in class org.apache.hadoop.mapred.WrappedPeriodicStatsAccumulator
 

F

failedJob(Job) - Method in class org.apache.hadoop.mapreduce.v2.app.metrics.MRAppMetrics
 
failedMapAttempts - Variable in class org.apache.hadoop.mapreduce.v2.app.webapp.dao.JobInfo
 
failedReduceAttempts - Variable in class org.apache.hadoop.mapreduce.v2.app.webapp.dao.JobInfo
 
failedTask(Task) - Method in class org.apache.hadoop.mapreduce.v2.app.metrics.MRAppMetrics
 
fatalError(TaskAttemptID, String, boolean) - Method in class org.apache.hadoop.mapred.TaskAttemptListenerImpl
 
fetchFailedMaps - Variable in class org.apache.hadoop.mapreduce.v2.app.job.event.TaskAttemptStatusUpdateEvent.TaskAttemptStatus
 
fileMap - Static variable in class org.apache.hadoop.mapreduce.jobhistory.JobHistoryEventHandler
 
finishTime - Variable in class org.apache.hadoop.mapreduce.v2.app.webapp.dao.JobInfo
 
finishTime - Variable in class org.apache.hadoop.mapreduce.v2.app.webapp.dao.TaskAttemptInfo
 
finishTime - Variable in class org.apache.hadoop.mapreduce.v2.app.webapp.dao.TaskInfo
 
forceJobCompletion - Variable in class org.apache.hadoop.mapreduce.jobhistory.JobHistoryEventHandler
 
forceKillTaskAttempt(KillTaskAttemptRequest) - Method in class org.apache.hadoop.mapreduce.v2.app.client.MRClientService
 
fsError(TaskAttemptID, String) - Method in class org.apache.hadoop.mapred.TaskAttemptListenerImpl
 

G

get() - Method in class org.apache.hadoop.mapreduce.v2.app.webapp.AMWebServices
 
getAcls() - Method in class org.apache.hadoop.mapreduce.v2.app.webapp.dao.JobInfo
 
getAddress() - Method in class org.apache.hadoop.mapred.TaskAttemptListenerImpl
 
getAddress() - Method in interface org.apache.hadoop.mapreduce.v2.app.TaskAttemptListener
 
getAllAMInfos() - Method in class org.apache.hadoop.mapreduce.v2.app.MRAppMaster
 
getAllCounters() - Method in class org.apache.hadoop.mapreduce.v2.app.job.impl.JobImpl
 
getAllCounters() - Method in interface org.apache.hadoop.mapreduce.v2.app.job.Job
Get all the counters of this job.
getAllJobs() - Method in interface org.apache.hadoop.mapreduce.v2.app.AppContext
 
getAllJobs() - Method in class org.apache.hadoop.mapreduce.v2.app.MRAppMaster.RunningAppContext
 
getAllocatedContainer() - Method in class org.apache.hadoop.mapreduce.v2.app.launcher.ContainerRemoteLaunchEvent
 
getAMInfos() - Method in class org.apache.hadoop.mapreduce.v2.app.job.impl.JobImpl
 
getAMInfos() - Method in interface org.apache.hadoop.mapreduce.v2.app.job.Job
 
getAppID() - Method in class org.apache.hadoop.mapreduce.v2.app.MRAppMaster
 
getAppInfo() - Method in class org.apache.hadoop.mapreduce.v2.app.webapp.AMWebServices
 
getApplicationACLs() - Method in class org.apache.hadoop.mapreduce.v2.app.job.event.TaskAttemptContainerAssignedEvent
 
getApplicationAttemptId() - Method in interface org.apache.hadoop.mapreduce.v2.app.AppContext
 
getApplicationAttemptId() - Method in class org.apache.hadoop.mapreduce.v2.app.MRAppMaster.RunningAppContext
 
getApplicationID() - Method in interface org.apache.hadoop.mapreduce.v2.app.AppContext
 
getApplicationID() - Method in class org.apache.hadoop.mapreduce.v2.app.MRAppMaster.RunningAppContext
 
getApplicationName() - Method in interface org.apache.hadoop.mapreduce.v2.app.AppContext
 
getApplicationName() - Method in class org.apache.hadoop.mapreduce.v2.app.MRAppMaster.RunningAppContext
 
getApplicationProgress() - Method in class org.apache.hadoop.mapreduce.v2.app.rm.RMCommunicator
Get the appProgress.
getAssignedContainerID() - Method in class org.apache.hadoop.mapreduce.v2.app.job.impl.TaskAttemptImpl
 
getAssignedContainerID() - Method in interface org.apache.hadoop.mapreduce.v2.app.job.TaskAttempt
 
getAssignedContainerId() - Method in class org.apache.hadoop.mapreduce.v2.app.webapp.dao.TaskAttemptInfo
 
getAssignedContainerIdStr() - Method in class org.apache.hadoop.mapreduce.v2.app.webapp.dao.TaskAttemptInfo
 
getAssignedContainerMgrAddress() - Method in class org.apache.hadoop.mapreduce.v2.app.job.impl.TaskAttemptImpl
 
getAssignedContainerMgrAddress() - Method in interface org.apache.hadoop.mapreduce.v2.app.job.TaskAttempt
 
getAttempt(TaskAttemptId) - Method in class org.apache.hadoop.mapreduce.v2.app.job.impl.TaskImpl
 
getAttempt(TaskAttemptId) - Method in interface org.apache.hadoop.mapreduce.v2.app.job.Task
 
getAttemptContext() - Method in class org.apache.hadoop.mapreduce.v2.app.commit.CommitterTaskAbortEvent
 
getAttemptID() - Method in class org.apache.hadoop.mapreduce.v2.app.commit.CommitterTaskAbortEvent
 
getAttemptID() - Method in class org.apache.hadoop.mapreduce.v2.app.MRAppMaster
 
getAttemptID() - Method in class org.apache.hadoop.mapreduce.v2.app.rm.ContainerAllocatorEvent
 
getAttemptId() - Method in class org.apache.hadoop.mapreduce.v2.app.webapp.dao.AMAttemptInfo
 
getAttempts() - Method in class org.apache.hadoop.mapreduce.v2.app.job.impl.TaskImpl
 
getAttempts() - Method in interface org.apache.hadoop.mapreduce.v2.app.job.Task
 
getAttempts() - Method in class org.apache.hadoop.mapreduce.v2.app.webapp.dao.AMAttemptsInfo
 
getAvailableResources() - Method in class org.apache.hadoop.mapreduce.v2.app.rm.RMContainerRequestor
 
getAvataar() - Method in class org.apache.hadoop.mapreduce.v2.app.job.impl.TaskAttemptImpl
 
getBindAddress() - Method in interface org.apache.hadoop.mapreduce.v2.app.client.ClientService
 
getBindAddress() - Method in class org.apache.hadoop.mapreduce.v2.app.client.MRClientService
 
getBlacklistedNodes() - Method in interface org.apache.hadoop.mapreduce.v2.app.AppContext
 
getBlacklistedNodes() - Method in class org.apache.hadoop.mapreduce.v2.app.MRAppMaster.RunningAppContext
 
getBlacklistedNodes() - Method in class org.apache.hadoop.mapreduce.v2.app.rm.RMContainerRequestor
 
getBlacklistedNodes() - Method in class org.apache.hadoop.mapreduce.v2.app.webapp.AMWebServices
 
getBlacklistedNodes() - Method in class org.apache.hadoop.mapreduce.v2.app.webapp.dao.BlacklistedNodesInfo
 
getCapability() - Method in class org.apache.hadoop.mapreduce.v2.app.rm.ContainerRequestEvent
 
getCheckpointID(TaskID) - Method in class org.apache.hadoop.mapred.TaskAttemptListenerImpl
 
getCheckpointID(TaskId) - Method in interface org.apache.hadoop.mapreduce.v2.app.rm.preemption.AMPreemptionPolicy
Method to retrieve the latest checkpoint for a given TaskId
getCheckpointID(TaskId) - Method in class org.apache.hadoop.mapreduce.v2.app.rm.preemption.CheckpointAMPreemptionPolicy
 
getCheckpointID(TaskId) - Method in class org.apache.hadoop.mapreduce.v2.app.rm.preemption.KillAMPreemptionPolicy
 
getCheckpointID(TaskId) - Method in class org.apache.hadoop.mapreduce.v2.app.rm.preemption.NoopAMPreemptionPolicy
 
getClientService() - Method in class org.apache.hadoop.mapreduce.v2.app.MRAppMaster
 
getClientToAMTokenSecretManager() - Method in interface org.apache.hadoop.mapreduce.v2.app.AppContext
 
getClientToAMTokenSecretManager() - Method in class org.apache.hadoop.mapreduce.v2.app.MRAppMaster.RunningAppContext
 
getClock() - Method in interface org.apache.hadoop.mapreduce.v2.app.AppContext
 
getClock() - Method in class org.apache.hadoop.mapreduce.v2.app.MRAppMaster.RunningAppContext
 
getClusterInfo() - Method in interface org.apache.hadoop.mapreduce.v2.app.AppContext
 
getClusterInfo() - Method in class org.apache.hadoop.mapreduce.v2.app.MRAppMaster.RunningAppContext
 
getCMProxy(String, ContainerId) - Method in class org.apache.hadoop.mapreduce.v2.app.launcher.ContainerLauncherImpl
 
getCommitter() - Method in class org.apache.hadoop.mapreduce.v2.app.job.event.TaskAttemptRecoverEvent
 
getCommitter() - Method in class org.apache.hadoop.mapreduce.v2.app.MRAppMaster
 
getCompletedMaps() - Method in class org.apache.hadoop.mapreduce.v2.app.job.impl.JobImpl
 
getCompletedMaps() - Method in interface org.apache.hadoop.mapreduce.v2.app.job.Job
 
getCompletedReduces() - Method in class org.apache.hadoop.mapreduce.v2.app.job.impl.JobImpl
 
getCompletedReduces() - Method in interface org.apache.hadoop.mapreduce.v2.app.job.Job
 
getCompletedTaskFromPreviousRun() - Method in class org.apache.hadoop.mapreduce.v2.app.MRAppMaster
 
getCompletionEvent() - Method in class org.apache.hadoop.mapreduce.v2.app.job.event.JobTaskAttemptCompletedEvent
 
getConf() - Method in class org.apache.hadoop.mapred.YarnOutputFiles
 
getConf() - Method in class org.apache.hadoop.mapreduce.v2.app.JobEndNotifier
 
getConfFile() - Method in class org.apache.hadoop.mapreduce.v2.app.job.impl.JobImpl
 
getConfFile() - Method in interface org.apache.hadoop.mapreduce.v2.app.job.Job
 
getContainer() - Method in class org.apache.hadoop.mapreduce.v2.app.job.event.TaskAttemptContainerAssignedEvent
 
getContainerAllocator() - Method in class org.apache.hadoop.mapreduce.v2.app.MRAppMaster
 
getContainerID() - Method in class org.apache.hadoop.mapreduce.v2.app.launcher.ContainerLauncherEvent
 
getContainerId() - Method in class org.apache.hadoop.mapreduce.v2.app.webapp.dao.AMAttemptInfo
 
getContainerLaunchContext() - Method in class org.apache.hadoop.mapreduce.v2.app.launcher.ContainerRemoteLaunchEvent
 
getContainerLauncher() - Method in class org.apache.hadoop.mapreduce.v2.app.MRAppMaster
 
getContainerMgrAddress() - Method in class org.apache.hadoop.mapreduce.v2.app.launcher.ContainerLauncherEvent
 
getContainers(TaskType) - Method in class org.apache.hadoop.mapreduce.v2.app.rm.preemption.AMPreemptionPolicy.Context
Method provides the complete list of containers running task of type t for this AM.
getContainerToken() - Method in class org.apache.hadoop.mapreduce.v2.app.launcher.ContainerLauncherEvent
 
getContext() - Method in class org.apache.hadoop.mapreduce.v2.app.MRAppMaster
 
getContext() - Method in class org.apache.hadoop.mapreduce.v2.app.rm.RMCommunicator
 
getContext(Class<?>) - Method in class org.apache.hadoop.mapreduce.v2.app.webapp.JAXBContextResolver
 
getContMgrAddress() - Method in class org.apache.hadoop.mapreduce.v2.app.rm.ContainerFailedEvent
 
getCounterKey() - Method in class org.apache.hadoop.mapreduce.v2.app.job.event.JobCounterUpdateEvent.CounterIncrementalUpdate
 
getCounters() - Method in class org.apache.hadoop.mapreduce.v2.app.job.impl.TaskAttemptImpl
 
getCounters() - Method in class org.apache.hadoop.mapreduce.v2.app.job.impl.TaskImpl
 
getCounters() - Method in interface org.apache.hadoop.mapreduce.v2.app.job.Task
 
getCounters() - Method in interface org.apache.hadoop.mapreduce.v2.app.job.TaskAttempt
 
getCounterUpdates() - Method in class org.apache.hadoop.mapreduce.v2.app.job.event.JobCounterUpdateEvent
 
getCredentials() - Method in class org.apache.hadoop.mapreduce.v2.app.MRAppMaster
 
getDiagnosticInfo() - Method in class org.apache.hadoop.mapreduce.v2.app.job.event.TaskAttemptDiagnosticsUpdateEvent
 
getDiagnostics() - Method in class org.apache.hadoop.mapreduce.v2.app.job.impl.JobImpl
 
getDiagnostics() - Method in class org.apache.hadoop.mapreduce.v2.app.job.impl.TaskAttemptImpl
 
getDiagnostics() - Method in interface org.apache.hadoop.mapreduce.v2.app.job.Job
 
getDiagnostics() - Method in interface org.apache.hadoop.mapreduce.v2.app.job.TaskAttempt
 
getdiagnostics() - Method in class org.apache.hadoop.mapreduce.v2.app.webapp.dao.JobInfo
 
getDiagnosticUpdate() - Method in class org.apache.hadoop.mapreduce.v2.app.job.event.JobDiagnosticsUpdateEvent
 
getDispatcher() - Method in class org.apache.hadoop.mapreduce.v2.app.MRAppMaster
 
getDumpContainerThreads() - Method in class org.apache.hadoop.mapreduce.v2.app.launcher.ContainerLauncherEvent
 
getEarlierAttemptFailed() - Method in class org.apache.hadoop.mapreduce.v2.app.rm.ContainerRequestEvent
 
getElapsedMergeTime() - Method in class org.apache.hadoop.mapreduce.v2.app.webapp.dao.ReduceTaskAttemptInfo
 
getElapsedReduceTime() - Method in class org.apache.hadoop.mapreduce.v2.app.webapp.dao.ReduceTaskAttemptInfo
 
getElapsedShuffleTime() - Method in class org.apache.hadoop.mapreduce.v2.app.webapp.dao.ReduceTaskAttemptInfo
 
getElapsedTime() - Method in class org.apache.hadoop.mapreduce.v2.app.webapp.dao.AppInfo
 
getElapsedTime() - Method in class org.apache.hadoop.mapreduce.v2.app.webapp.dao.JobInfo
 
getElapsedTime() - Method in class org.apache.hadoop.mapreduce.v2.app.webapp.dao.TaskAttemptInfo
 
getElapsedTime() - Method in class org.apache.hadoop.mapreduce.v2.app.webapp.dao.TaskInfo
 
getEventHandler() - Method in interface org.apache.hadoop.mapreduce.v2.app.AppContext
 
getEventHandler() - Method in class org.apache.hadoop.mapreduce.v2.app.MRAppMaster.RunningAppContext
 
getExternalState(TaskAttemptStateInternal) - Static method in class org.apache.hadoop.mapreduce.v2.app.job.impl.TaskAttemptImpl
 
getFailedMapAttempts() - Method in class org.apache.hadoop.mapreduce.v2.app.webapp.dao.JobInfo
 
getFailedMaps() - Method in class org.apache.hadoop.mapreduce.v2.app.job.impl.JobImpl
 
getFailedMaps() - Method in interface org.apache.hadoop.mapreduce.v2.app.job.Job
 
getFailedReduceAttempts() - Method in class org.apache.hadoop.mapreduce.v2.app.webapp.dao.JobInfo
 
getFailedReduces() - Method in class org.apache.hadoop.mapreduce.v2.app.job.impl.JobImpl
 
getFailedReduces() - Method in interface org.apache.hadoop.mapreduce.v2.app.job.Job
 
getFileSystem(Configuration) - Method in class org.apache.hadoop.mapreduce.v2.app.job.impl.JobImpl
Create the default file System for this job.
getFileSystem(Configuration) - Method in class org.apache.hadoop.mapreduce.v2.app.MRAppMaster
Create the default file System for this job.
getFilteredContainerRequest(RMContainerRequestor.ContainerRequest) - Method in class org.apache.hadoop.mapreduce.v2.app.rm.RMContainerRequestor
 
getFinalState() - Method in class org.apache.hadoop.mapreduce.v2.app.commit.CommitterJobAbortEvent
 
getFinalState() - Method in class org.apache.hadoop.mapreduce.v2.app.job.event.JobAbortCompletedEvent
 
getFinishTime() - Method in class org.apache.hadoop.mapreduce.v2.app.job.impl.TaskAttemptImpl
 
getFinishTime() - Method in interface org.apache.hadoop.mapreduce.v2.app.job.TaskAttempt
 
getFinishTime() - Method in class org.apache.hadoop.mapreduce.v2.app.webapp.dao.JobInfo
 
getFinishTime() - Method in class org.apache.hadoop.mapreduce.v2.app.webapp.dao.TaskAttemptInfo
 
getFinishTime() - Method in class org.apache.hadoop.mapreduce.v2.app.webapp.dao.TaskInfo
 
getFirstMapTaskLaunchTime() - Method in class org.apache.hadoop.mapreduce.jobhistory.JobSummary
 
getFirstReduceTaskLaunchTime() - Method in class org.apache.hadoop.mapreduce.jobhistory.JobSummary
 
getForecast() - Method in class org.apache.hadoop.mapreduce.v2.app.speculate.forecast.SimpleExponentialSmoothing
 
getForecastRefEntry() - Method in class org.apache.hadoop.mapreduce.v2.app.speculate.forecast.SimpleExponentialSmoothing
 
getHistoryEvent() - Method in class org.apache.hadoop.mapreduce.jobhistory.JobHistoryEvent
 
getHistoryUrl() - Method in interface org.apache.hadoop.mapreduce.v2.app.AppContext
 
getHistoryUrl() - Method in class org.apache.hadoop.mapreduce.v2.app.MRAppMaster.RunningAppContext
 
getHost() - Method in class org.apache.hadoop.mapreduce.v2.app.job.event.JobTaskAttemptFetchFailureEvent
 
getHosts() - Method in class org.apache.hadoop.mapreduce.v2.app.rm.ContainerRequestEvent
 
getHttpPort() - Method in interface org.apache.hadoop.mapreduce.v2.app.client.ClientService
 
getHttpPort() - Method in class org.apache.hadoop.mapreduce.v2.app.client.MRClientService
 
getID() - Method in class org.apache.hadoop.mapreduce.v2.app.job.impl.JobImpl
 
getID() - Method in class org.apache.hadoop.mapreduce.v2.app.job.impl.TaskAttemptImpl
 
getID() - Method in class org.apache.hadoop.mapreduce.v2.app.job.impl.TaskImpl
 
getID() - Method in interface org.apache.hadoop.mapreduce.v2.app.job.Job
 
getID() - Method in interface org.apache.hadoop.mapreduce.v2.app.job.Task
 
getID() - Method in interface org.apache.hadoop.mapreduce.v2.app.job.TaskAttempt
 
getId() - Method in class org.apache.hadoop.mapreduce.v2.app.webapp.dao.AppInfo
 
getId() - Method in class org.apache.hadoop.mapreduce.v2.app.webapp.dao.JobInfo
 
getId() - Method in class org.apache.hadoop.mapreduce.v2.app.webapp.dao.TaskAttemptInfo
 
getId() - Method in class org.apache.hadoop.mapreduce.v2.app.webapp.dao.TaskInfo
 
getIncrementValue() - Method in class org.apache.hadoop.mapreduce.v2.app.job.event.JobCounterUpdateEvent.CounterIncrementalUpdate
 
getInputFile(int) - Method in class org.apache.hadoop.mapred.YarnOutputFiles
Return a local reduce input file created earlier
getInputFileForWrite(TaskID, long) - Method in class org.apache.hadoop.mapred.YarnOutputFiles
Create a local reduce input file name.
getInternalState() - Method in class org.apache.hadoop.mapreduce.v2.app.job.impl.JobImpl
 
getInternalState() - Method in class org.apache.hadoop.mapreduce.v2.app.job.impl.TaskAttemptImpl
 
getInternalState() - Method in class org.apache.hadoop.mapreduce.v2.app.job.impl.TaskImpl
 
getIsReduceStarted() - Method in class org.apache.hadoop.mapreduce.v2.app.rm.RMContainerAllocator
 
getJob(JobId) - Method in interface org.apache.hadoop.mapreduce.v2.app.AppContext
 
getJob(JobId) - Method in class org.apache.hadoop.mapreduce.v2.app.MRAppMaster.RunningAppContext
 
getJob() - Method in class org.apache.hadoop.mapreduce.v2.app.rm.RMCommunicator
 
getJob(HttpServletRequest, String) - Method in class org.apache.hadoop.mapreduce.v2.app.webapp.AMWebServices
 
getJob() - Method in class org.apache.hadoop.mapreduce.v2.app.webapp.App
 
getJobACLs() - Method in class org.apache.hadoop.mapreduce.v2.app.job.impl.JobImpl
 
getJobACLs() - Method in interface org.apache.hadoop.mapreduce.v2.app.job.Job
 
getJobAttempts(String) - Method in class org.apache.hadoop.mapreduce.v2.app.webapp.AMWebServices
 
getJobConf(HttpServletRequest, String) - Method in class org.apache.hadoop.mapreduce.v2.app.webapp.AMWebServices
 
getJobContext() - Method in class org.apache.hadoop.mapreduce.v2.app.commit.CommitterJobAbortEvent
 
getJobContext() - Method in class org.apache.hadoop.mapreduce.v2.app.commit.CommitterJobCommitEvent
 
getJobContext() - Method in class org.apache.hadoop.mapreduce.v2.app.commit.CommitterJobSetupEvent
 
getJobCounters(HttpServletRequest, String) - Method in class org.apache.hadoop.mapreduce.v2.app.webapp.AMWebServices
 
getJobFinishTime() - Method in class org.apache.hadoop.mapreduce.jobhistory.JobSummary
 
getJobFromJobIdString(String, AppContext) - Static method in class org.apache.hadoop.mapreduce.v2.app.webapp.AMWebServices
convert a job id string to an actual job and handle all the error checking.
getJobID() - Method in class org.apache.hadoop.mapreduce.jobhistory.JobHistoryEvent
 
getJobId() - Method in class org.apache.hadoop.mapreduce.jobhistory.JobSummary
 
getJobID() - Method in class org.apache.hadoop.mapreduce.v2.app.commit.CommitterJobAbortEvent
 
getJobID() - Method in class org.apache.hadoop.mapreduce.v2.app.commit.CommitterJobCommitEvent
 
getJobID() - Method in class org.apache.hadoop.mapreduce.v2.app.commit.CommitterJobSetupEvent
 
getJobId() - Method in class org.apache.hadoop.mapreduce.v2.app.job.event.JobEvent
 
getJobId() - Method in class org.apache.hadoop.mapreduce.v2.app.job.event.JobFinishEvent
 
getJobId() - Method in class org.apache.hadoop.mapreduce.v2.app.MRAppMaster
 
getJobID() - Method in class org.apache.hadoop.mapreduce.v2.app.speculate.SpeculatorEvent
 
getJobLaunchTime() - Method in class org.apache.hadoop.mapreduce.jobhistory.JobSummary
 
getJobName() - Method in class org.apache.hadoop.mapreduce.jobhistory.JobSummary
 
getJobs(HttpServletRequest) - Method in class org.apache.hadoop.mapreduce.v2.app.webapp.AMWebServices
 
getJobs() - Method in class org.apache.hadoop.mapreduce.v2.app.webapp.dao.JobsInfo
 
getJobStatus() - Method in class org.apache.hadoop.mapreduce.jobhistory.JobSummary
 
getJobSubmitTime() - Method in class org.apache.hadoop.mapreduce.jobhistory.JobSummary
 
getJobSummaryString() - Method in class org.apache.hadoop.mapreduce.jobhistory.JobSummary
 
getJobTask(HttpServletRequest, String, String) - Method in class org.apache.hadoop.mapreduce.v2.app.webapp.AMWebServices
 
getJobTaskAttemptId(HttpServletRequest, String, String, String) - Method in class org.apache.hadoop.mapreduce.v2.app.webapp.AMWebServices
 
getJobTaskAttemptIdCounters(HttpServletRequest, String, String, String) - Method in class org.apache.hadoop.mapreduce.v2.app.webapp.AMWebServices
 
getJobTaskAttempts(HttpServletRequest, String, String) - Method in class org.apache.hadoop.mapreduce.v2.app.webapp.AMWebServices
 
getJobTaskAttemptState(HttpServletRequest, String, String, String) - Method in class org.apache.hadoop.mapreduce.v2.app.webapp.AMWebServices
 
getJobTasks(HttpServletRequest, String, String) - Method in class org.apache.hadoop.mapreduce.v2.app.webapp.AMWebServices
 
getKerberosInfo(Class<?>, Configuration) - Method in class org.apache.hadoop.mapreduce.v2.app.MRClientSecurityInfo
 
getKilledMapAttempts() - Method in class org.apache.hadoop.mapreduce.v2.app.webapp.dao.JobInfo
 
getKilledMaps() - Method in class org.apache.hadoop.mapreduce.jobhistory.JobSummary
 
getKilledMaps() - Method in class org.apache.hadoop.mapreduce.v2.app.job.impl.JobImpl
 
getKilledMaps() - Method in interface org.apache.hadoop.mapreduce.v2.app.job.Job
 
getKilledReduceAttempts() - Method in class org.apache.hadoop.mapreduce.v2.app.webapp.dao.JobInfo
 
getKilledReduces() - Method in class org.apache.hadoop.mapreduce.jobhistory.JobSummary
 
getKilledReduces() - Method in class org.apache.hadoop.mapreduce.v2.app.job.impl.JobImpl
 
getKilledReduces() - Method in interface org.apache.hadoop.mapreduce.v2.app.job.Job
 
getLastHeartbeatTime() - Method in class org.apache.hadoop.mapreduce.v2.app.rm.RMCommunicator
 
getLastHeartbeatTime() - Method in interface org.apache.hadoop.mapreduce.v2.app.rm.RMHeartbeatHandler
 
getLaunchTime() - Method in class org.apache.hadoop.mapreduce.v2.app.job.impl.TaskAttemptImpl
 
getLaunchTime() - Method in interface org.apache.hadoop.mapreduce.v2.app.job.TaskAttempt
 
getLocality() - Method in class org.apache.hadoop.mapreduce.v2.app.job.impl.TaskAttemptImpl
 
getLogsLink() - Method in class org.apache.hadoop.mapreduce.v2.app.webapp.dao.AMAttemptInfo
 
getMapAttemptCompletionEvents(int, int) - Method in class org.apache.hadoop.mapreduce.v2.app.job.impl.JobImpl
 
getMapAttemptCompletionEvents(int, int) - Method in interface org.apache.hadoop.mapreduce.v2.app.job.Job
 
getMapCompletionEvents(JobID, int, int, TaskAttemptID) - Method in class org.apache.hadoop.mapred.TaskAttemptListenerImpl
 
getMapProgress() - Method in class org.apache.hadoop.mapreduce.v2.app.webapp.dao.JobInfo
 
getMapProgressPercent() - Method in class org.apache.hadoop.mapreduce.v2.app.webapp.dao.JobInfo
 
getMaps() - Method in class org.apache.hadoop.mapreduce.v2.app.job.event.JobTaskAttemptFetchFailureEvent
 
getMapsCompleted() - Method in class org.apache.hadoop.mapreduce.v2.app.webapp.dao.JobInfo
 
getMapSlotSeconds() - Method in class org.apache.hadoop.mapreduce.jobhistory.JobSummary
 
getMapsPending() - Method in class org.apache.hadoop.mapreduce.v2.app.webapp.dao.JobInfo
 
getMapsRunning() - Method in class org.apache.hadoop.mapreduce.v2.app.webapp.dao.JobInfo
 
getMapsTotal() - Method in class org.apache.hadoop.mapreduce.v2.app.webapp.dao.JobInfo
 
getMaxAllowedFetchFailuresFraction() - Method in class org.apache.hadoop.mapreduce.v2.app.job.impl.JobImpl
 
getMaxAttempts() - Method in class org.apache.hadoop.mapreduce.v2.app.job.impl.MapTaskImpl
 
getMaxAttempts() - Method in class org.apache.hadoop.mapreduce.v2.app.job.impl.ReduceTaskImpl
 
getMaxAttempts() - Method in class org.apache.hadoop.mapreduce.v2.app.job.impl.TaskImpl
 
getMaxContainerCapability() - Method in class org.apache.hadoop.mapreduce.v2.app.ClusterInfo
 
getMaxContainerCapability() - Method in class org.apache.hadoop.mapreduce.v2.app.rm.RMCommunicator
 
getMaxFetchFailuresNotifications() - Method in class org.apache.hadoop.mapreduce.v2.app.job.impl.JobImpl
 
getMergeFinishTime() - Method in class org.apache.hadoop.mapreduce.v2.app.webapp.dao.ReduceTaskAttemptInfo
 
getMessage() - Method in class org.apache.hadoop.mapreduce.v2.app.job.event.JobCommitFailedEvent
 
getMessage() - Method in class org.apache.hadoop.mapreduce.v2.app.job.event.JobSetupFailedEvent
 
getMessage() - Method in class org.apache.hadoop.mapreduce.v2.app.job.event.TaskAttemptKillEvent
 
getMinimumAllowedSpeculativeTasks() - Method in class org.apache.hadoop.mapreduce.v2.app.speculate.DefaultSpeculator
 
getName() - Method in class org.apache.hadoop.mapreduce.v2.app.job.impl.JobImpl
 
getName() - Method in interface org.apache.hadoop.mapreduce.v2.app.job.Job
 
getName() - Method in class org.apache.hadoop.mapreduce.v2.app.webapp.dao.AppInfo
 
getName() - Method in class org.apache.hadoop.mapreduce.v2.app.webapp.dao.ConfEntryInfo
 
getName() - Method in class org.apache.hadoop.mapreduce.v2.app.webapp.dao.JobInfo
 
getName() - Method in class org.apache.hadoop.mapreduce.v2.app.webapp.dao.TaskCounterInfo
 
getNewMapAttempts() - Method in class org.apache.hadoop.mapreduce.v2.app.webapp.dao.JobInfo
 
getNewReduceAttempts() - Method in class org.apache.hadoop.mapreduce.v2.app.webapp.dao.JobInfo
 
getNMHostname() - Method in interface org.apache.hadoop.mapreduce.v2.app.AppContext
 
getNMHostname() - Method in class org.apache.hadoop.mapreduce.v2.app.MRAppMaster.RunningAppContext
 
getNode() - Method in class org.apache.hadoop.mapreduce.v2.app.webapp.dao.TaskAttemptInfo
 
getNodeHttpAddress() - Method in class org.apache.hadoop.mapreduce.v2.app.job.impl.TaskAttemptImpl
If container Assigned then return the node's address, otherwise null.
getNodeHttpAddress() - Method in interface org.apache.hadoop.mapreduce.v2.app.job.TaskAttempt
 
getNodeHttpAddress() - Method in class org.apache.hadoop.mapreduce.v2.app.webapp.dao.AMAttemptInfo
 
getNodeId() - Method in class org.apache.hadoop.mapreduce.v2.app.job.impl.TaskAttemptImpl
 
getNodeId() - Method in interface org.apache.hadoop.mapreduce.v2.app.job.TaskAttempt
 
getNodeId() - Method in class org.apache.hadoop.mapreduce.v2.app.webapp.dao.AMAttemptInfo
 
getNodeRackName() - Method in class org.apache.hadoop.mapreduce.v2.app.job.impl.TaskAttemptImpl
If container Assigned then return the node's rackname, otherwise null.
getNodeRackName() - Method in interface org.apache.hadoop.mapreduce.v2.app.job.TaskAttempt
 
getNote() - Method in class org.apache.hadoop.mapreduce.v2.app.webapp.dao.TaskAttemptInfo
 
getNumFailedMaps() - Method in class org.apache.hadoop.mapreduce.jobhistory.JobSummary
 
getNumFailedReduces() - Method in class org.apache.hadoop.mapreduce.jobhistory.JobSummary
 
getNumSucceededMaps() - Method in class org.apache.hadoop.mapreduce.jobhistory.JobSummary
 
getNumSucceededReduces() - Method in class org.apache.hadoop.mapreduce.jobhistory.JobSummary
 
getOutputCommitter() - Method in class org.apache.hadoop.mapreduce.v2.app.job.event.TaskRecoverEvent
 
getOutputFile() - Method in class org.apache.hadoop.mapred.YarnOutputFiles
Return the path to local map output file created earlier
getOutputFileForWrite(long) - Method in class org.apache.hadoop.mapred.YarnOutputFiles
Create a local map output file name.
getOutputFileForWriteInVolume(Path) - Method in class org.apache.hadoop.mapred.YarnOutputFiles
Create a local map output file name on the same volume.
getOutputIndexFile() - Method in class org.apache.hadoop.mapred.YarnOutputFiles
Return the path to a local map output index file created earlier
getOutputIndexFileForWrite(long) - Method in class org.apache.hadoop.mapred.YarnOutputFiles
Create a local map output index file name.
getOutputIndexFileForWriteInVolume(Path) - Method in class org.apache.hadoop.mapred.YarnOutputFiles
Create a local map output index file name on the same volume.
getPath() - Method in class org.apache.hadoop.mapreduce.v2.app.webapp.dao.ConfInfo
 
getPhase() - Method in class org.apache.hadoop.mapreduce.v2.app.job.impl.TaskAttemptImpl
 
getPhase() - Method in interface org.apache.hadoop.mapreduce.v2.app.job.TaskAttempt
 
getPreviousJobHistoryFileStream(Configuration, ApplicationAttemptId) - Static method in class org.apache.hadoop.mapreduce.jobhistory.JobHistoryCopyService
 
getProgress() - Method in class org.apache.hadoop.mapreduce.v2.app.job.impl.JobImpl
 
getProgress() - Method in class org.apache.hadoop.mapreduce.v2.app.job.impl.TaskAttemptImpl
 
getProgress() - Method in class org.apache.hadoop.mapreduce.v2.app.job.impl.TaskImpl
 
getProgress() - Method in interface org.apache.hadoop.mapreduce.v2.app.job.Job
 
getProgress() - Method in interface org.apache.hadoop.mapreduce.v2.app.job.Task
 
getProgress() - Method in interface org.apache.hadoop.mapreduce.v2.app.job.TaskAttempt
 
getProgress() - Method in class org.apache.hadoop.mapreduce.v2.app.webapp.dao.TaskAttemptInfo
 
getProgress() - Method in class org.apache.hadoop.mapreduce.v2.app.webapp.dao.TaskInfo
 
getProgressCPUTime() - Method in class org.apache.hadoop.mapred.WrappedProgressSplitsBlock
 
getProgressPhysicalMemoryKbytes() - Method in class org.apache.hadoop.mapred.WrappedProgressSplitsBlock
 
getProgressVirtualMemoryKbytes() - Method in class org.apache.hadoop.mapred.WrappedProgressSplitsBlock
 
getProgressWallclockTime() - Method in class org.apache.hadoop.mapred.WrappedProgressSplitsBlock
 
getProperties() - Method in class org.apache.hadoop.mapreduce.v2.app.webapp.dao.ConfInfo
 
getProportionRunningTasksSpeculatable() - Method in class org.apache.hadoop.mapreduce.v2.app.speculate.DefaultSpeculator
 
getProportionTotalTasksSpeculatable() - Method in class org.apache.hadoop.mapreduce.v2.app.speculate.DefaultSpeculator
 
getProtocolSignature(String, long, int) - Method in class org.apache.hadoop.mapred.TaskAttemptListenerImpl
 
getProtocolVersion(String, long) - Method in class org.apache.hadoop.mapred.TaskAttemptListenerImpl
 
getQueue() - Method in class org.apache.hadoop.mapreduce.jobhistory.JobSummary
 
getQueueName() - Method in class org.apache.hadoop.mapreduce.v2.app.job.impl.JobImpl
 
getQueueName() - Method in interface org.apache.hadoop.mapreduce.v2.app.job.Job
 
getQueueName() - Method in class org.apache.hadoop.mapreduce.v2.app.webapp.dao.JobInfo
 
getRack() - Method in class org.apache.hadoop.mapreduce.v2.app.webapp.dao.TaskAttemptInfo
 
getRacks() - Method in class org.apache.hadoop.mapreduce.v2.app.rm.ContainerRequestEvent
 
getRawData() - Method in class org.apache.hadoop.mapreduce.v2.app.speculate.forecast.SimpleExponentialSmoothing
 
getRecoveredJobStartTime() - Method in class org.apache.hadoop.mapreduce.v2.app.job.event.JobStartEvent
 
getRecoverOutput() - Method in class org.apache.hadoop.mapreduce.v2.app.job.event.TaskAttemptRecoverEvent
 
getRecoverTaskOutput() - Method in class org.apache.hadoop.mapreduce.v2.app.job.event.TaskRecoverEvent
 
getReduce() - Method in class org.apache.hadoop.mapreduce.v2.app.job.event.JobTaskAttemptFetchFailureEvent
 
getReduceHost() - Method in class org.apache.hadoop.mapreduce.v2.app.job.event.TaskAttemptTooManyFetchFailureEvent
 
getReduceId() - Method in class org.apache.hadoop.mapreduce.v2.app.job.event.TaskAttemptTooManyFetchFailureEvent
 
getReduceProgress() - Method in class org.apache.hadoop.mapreduce.v2.app.webapp.dao.JobInfo
 
getReduceProgressPercent() - Method in class org.apache.hadoop.mapreduce.v2.app.webapp.dao.JobInfo
 
getReducesCompleted() - Method in class org.apache.hadoop.mapreduce.v2.app.webapp.dao.JobInfo
 
getReduceSlotSeconds() - Method in class org.apache.hadoop.mapreduce.jobhistory.JobSummary
 
getReducesPending() - Method in class org.apache.hadoop.mapreduce.v2.app.webapp.dao.JobInfo
 
getReducesRunning() - Method in class org.apache.hadoop.mapreduce.v2.app.webapp.dao.JobInfo
 
getReducesTotal() - Method in class org.apache.hadoop.mapreduce.v2.app.webapp.dao.JobInfo
 
getRemoteTask() - Method in class org.apache.hadoop.mapreduce.v2.app.launcher.ContainerRemoteLaunchEvent
 
getReport() - Method in class org.apache.hadoop.mapreduce.v2.app.job.impl.JobImpl
 
getReport() - Method in class org.apache.hadoop.mapreduce.v2.app.job.impl.TaskAttemptImpl
 
getReport() - Method in class org.apache.hadoop.mapreduce.v2.app.job.impl.TaskImpl
 
getReport() - Method in interface org.apache.hadoop.mapreduce.v2.app.job.Job
 
getReport() - Method in interface org.apache.hadoop.mapreduce.v2.app.job.Task
 
getReport() - Method in interface org.apache.hadoop.mapreduce.v2.app.job.TaskAttempt
 
getReportedStatus() - Method in class org.apache.hadoop.mapreduce.v2.app.speculate.SpeculatorEvent
 
getRescheduleAttempt() - Method in class org.apache.hadoop.mapreduce.v2.app.job.event.TaskAttemptKillEvent
 
getRescheduleAttempt() - Method in class org.apache.hadoop.mapreduce.v2.app.job.event.TaskTAttemptKilledEvent
 
getResourceLimit() - Method in class org.apache.hadoop.mapreduce.v2.app.rm.RMContainerAllocator
 
getResourcesPerMap() - Method in class org.apache.hadoop.mapreduce.jobhistory.JobSummary
 
getResourcesPerReduce() - Method in class org.apache.hadoop.mapreduce.jobhistory.JobSummary
 
getRMHeartbeatHandler() - Method in class org.apache.hadoop.mapreduce.v2.app.MRAppMaster
 
getRunningMapAttempts() - Method in class org.apache.hadoop.mapreduce.v2.app.webapp.dao.JobInfo
 
getRunningReduceAttempts() - Method in class org.apache.hadoop.mapreduce.v2.app.webapp.dao.JobInfo
 
getSchedulerResourceTypes() - Method in class org.apache.hadoop.mapreduce.v2.app.rm.RMCommunicator
 
getServices() - Method in class org.apache.hadoop.mapreduce.v2.app.security.authorize.ClientHSPolicyProvider
 
getServices() - Method in class org.apache.hadoop.mapreduce.v2.app.security.authorize.MRAMPolicyProvider
 
getShuffleFinishTime() - Method in class org.apache.hadoop.mapreduce.v2.app.job.impl.TaskAttemptImpl
 
getShuffleFinishTime() - Method in interface org.apache.hadoop.mapreduce.v2.app.job.TaskAttempt
 
getShuffleFinishTime() - Method in class org.apache.hadoop.mapreduce.v2.app.webapp.dao.ReduceTaskAttemptInfo
 
getShufflePort() - Method in class org.apache.hadoop.mapreduce.v2.app.job.event.TaskAttemptContainerLaunchedEvent
Get the port that the shuffle handler is listening on.
getShufflePort() - Method in class org.apache.hadoop.mapreduce.v2.app.job.impl.TaskAttemptImpl
 
getShufflePort() - Method in interface org.apache.hadoop.mapreduce.v2.app.job.TaskAttempt
 
getSingleTaskCounters(HttpServletRequest, String, String) - Method in class org.apache.hadoop.mapreduce.v2.app.webapp.AMWebServices
 
getSoonestRetryAfterNoSpeculate() - Method in class org.apache.hadoop.mapreduce.v2.app.speculate.DefaultSpeculator
 
getSoonestRetryAfterSpeculate() - Method in class org.apache.hadoop.mapreduce.v2.app.speculate.DefaultSpeculator
 
getSortFinishTime() - Method in class org.apache.hadoop.mapreduce.v2.app.job.impl.TaskAttemptImpl
 
getSortFinishTime() - Method in interface org.apache.hadoop.mapreduce.v2.app.job.TaskAttempt
 
getSource() - Method in class org.apache.hadoop.mapreduce.v2.app.webapp.dao.ConfEntryInfo
 
getSpillFile(int) - Method in class org.apache.hadoop.mapred.YarnOutputFiles
Return a local map spill file created earlier.
getSpillFileForWrite(int, long) - Method in class org.apache.hadoop.mapred.YarnOutputFiles
Create a local map spill file name.
getSpillIndexFile(int) - Method in class org.apache.hadoop.mapred.YarnOutputFiles
Return a local map spill index file created earlier
getSpillIndexFileForWrite(int, long) - Method in class org.apache.hadoop.mapred.YarnOutputFiles
Create a local map spill index file name.
getSplitsAsString() - Method in class org.apache.hadoop.mapreduce.v2.app.job.impl.MapTaskImpl
 
getSplitsAsString() - Method in class org.apache.hadoop.mapreduce.v2.app.job.impl.TaskImpl
 
getSSE() - Method in class org.apache.hadoop.mapreduce.v2.app.speculate.forecast.SimpleExponentialSmoothing
 
getStartCount() - Method in class org.apache.hadoop.mapreduce.v2.app.MRAppMaster
 
getStartTime() - Method in interface org.apache.hadoop.mapreduce.v2.app.AppContext
 
getStartTime() - Method in class org.apache.hadoop.mapreduce.v2.app.MRAppMaster.RunningAppContext
 
getStartTime() - Method in class org.apache.hadoop.mapreduce.v2.app.speculate.forecast.SimpleExponentialSmoothing
 
getStartTime() - Method in class org.apache.hadoop.mapreduce.v2.app.webapp.dao.AMAttemptInfo
 
getStartTime() - Method in class org.apache.hadoop.mapreduce.v2.app.webapp.dao.AppInfo
 
getStartTime() - Method in class org.apache.hadoop.mapreduce.v2.app.webapp.dao.JobInfo
 
getStartTime() - Method in class org.apache.hadoop.mapreduce.v2.app.webapp.dao.TaskAttemptInfo
 
getStartTime() - Method in class org.apache.hadoop.mapreduce.v2.app.webapp.dao.TaskInfo
 
getState() - Method in class org.apache.hadoop.mapreduce.v2.app.job.event.JobTaskEvent
 
getState() - Method in class org.apache.hadoop.mapreduce.v2.app.job.impl.JobImpl
 
getState() - Method in class org.apache.hadoop.mapreduce.v2.app.job.impl.TaskAttemptImpl
 
getState() - Method in class org.apache.hadoop.mapreduce.v2.app.job.impl.TaskImpl
 
getState() - Method in interface org.apache.hadoop.mapreduce.v2.app.job.Job
 
getState() - Method in interface org.apache.hadoop.mapreduce.v2.app.job.Task
 
getState() - Method in interface org.apache.hadoop.mapreduce.v2.app.job.TaskAttempt
 
getState() - Method in class org.apache.hadoop.mapreduce.v2.app.webapp.dao.JobInfo
 
getState() - Method in class org.apache.hadoop.mapreduce.v2.app.webapp.dao.JobTaskAttemptState
 
getState() - Method in class org.apache.hadoop.mapreduce.v2.app.webapp.dao.TaskAttemptInfo
 
getState() - Method in class org.apache.hadoop.mapreduce.v2.app.webapp.dao.TaskInfo
 
getStateMachine() - Method in class org.apache.hadoop.mapreduce.v2.app.job.impl.JobImpl
 
getStatus() - Method in class org.apache.hadoop.mapreduce.v2.app.webapp.dao.TaskAttemptInfo
 
getStatus() - Method in class org.apache.hadoop.mapreduce.v2.app.webapp.dao.TaskInfo
 
getSuccessful() - Method in class org.apache.hadoop.mapreduce.v2.app.webapp.dao.TaskInfo
 
getSuccessfulAttempt() - Method in class org.apache.hadoop.mapreduce.v2.app.job.impl.TaskImpl
 
getSuccessfulAttempt() - Method in class org.apache.hadoop.mapreduce.v2.app.webapp.dao.TaskInfo
 
getSuccessfulMapAttempts() - Method in class org.apache.hadoop.mapreduce.v2.app.webapp.dao.JobInfo
 
getSuccessfulReduceAttempts() - Method in class org.apache.hadoop.mapreduce.v2.app.webapp.dao.JobInfo
 
getTask(JvmContext) - Method in class org.apache.hadoop.mapred.TaskAttemptListenerImpl
 
getTask(TaskId) - Method in class org.apache.hadoop.mapreduce.v2.app.job.impl.JobImpl
 
getTask(TaskId) - Method in interface org.apache.hadoop.mapreduce.v2.app.job.Job
 
getTask() - Method in class org.apache.hadoop.mapreduce.v2.app.webapp.App
 
getTaskAttempt(ContainerId) - Method in class org.apache.hadoop.mapreduce.v2.app.rm.preemption.AMPreemptionPolicy.Context
 
getTaskAttemptCompletionEvents(int, int) - Method in class org.apache.hadoop.mapreduce.v2.app.job.impl.JobImpl
 
getTaskAttemptCompletionEvents(int, int) - Method in interface org.apache.hadoop.mapreduce.v2.app.job.Job
 
getTaskAttemptFinishingMonitor() - Method in interface org.apache.hadoop.mapreduce.v2.app.AppContext
 
getTaskAttemptFinishingMonitor() - Method in class org.apache.hadoop.mapreduce.v2.app.MRAppMaster.RunningAppContext
 
getTaskAttemptFromTaskAttemptString(String, Task) - Static method in class org.apache.hadoop.mapreduce.v2.app.webapp.AMWebServices
convert a task attempt id string to an actual task attempt and handle all the error checking.
getTaskAttemptID() - Method in class org.apache.hadoop.mapreduce.v2.app.job.event.TaskAttemptEvent
 
getTaskAttemptID() - Method in class org.apache.hadoop.mapreduce.v2.app.job.event.TaskTAttemptEvent
 
getTaskAttemptID() - Method in class org.apache.hadoop.mapreduce.v2.app.launcher.ContainerLauncherEvent
 
getTaskAttemptInfo() - Method in class org.apache.hadoop.mapreduce.v2.app.job.event.TaskAttemptRecoverEvent
 
getTaskAttemptListener() - Method in class org.apache.hadoop.mapreduce.v2.app.MRAppMaster
 
getTaskAttempts() - Method in class org.apache.hadoop.mapreduce.v2.app.webapp.dao.TaskAttemptsInfo
 
getTaskAttemptStatusRef() - Method in class org.apache.hadoop.mapreduce.v2.app.job.event.TaskAttemptStatusUpdateEvent
 
getTaskFromTaskIdString(String, Job) - Static method in class org.apache.hadoop.mapreduce.v2.app.webapp.AMWebServices
convert a task id string to an actual task and handle all the error checking.
getTaskID() - Method in class org.apache.hadoop.mapreduce.v2.app.job.event.JobMapTaskRescheduledEvent
 
getTaskID() - Method in class org.apache.hadoop.mapreduce.v2.app.job.event.JobTaskEvent
 
getTaskID() - Method in class org.apache.hadoop.mapreduce.v2.app.job.event.TaskEvent
 
getTaskID() - Method in class org.apache.hadoop.mapreduce.v2.app.speculate.SpeculatorEvent
 
getTaskInfo() - Method in class org.apache.hadoop.mapreduce.v2.app.job.event.TaskRecoverEvent
 
getTaskNum() - Method in class org.apache.hadoop.mapreduce.v2.app.webapp.dao.TaskInfo
 
getTasks() - Method in class org.apache.hadoop.mapreduce.v2.app.job.impl.JobImpl
 
getTasks(TaskType) - Method in class org.apache.hadoop.mapreduce.v2.app.job.impl.JobImpl
 
getTasks() - Method in interface org.apache.hadoop.mapreduce.v2.app.job.Job
 
getTasks(TaskType) - Method in interface org.apache.hadoop.mapreduce.v2.app.job.Job
 
getTasks() - Method in class org.apache.hadoop.mapreduce.v2.app.webapp.dao.TasksInfo
 
getTaskSplitMetaInfo() - Method in class org.apache.hadoop.mapreduce.v2.app.job.impl.MapTaskImpl
 
getTaskTimeOut() - Method in class org.apache.hadoop.mapreduce.v2.app.TaskHeartbeatHandler
 
getTimelineClient() - Method in class org.apache.hadoop.mapreduce.v2.app.MRAppMaster.RunningAppContext
 
getTimelineV2Client() - Method in class org.apache.hadoop.mapreduce.v2.app.MRAppMaster.RunningAppContext
 
getTimeStamp() - Method in class org.apache.hadoop.mapreduce.v2.app.speculate.forecast.SimpleExponentialSmoothing
 
getTokenInfo(Class<?>, Configuration) - Method in class org.apache.hadoop.mapreduce.v2.app.MRClientSecurityInfo
 
getTotalMaps() - Method in class org.apache.hadoop.mapreduce.v2.app.job.impl.JobImpl
 
getTotalMaps() - Method in interface org.apache.hadoop.mapreduce.v2.app.job.Job
 
getTotalReduces() - Method in class org.apache.hadoop.mapreduce.v2.app.job.impl.JobImpl
 
getTotalReduces() - Method in interface org.apache.hadoop.mapreduce.v2.app.job.Job
 
getType() - Method in class org.apache.hadoop.mapreduce.v2.app.job.impl.MapTaskImpl
 
getType() - Method in class org.apache.hadoop.mapreduce.v2.app.job.impl.ReduceTaskImpl
 
getType() - Method in interface org.apache.hadoop.mapreduce.v2.app.job.Task
 
getType() - Method in class org.apache.hadoop.mapreduce.v2.app.webapp.dao.TaskAttemptInfo
 
getUpdatedNodes() - Method in class org.apache.hadoop.mapreduce.v2.app.job.event.JobUpdatedNodesEvent
 
getUser() - Method in class org.apache.hadoop.mapreduce.jobhistory.JobSummary
 
getUser() - Method in interface org.apache.hadoop.mapreduce.v2.app.AppContext
 
getUser() - Method in class org.apache.hadoop.mapreduce.v2.app.MRAppMaster.RunningAppContext
 
getUser() - Method in class org.apache.hadoop.mapreduce.v2.app.webapp.dao.AppInfo
 
getUserName() - Method in class org.apache.hadoop.mapreduce.v2.app.job.impl.JobImpl
 
getUserName() - Method in interface org.apache.hadoop.mapreduce.v2.app.job.Job
 
getUserName() - Method in class org.apache.hadoop.mapreduce.v2.app.webapp.dao.JobInfo
 
getValue() - Method in class org.apache.hadoop.mapreduce.v2.app.webapp.dao.ConfEntryInfo
 
getValue() - Method in class org.apache.hadoop.mapreduce.v2.app.webapp.dao.TaskCounterInfo
 
getVMCommand(InetSocketAddress, Task, JVMId) - Static method in class org.apache.hadoop.mapred.MapReduceChildJVM
 
getWebApp() - Method in class org.apache.hadoop.mapreduce.v2.app.client.MRClientService
 

H

handle(ContainerLauncherEvent) - Method in class org.apache.hadoop.mapred.LocalContainerLauncher
 
handle(JobHistoryEvent) - Method in class org.apache.hadoop.mapreduce.jobhistory.JobHistoryEventHandler
 
handle(CommitterEvent) - Method in class org.apache.hadoop.mapreduce.v2.app.commit.CommitterEventHandler
 
handle(JobEvent) - Method in class org.apache.hadoop.mapreduce.v2.app.job.impl.JobImpl
 
handle(TaskAttemptEvent) - Method in class org.apache.hadoop.mapreduce.v2.app.job.impl.TaskAttemptImpl
 
handle(TaskEvent) - Method in class org.apache.hadoop.mapreduce.v2.app.job.impl.TaskImpl
 
handle(ContainerLauncherEvent) - Method in class org.apache.hadoop.mapreduce.v2.app.launcher.ContainerLauncherImpl
 
handle(ContainerAllocatorEvent) - Method in class org.apache.hadoop.mapreduce.v2.app.local.LocalContainerAllocator
 
handle(ContainerAllocatorEvent) - Method in class org.apache.hadoop.mapreduce.v2.app.rm.RMContainerAllocator
 
handle(SpeculatorEvent) - Method in class org.apache.hadoop.mapreduce.v2.app.speculate.DefaultSpeculator
 
handleAttempt(TaskAttemptStatusUpdateEvent.TaskAttemptStatus) - Method in class org.apache.hadoop.mapreduce.v2.app.speculate.DefaultSpeculator
 
handleAttempt(TaskAttemptStatusUpdateEvent.TaskAttemptStatus) - Method in interface org.apache.hadoop.mapreduce.v2.app.speculate.Speculator
 
handleCompletedContainer(TaskAttemptId) - Method in interface org.apache.hadoop.mapreduce.v2.app.rm.preemption.AMPreemptionPolicy
Callback informing the policy of containers exiting cleanly.
handleCompletedContainer(TaskAttemptId) - Method in class org.apache.hadoop.mapreduce.v2.app.rm.preemption.CheckpointAMPreemptionPolicy
 
handleCompletedContainer(TaskAttemptId) - Method in class org.apache.hadoop.mapreduce.v2.app.rm.preemption.KillAMPreemptionPolicy
 
handleCompletedContainer(TaskAttemptId) - Method in class org.apache.hadoop.mapreduce.v2.app.rm.preemption.NoopAMPreemptionPolicy
 
handleEvent(HistoryEvent) - Method in class org.apache.hadoop.mapreduce.jobhistory.JobHistoryCopyService
 
handleEvent(JobHistoryEvent) - Method in class org.apache.hadoop.mapreduce.jobhistory.JobHistoryEventHandler
 
handleEvent(ContainerAllocatorEvent) - Method in class org.apache.hadoop.mapreduce.v2.app.rm.RMContainerAllocator
 
handleFailedContainer(TaskAttemptId) - Method in interface org.apache.hadoop.mapreduce.v2.app.rm.preemption.AMPreemptionPolicy
Callback informing the policy of containers exiting with a failure.
handleFailedContainer(TaskAttemptId) - Method in class org.apache.hadoop.mapreduce.v2.app.rm.preemption.CheckpointAMPreemptionPolicy
 
handleFailedContainer(TaskAttemptId) - Method in class org.apache.hadoop.mapreduce.v2.app.rm.preemption.KillAMPreemptionPolicy
 
handleFailedContainer(TaskAttemptId) - Method in class org.apache.hadoop.mapreduce.v2.app.rm.preemption.NoopAMPreemptionPolicy
 
handleTimelineEvent - Variable in class org.apache.hadoop.mapreduce.jobhistory.JobHistoryEventHandler
 
hashCode() - Method in class org.apache.hadoop.mapreduce.v2.app.launcher.ContainerLauncherEvent
 
hashCode() - Method in class org.apache.hadoop.mapreduce.v2.app.launcher.ContainerRemoteLaunchEvent
 
hasRecentlyUnregistered(TaskAttemptId) - Method in class org.apache.hadoop.mapreduce.v2.app.TaskHeartbeatHandler
 
hasStagnatedProgress(TaskAttemptId, long) - Method in class org.apache.hadoop.mapreduce.v2.app.speculate.SimpleExponentialTaskRuntimeEstimator
 
hasStagnatedProgress(TaskAttemptId, long) - Method in interface org.apache.hadoop.mapreduce.v2.app.speculate.TaskRuntimeEstimator
Returns true if the estimator has no updates records for a threshold time window.
hasSuccessfullyUnregistered() - Method in interface org.apache.hadoop.mapreduce.v2.app.AppContext
 
hasSuccessfullyUnregistered() - Method in class org.apache.hadoop.mapreduce.v2.app.MRAppMaster.RunningAppContext
 
heartbeat() - Method in class org.apache.hadoop.mapreduce.v2.app.local.LocalContainerAllocator
 
heartbeat() - Method in class org.apache.hadoop.mapreduce.v2.app.rm.RMCommunicator
 
heartbeat() - Method in class org.apache.hadoop.mapreduce.v2.app.rm.RMContainerAllocator
 

I

id - Variable in class org.apache.hadoop.mapreduce.v2.app.job.event.TaskAttemptStatusUpdateEvent.TaskAttemptStatus
 
id - Variable in class org.apache.hadoop.mapreduce.v2.app.webapp.dao.AMAttemptInfo
 
id - Variable in class org.apache.hadoop.mapreduce.v2.app.webapp.dao.JobCounterInfo
 
id - Variable in class org.apache.hadoop.mapreduce.v2.app.webapp.dao.JobInfo
 
id - Variable in class org.apache.hadoop.mapreduce.v2.app.webapp.dao.JobTaskAttemptCounterInfo
 
id - Variable in class org.apache.hadoop.mapreduce.v2.app.webapp.dao.JobTaskCounterInfo
 
id - Variable in class org.apache.hadoop.mapreduce.v2.app.webapp.dao.TaskAttemptInfo
 
id - Variable in class org.apache.hadoop.mapreduce.v2.app.webapp.dao.TaskInfo
 
incorporateReading(long, double) - Method in class org.apache.hadoop.mapreduce.v2.app.speculate.forecast.SimpleExponentialSmoothing
 
incrTaskCounters(Counters, Collection<Task>) - Static method in class org.apache.hadoop.mapreduce.v2.app.job.impl.JobImpl
 
index() - Method in class org.apache.hadoop.mapreduce.v2.app.webapp.AppController
Render the default(index.html) page for the Application Controller
info() - Method in class org.apache.hadoop.mapreduce.v2.app.webapp.AppController
Render the /info page with an overview of current application.
InfoPage - Class in org.apache.hadoop.mapreduce.v2.app.webapp
 
InfoPage() - Constructor for class org.apache.hadoop.mapreduce.v2.app.webapp.InfoPage
 
init(AppContext) - Method in interface org.apache.hadoop.mapreduce.v2.app.rm.preemption.AMPreemptionPolicy
 
init(AppContext) - Method in class org.apache.hadoop.mapreduce.v2.app.rm.preemption.CheckpointAMPreemptionPolicy
 
init(AppContext) - Method in class org.apache.hadoop.mapreduce.v2.app.rm.preemption.KillAMPreemptionPolicy
 
init(AppContext) - Method in class org.apache.hadoop.mapreduce.v2.app.rm.preemption.NoopAMPreemptionPolicy
 
init(Configuration) - Method in class org.apache.hadoop.mapreduce.v2.app.TaskAttemptFinishingMonitor
 
initAndStartAppMaster(MRAppMaster, JobConf, String) - Static method in class org.apache.hadoop.mapreduce.v2.app.MRAppMaster
 
initialPoolSize - Variable in class org.apache.hadoop.mapreduce.v2.app.launcher.ContainerLauncherImpl
 
initJobCredentialsAndUGI(Configuration) - Method in class org.apache.hadoop.mapreduce.v2.app.MRAppMaster
Obtain the tokens needed by the job and put them in the UGI
InitTransition() - Constructor for class org.apache.hadoop.mapreduce.v2.app.job.impl.JobImpl.InitTransition
 
INTERMEDIATE_DATA_ENCRYPTION_ALGO - Static variable in class org.apache.hadoop.mapreduce.v2.app.MRAppMaster
 
internalError(TaskEventType) - Method in class org.apache.hadoop.mapreduce.v2.app.job.impl.TaskImpl
 
isApplicationMasterRegistered() - Method in class org.apache.hadoop.mapreduce.v2.app.rm.RMCommunicator
 
isDataStagnated(long) - Method in class org.apache.hadoop.mapreduce.v2.app.speculate.forecast.SimpleExponentialSmoothing
checks if the task is hanging up.
isDefaultForecast(double) - Method in class org.apache.hadoop.mapreduce.v2.app.speculate.forecast.SimpleExponentialSmoothing
 
isErrorWithinBound(double) - Method in class org.apache.hadoop.mapreduce.v2.app.speculate.forecast.SimpleExponentialSmoothing
 
isFastFail() - Method in class org.apache.hadoop.mapreduce.v2.app.job.event.TaskAttemptFailEvent
Check if task should fast fail or retry
isFastFail() - Method in class org.apache.hadoop.mapreduce.v2.app.job.event.TaskTAttemptFailedEvent
 
isFinished() - Method in class org.apache.hadoop.mapreduce.v2.app.job.impl.TaskAttemptImpl
 
isFinished() - Method in class org.apache.hadoop.mapreduce.v2.app.job.impl.TaskImpl
 
isFinished() - Method in interface org.apache.hadoop.mapreduce.v2.app.job.Task
Has Task reached the final state or not.
isFinished() - Method in interface org.apache.hadoop.mapreduce.v2.app.job.TaskAttempt
Has attempt reached the final state or not.
isIP(String) - Method in class org.apache.hadoop.mapreduce.v2.app.job.impl.TaskAttemptImpl
 
isLastAMRetry() - Method in interface org.apache.hadoop.mapreduce.v2.app.AppContext
 
isLastAMRetry - Variable in class org.apache.hadoop.mapreduce.v2.app.MRAppMaster
 
isLastAMRetry() - Method in class org.apache.hadoop.mapreduce.v2.app.MRAppMaster
 
isLastAMRetry() - Method in class org.apache.hadoop.mapreduce.v2.app.MRAppMaster.RunningAppContext
 
isNewApiCommitter() - Method in class org.apache.hadoop.mapreduce.v2.app.MRAppMaster
 
isNodeBlacklisted(String) - Method in class org.apache.hadoop.mapreduce.v2.app.rm.RMContainerRequestor
 
isPreempted(TaskAttemptId) - Method in interface org.apache.hadoop.mapreduce.v2.app.rm.preemption.AMPreemptionPolicy
This method is invoked by components interested to learn whether a certain task is being preempted.
isPreempted(TaskAttemptId) - Method in class org.apache.hadoop.mapreduce.v2.app.rm.preemption.CheckpointAMPreemptionPolicy
 
isPreempted(TaskAttemptId) - Method in class org.apache.hadoop.mapreduce.v2.app.rm.preemption.KillAMPreemptionPolicy
 
isPreempted(TaskAttemptId) - Method in class org.apache.hadoop.mapreduce.v2.app.rm.preemption.NoopAMPreemptionPolicy
 
isSignalled - Variable in class org.apache.hadoop.mapreduce.v2.app.rm.RMCommunicator
 
isTaskFailFast() - Method in class org.apache.hadoop.mapreduce.v2.app.job.impl.TaskAttemptImpl
 
isUber() - Method in class org.apache.hadoop.mapreduce.v2.app.job.impl.JobImpl
 
isUber() - Method in interface org.apache.hadoop.mapreduce.v2.app.job.Job
 
isUberized() - Method in class org.apache.hadoop.mapreduce.v2.app.webapp.dao.JobInfo
 

J

JAXBContextResolver - Class in org.apache.hadoop.mapreduce.v2.app.webapp
 
JAXBContextResolver() - Constructor for class org.apache.hadoop.mapreduce.v2.app.webapp.JAXBContextResolver
 
Job - Interface in org.apache.hadoop.mapreduce.v2.app.job
Main interface to interact with the job.
job() - Method in class org.apache.hadoop.mapreduce.v2.app.webapp.AppController
Render the /job page
job - Variable in class org.apache.hadoop.mapreduce.v2.app.webapp.dao.JobsInfo
 
job - Variable in class org.apache.hadoop.mapreduce.v2.app.webapp.SingleCounterBlock
 
JOB_ABORT_FILE_NAME - Static variable in class org.apache.hadoop.CustomOutputCommitter
 
JOB_COMMIT_FILE_NAME - Static variable in class org.apache.hadoop.CustomOutputCommitter
 
JOB_ID - Static variable in interface org.apache.hadoop.mapreduce.v2.app.webapp.AMParams
 
JOB_KILLED_DIAG - Static variable in class org.apache.hadoop.mapreduce.v2.app.job.impl.JobImpl
 
JOB_SETUP_FILE_NAME - Static variable in class org.apache.hadoop.CustomOutputCommitter
 
JobAbortCompletedEvent - Class in org.apache.hadoop.mapreduce.v2.app.job.event
 
JobAbortCompletedEvent(JobId, JobStatus.State) - Constructor for class org.apache.hadoop.mapreduce.v2.app.job.event.JobAbortCompletedEvent
 
JobBlock - Class in org.apache.hadoop.mapreduce.v2.app.webapp
 
JobCommitCompletedEvent - Class in org.apache.hadoop.mapreduce.v2.app.job.event
 
JobCommitCompletedEvent(JobId) - Constructor for class org.apache.hadoop.mapreduce.v2.app.job.event.JobCommitCompletedEvent
 
JobCommitFailedEvent - Class in org.apache.hadoop.mapreduce.v2.app.job.event
 
JobCommitFailedEvent(JobId, String) - Constructor for class org.apache.hadoop.mapreduce.v2.app.job.event.JobCommitFailedEvent
 
JobConfPage - Class in org.apache.hadoop.mapreduce.v2.app.webapp
Render a page with the configuration for a given job in it.
JobConfPage() - Constructor for class org.apache.hadoop.mapreduce.v2.app.webapp.JobConfPage
 
JobCounterInfo - Class in org.apache.hadoop.mapreduce.v2.app.webapp.dao
 
JobCounterInfo() - Constructor for class org.apache.hadoop.mapreduce.v2.app.webapp.dao.JobCounterInfo
 
JobCounterInfo(AppContext, Job) - Constructor for class org.apache.hadoop.mapreduce.v2.app.webapp.dao.JobCounterInfo
 
jobCounters() - Method in class org.apache.hadoop.mapreduce.v2.app.webapp.AppController
Render the /jobcounters page
JobCounterUpdateEvent - Class in org.apache.hadoop.mapreduce.v2.app.job.event
 
JobCounterUpdateEvent(JobId) - Constructor for class org.apache.hadoop.mapreduce.v2.app.job.event.JobCounterUpdateEvent
 
JobCounterUpdateEvent.CounterIncrementalUpdate - Class in org.apache.hadoop.mapreduce.v2.app.job.event
 
JobDiagnosticsUpdateEvent - Class in org.apache.hadoop.mapreduce.v2.app.job.event
 
JobDiagnosticsUpdateEvent(JobId, String) - Constructor for class org.apache.hadoop.mapreduce.v2.app.job.event.JobDiagnosticsUpdateEvent
 
JobEndNotifier - Class in org.apache.hadoop.mapreduce.v2.app
This class handles job end notification.
JobEndNotifier() - Constructor for class org.apache.hadoop.mapreduce.v2.app.JobEndNotifier
 
JobEvent - Class in org.apache.hadoop.mapreduce.v2.app.job.event
This class encapsulates job related events.
JobEvent(JobId, JobEventType) - Constructor for class org.apache.hadoop.mapreduce.v2.app.job.event.JobEvent
 
JobEventType - Enum in org.apache.hadoop.mapreduce.v2.app.job.event
Event types handled by Job.
jobFile - Variable in class org.apache.hadoop.mapreduce.v2.app.job.impl.TaskAttemptImpl
 
jobFile - Variable in class org.apache.hadoop.mapreduce.v2.app.job.impl.TaskImpl
 
JobFinishEvent - Class in org.apache.hadoop.mapreduce.v2.app.job.event
 
JobFinishEvent(JobId) - Constructor for class org.apache.hadoop.mapreduce.v2.app.job.event.JobFinishEvent
 
JobFinishEvent.Type - Enum in org.apache.hadoop.mapreduce.v2.app.job.event
 
JobHistoryCopyService - Class in org.apache.hadoop.mapreduce.jobhistory
Reads in history events from the JobHistoryFile and sends them out again to be recorded.
JobHistoryCopyService(ApplicationAttemptId, EventHandler<Event>) - Constructor for class org.apache.hadoop.mapreduce.jobhistory.JobHistoryCopyService
 
JobHistoryEvent - Class in org.apache.hadoop.mapreduce.jobhistory
 
JobHistoryEvent(JobId, HistoryEvent) - Constructor for class org.apache.hadoop.mapreduce.jobhistory.JobHistoryEvent
 
JobHistoryEvent(JobId, HistoryEvent, long) - Constructor for class org.apache.hadoop.mapreduce.jobhistory.JobHistoryEvent
 
JobHistoryEventHandler - Class in org.apache.hadoop.mapreduce.jobhistory
The job history events get routed to this class.
JobHistoryEventHandler(AppContext, int) - Constructor for class org.apache.hadoop.mapreduce.jobhistory.JobHistoryEventHandler
 
JobHistoryEventHandler.MetaInfo - Class in org.apache.hadoop.mapreduce.jobhistory
 
JobImpl - Class in org.apache.hadoop.mapreduce.v2.app.job.impl
Implementation of Job interface.
JobImpl(JobId, ApplicationAttemptId, Configuration, EventHandler, TaskAttemptListener, JobTokenSecretManager, Credentials, Clock, Map<TaskId, JobHistoryParser.TaskInfo>, MRAppMetrics, OutputCommitter, boolean, String, long, List<AMInfo>, AppContext, JobStateInternal, String) - Constructor for class org.apache.hadoop.mapreduce.v2.app.job.impl.JobImpl
 
JobImpl.InitTransition - Class in org.apache.hadoop.mapreduce.v2.app.job.impl
 
JobImpl.StartTransition - Class in org.apache.hadoop.mapreduce.v2.app.job.impl
 
JobInfo - Class in org.apache.hadoop.mapreduce.v2.app.webapp.dao
 
JobInfo() - Constructor for class org.apache.hadoop.mapreduce.v2.app.webapp.dao.JobInfo
 
JobInfo(Job, Boolean) - Constructor for class org.apache.hadoop.mapreduce.v2.app.webapp.dao.JobInfo
 
JobMapTaskRescheduledEvent - Class in org.apache.hadoop.mapreduce.v2.app.job.event
 
JobMapTaskRescheduledEvent(TaskId) - Constructor for class org.apache.hadoop.mapreduce.v2.app.job.event.JobMapTaskRescheduledEvent
 
jobPage() - Method in class org.apache.hadoop.mapreduce.v2.app.webapp.AppController
 
JobPage - Class in org.apache.hadoop.mapreduce.v2.app.webapp
 
JobPage() - Constructor for class org.apache.hadoop.mapreduce.v2.app.webapp.JobPage
 
JobsBlock - Class in org.apache.hadoop.mapreduce.v2.app.webapp
 
JobSetupCompletedEvent - Class in org.apache.hadoop.mapreduce.v2.app.job.event
 
JobSetupCompletedEvent(JobId) - Constructor for class org.apache.hadoop.mapreduce.v2.app.job.event.JobSetupCompletedEvent
 
JobSetupFailedEvent - Class in org.apache.hadoop.mapreduce.v2.app.job.event
 
JobSetupFailedEvent(JobId, String) - Constructor for class org.apache.hadoop.mapreduce.v2.app.job.event.JobSetupFailedEvent
 
JobsInfo - Class in org.apache.hadoop.mapreduce.v2.app.webapp.dao
 
JobsInfo() - Constructor for class org.apache.hadoop.mapreduce.v2.app.webapp.dao.JobsInfo
 
JobStartEvent - Class in org.apache.hadoop.mapreduce.v2.app.job.event
 
JobStartEvent(JobId) - Constructor for class org.apache.hadoop.mapreduce.v2.app.job.event.JobStartEvent
 
JobStartEvent(JobId, long) - Constructor for class org.apache.hadoop.mapreduce.v2.app.job.event.JobStartEvent
 
JobStateInternal - Enum in org.apache.hadoop.mapreduce.v2.app.job
 
JobSummary - Class in org.apache.hadoop.mapreduce.jobhistory
 
JobTaskAttemptCompletedEvent - Class in org.apache.hadoop.mapreduce.v2.app.job.event
 
JobTaskAttemptCompletedEvent(TaskAttemptCompletionEvent) - Constructor for class org.apache.hadoop.mapreduce.v2.app.job.event.JobTaskAttemptCompletedEvent
 
JobTaskAttemptCounterInfo - Class in org.apache.hadoop.mapreduce.v2.app.webapp.dao
 
JobTaskAttemptCounterInfo() - Constructor for class org.apache.hadoop.mapreduce.v2.app.webapp.dao.JobTaskAttemptCounterInfo
 
JobTaskAttemptCounterInfo(TaskAttempt) - Constructor for class org.apache.hadoop.mapreduce.v2.app.webapp.dao.JobTaskAttemptCounterInfo
 
JobTaskAttemptFetchFailureEvent - Class in org.apache.hadoop.mapreduce.v2.app.job.event
 
JobTaskAttemptFetchFailureEvent(TaskAttemptId, List<TaskAttemptId>, String) - Constructor for class org.apache.hadoop.mapreduce.v2.app.job.event.JobTaskAttemptFetchFailureEvent
 
JobTaskAttemptState - Class in org.apache.hadoop.mapreduce.v2.app.webapp.dao
Job task attempt state.
JobTaskAttemptState() - Constructor for class org.apache.hadoop.mapreduce.v2.app.webapp.dao.JobTaskAttemptState
 
JobTaskAttemptState(String) - Constructor for class org.apache.hadoop.mapreduce.v2.app.webapp.dao.JobTaskAttemptState
 
JobTaskCounterInfo - Class in org.apache.hadoop.mapreduce.v2.app.webapp.dao
 
JobTaskCounterInfo() - Constructor for class org.apache.hadoop.mapreduce.v2.app.webapp.dao.JobTaskCounterInfo
 
JobTaskCounterInfo(Task) - Constructor for class org.apache.hadoop.mapreduce.v2.app.webapp.dao.JobTaskCounterInfo
 
JobTaskEvent - Class in org.apache.hadoop.mapreduce.v2.app.job.event
 
JobTaskEvent(TaskId, TaskState) - Constructor for class org.apache.hadoop.mapreduce.v2.app.job.event.JobTaskEvent
 
jobToken - Variable in class org.apache.hadoop.mapreduce.v2.app.job.impl.TaskImpl
 
jobTokenSecretManager - Variable in class org.apache.hadoop.mapreduce.v2.app.MRAppMaster
 
JobUpdatedNodesEvent - Class in org.apache.hadoop.mapreduce.v2.app.job.event
 
JobUpdatedNodesEvent(JobId, List<NodeReport>) - Constructor for class org.apache.hadoop.mapreduce.v2.app.job.event.JobUpdatedNodesEvent
 

K

keepJobFiles(JobConf, String) - Method in class org.apache.hadoop.mapreduce.v2.app.MRAppMaster
 
KillAMPreemptionPolicy - Class in org.apache.hadoop.mapreduce.v2.app.rm.preemption
Sample policy that aggressively kills tasks when requested.
KillAMPreemptionPolicy() - Constructor for class org.apache.hadoop.mapreduce.v2.app.rm.preemption.KillAMPreemptionPolicy
 
killedJob(Job) - Method in class org.apache.hadoop.mapreduce.v2.app.metrics.MRAppMetrics
 
killedMapAttempts - Variable in class org.apache.hadoop.mapreduce.v2.app.webapp.dao.JobInfo
 
killedReduceAttempts - Variable in class org.apache.hadoop.mapreduce.v2.app.webapp.dao.JobInfo
 
killedTask(Task) - Method in class org.apache.hadoop.mapreduce.v2.app.metrics.MRAppMetrics
 
killJobTaskAttempt(TaskAttempt, UserGroupInformation, HttpServletRequest) - Method in class org.apache.hadoop.mapreduce.v2.app.webapp.AMWebServices
 

L

lastResponseID - Variable in class org.apache.hadoop.mapreduce.v2.app.local.LocalContainerAllocator
 
lastResponseID - Variable in class org.apache.hadoop.mapreduce.v2.app.rm.RMContainerRequestor
 
launchedTask(Task) - Method in class org.apache.hadoop.mapreduce.v2.app.metrics.MRAppMetrics
 
launcherPool - Variable in class org.apache.hadoop.mapreduce.v2.app.launcher.ContainerLauncherImpl
 
LegacyTaskRuntimeEstimator - Class in org.apache.hadoop.mapreduce.v2.app.speculate
 
LegacyTaskRuntimeEstimator() - Constructor for class org.apache.hadoop.mapreduce.v2.app.speculate.LegacyTaskRuntimeEstimator
 
loadConfFile() - Method in class org.apache.hadoop.mapreduce.v2.app.job.impl.JobImpl
 
loadConfFile() - Method in interface org.apache.hadoop.mapreduce.v2.app.job.Job
 
LocalContainerAllocator - Class in org.apache.hadoop.mapreduce.v2.app.local
Allocates containers locally.
LocalContainerAllocator(ClientService, AppContext, String, int, int, ContainerId) - Constructor for class org.apache.hadoop.mapreduce.v2.app.local.LocalContainerAllocator
 
LocalContainerLauncher - Class in org.apache.hadoop.mapred
Runs the container task locally in a thread.
LocalContainerLauncher(AppContext, TaskUmbilicalProtocol) - Constructor for class org.apache.hadoop.mapred.LocalContainerLauncher
 
LocalContainerLauncher(AppContext, TaskUmbilicalProtocol, ClassLoader) - Constructor for class org.apache.hadoop.mapred.LocalContainerLauncher
 
logsLink - Variable in class org.apache.hadoop.mapreduce.v2.app.webapp.dao.AMAttemptInfo
 

M

main(String[]) - Static method in class org.apache.hadoop.mapreduce.v2.app.MRAppMaster
 
makeRemoteRequest() - Method in class org.apache.hadoop.mapreduce.v2.app.rm.RMContainerRequestor
 
map - Variable in class org.apache.hadoop.mapreduce.v2.app.webapp.dao.JobCounterInfo
 
mapCounterValue - Variable in class org.apache.hadoop.mapreduce.v2.app.webapp.dao.CounterInfo
 
mapFinishTime - Variable in class org.apache.hadoop.mapreduce.v2.app.job.event.TaskAttemptStatusUpdateEvent.TaskAttemptStatus
 
mapProgress - Variable in class org.apache.hadoop.mapreduce.v2.app.webapp.dao.JobInfo
 
mapProgressPercent - Variable in class org.apache.hadoop.mapreduce.v2.app.webapp.dao.JobInfo
 
MapReduceChildJVM - Class in org.apache.hadoop.mapred
 
MapReduceChildJVM() - Constructor for class org.apache.hadoop.mapred.MapReduceChildJVM
 
mapsCompleted - Variable in class org.apache.hadoop.mapreduce.v2.app.webapp.dao.JobInfo
 
mapsPending - Variable in class org.apache.hadoop.mapreduce.v2.app.webapp.dao.JobInfo
 
mapsRunning - Variable in class org.apache.hadoop.mapreduce.v2.app.webapp.dao.JobInfo
 
mapsTotal - Variable in class org.apache.hadoop.mapreduce.v2.app.webapp.dao.JobInfo
 
MapTaskAttemptImpl - Class in org.apache.hadoop.mapred
 
MapTaskAttemptImpl(TaskId, int, EventHandler, Path, int, JobSplit.TaskSplitMetaInfo, JobConf, TaskAttemptListener, Token<JobTokenIdentifier>, Credentials, Clock, AppContext) - Constructor for class org.apache.hadoop.mapred.MapTaskAttemptImpl
 
MapTaskAttemptInfo - Class in org.apache.hadoop.mapreduce.v2.app.webapp.dao
 
MapTaskAttemptInfo() - Constructor for class org.apache.hadoop.mapreduce.v2.app.webapp.dao.MapTaskAttemptInfo
 
MapTaskAttemptInfo(TaskAttempt) - Constructor for class org.apache.hadoop.mapreduce.v2.app.webapp.dao.MapTaskAttemptInfo
 
MapTaskAttemptInfo(TaskAttempt, Boolean) - Constructor for class org.apache.hadoop.mapreduce.v2.app.webapp.dao.MapTaskAttemptInfo
 
MapTaskImpl - Class in org.apache.hadoop.mapreduce.v2.app.job.impl
 
MapTaskImpl(JobId, int, EventHandler, Path, JobConf, JobSplit.TaskSplitMetaInfo, TaskAttemptListener, Token<JobTokenIdentifier>, Credentials, Clock, int, MRAppMetrics, AppContext) - Constructor for class org.apache.hadoop.mapreduce.v2.app.job.impl.MapTaskImpl
 
markSuccessfulUnregistration() - Method in class org.apache.hadoop.mapreduce.v2.app.MRAppMaster.RunningAppContext
 
mean() - Method in class org.apache.hadoop.mapreduce.v2.app.speculate.DataStatistics
 
meanCI() - Method in class org.apache.hadoop.mapreduce.v2.app.speculate.DataStatistics
calculates the mean value within 95% ConfidenceInterval.
mergeFinishTime - Variable in class org.apache.hadoop.mapreduce.v2.app.webapp.dao.ReduceTaskAttemptInfo
 
metrics - Variable in class org.apache.hadoop.mapreduce.v2.app.MRAppMaster
 
moveTmpToDone(Path) - Method in class org.apache.hadoop.mapreduce.jobhistory.JobHistoryEventHandler
 
moveToDoneNow(Path, Path) - Method in class org.apache.hadoop.mapreduce.jobhistory.JobHistoryEventHandler
 
MRAMPolicyProvider - Class in org.apache.hadoop.mapreduce.v2.app.security.authorize
PolicyProvider for YARN MapReduce protocols.
MRAMPolicyProvider() - Constructor for class org.apache.hadoop.mapreduce.v2.app.security.authorize.MRAMPolicyProvider
 
MRAppMaster - Class in org.apache.hadoop.mapreduce.v2.app
The Map-Reduce Application Master.
MRAppMaster(ApplicationAttemptId, ContainerId, String, int, int, long) - Constructor for class org.apache.hadoop.mapreduce.v2.app.MRAppMaster
 
MRAppMaster(ApplicationAttemptId, ContainerId, String, int, int, Clock, long) - Constructor for class org.apache.hadoop.mapreduce.v2.app.MRAppMaster
 
MRAppMaster.RunningAppContext - Class in org.apache.hadoop.mapreduce.v2.app
 
MRAppMetrics - Class in org.apache.hadoop.mapreduce.v2.app.metrics
 
MRAppMetrics() - Constructor for class org.apache.hadoop.mapreduce.v2.app.metrics.MRAppMetrics
 
MRClientSecurityInfo - Class in org.apache.hadoop.mapreduce.v2.app
 
MRClientSecurityInfo() - Constructor for class org.apache.hadoop.mapreduce.v2.app.MRClientSecurityInfo
 
MRClientService - Class in org.apache.hadoop.mapreduce.v2.app.client
This module is responsible for talking to the jobclient (user facing).
MRClientService(AppContext) - Constructor for class org.apache.hadoop.mapreduce.v2.app.client.MRClientService
 

N

name - Variable in class org.apache.hadoop.mapreduce.v2.app.webapp.dao.AppInfo
 
name - Variable in class org.apache.hadoop.mapreduce.v2.app.webapp.dao.ConfEntryInfo
 
name - Variable in class org.apache.hadoop.mapreduce.v2.app.webapp.dao.CounterInfo
 
name - Variable in class org.apache.hadoop.mapreduce.v2.app.webapp.dao.JobInfo
 
name - Variable in class org.apache.hadoop.mapreduce.v2.app.webapp.dao.TaskCounterInfo
 
nav() - Method in class org.apache.hadoop.mapreduce.v2.app.webapp.AppView
 
NavBlock - Class in org.apache.hadoop.mapreduce.v2.app.webapp
 
needsTaskCommit(TaskAttemptContext) - Method in class org.apache.hadoop.CustomOutputCommitter
 
newMapAttempts - Variable in class org.apache.hadoop.mapreduce.v2.app.webapp.dao.JobInfo
 
newReduceAttempts - Variable in class org.apache.hadoop.mapreduce.v2.app.webapp.dao.JobInfo
 
nextAttemptNumber - Variable in class org.apache.hadoop.mapreduce.v2.app.job.impl.TaskImpl
 
nodeHttpAddress - Variable in class org.apache.hadoop.mapreduce.v2.app.webapp.dao.AMAttemptInfo
 
nodeHttpAddress - Variable in class org.apache.hadoop.mapreduce.v2.app.webapp.dao.TaskAttemptInfo
 
nodeId - Variable in class org.apache.hadoop.mapreduce.v2.app.webapp.dao.AMAttemptInfo
 
NoopAMPreemptionPolicy - Class in org.apache.hadoop.mapreduce.v2.app.rm.preemption
NoOp policy that ignores all the requests for preemption.
NoopAMPreemptionPolicy() - Constructor for class org.apache.hadoop.mapreduce.v2.app.rm.preemption.NoopAMPreemptionPolicy
 
notify(JobReport) - Method in class org.apache.hadoop.mapreduce.v2.app.JobEndNotifier
Notify a server of the completion of a submitted job.
notifyIsLastAMRetry(boolean) - Method in class org.apache.hadoop.mapreduce.v2.app.MRAppMaster
 
notifyURLOnce() - Method in class org.apache.hadoop.mapreduce.v2.app.JobEndNotifier
Notify the URL just once.
NullTaskRuntimesEngine - Class in org.apache.hadoop.mapreduce.v2.app.speculate
 
NullTaskRuntimesEngine() - Constructor for class org.apache.hadoop.mapreduce.v2.app.speculate.NullTaskRuntimesEngine
 
numTries - Variable in class org.apache.hadoop.mapreduce.v2.app.JobEndNotifier
 

O

org.apache.hadoop - package org.apache.hadoop
 
org.apache.hadoop.mapred - package org.apache.hadoop.mapred
 
org.apache.hadoop.mapreduce.jobhistory - package org.apache.hadoop.mapreduce.jobhistory
 
org.apache.hadoop.mapreduce.v2.app - package org.apache.hadoop.mapreduce.v2.app
 
org.apache.hadoop.mapreduce.v2.app.client - package org.apache.hadoop.mapreduce.v2.app.client
 
org.apache.hadoop.mapreduce.v2.app.commit - package org.apache.hadoop.mapreduce.v2.app.commit
 
org.apache.hadoop.mapreduce.v2.app.job - package org.apache.hadoop.mapreduce.v2.app.job
 
org.apache.hadoop.mapreduce.v2.app.job.event - package org.apache.hadoop.mapreduce.v2.app.job.event
 
org.apache.hadoop.mapreduce.v2.app.job.impl - package org.apache.hadoop.mapreduce.v2.app.job.impl
 
org.apache.hadoop.mapreduce.v2.app.launcher - package org.apache.hadoop.mapreduce.v2.app.launcher
 
org.apache.hadoop.mapreduce.v2.app.local - package org.apache.hadoop.mapreduce.v2.app.local
 
org.apache.hadoop.mapreduce.v2.app.metrics - package org.apache.hadoop.mapreduce.v2.app.metrics
 
org.apache.hadoop.mapreduce.v2.app.rm - package org.apache.hadoop.mapreduce.v2.app.rm
 
org.apache.hadoop.mapreduce.v2.app.rm.preemption - package org.apache.hadoop.mapreduce.v2.app.rm.preemption
 
org.apache.hadoop.mapreduce.v2.app.security.authorize - package org.apache.hadoop.mapreduce.v2.app.security.authorize
 
org.apache.hadoop.mapreduce.v2.app.speculate - package org.apache.hadoop.mapreduce.v2.app.speculate
 
org.apache.hadoop.mapreduce.v2.app.speculate.forecast - package org.apache.hadoop.mapreduce.v2.app.speculate.forecast
 
org.apache.hadoop.mapreduce.v2.app.webapp - package org.apache.hadoop.mapreduce.v2.app.webapp
 
org.apache.hadoop.mapreduce.v2.app.webapp.dao - package org.apache.hadoop.mapreduce.v2.app.webapp.dao
 
outlier(float) - Method in class org.apache.hadoop.mapreduce.v2.app.speculate.DataStatistics
 

P

partition - Variable in class org.apache.hadoop.mapreduce.v2.app.job.impl.TaskAttemptImpl
 
partition - Variable in class org.apache.hadoop.mapreduce.v2.app.job.impl.TaskImpl
 
path - Variable in class org.apache.hadoop.mapreduce.v2.app.webapp.dao.ConfInfo
 
pendingRelease - Variable in class org.apache.hadoop.mapreduce.v2.app.rm.RMContainerRequestor
 
phase - Variable in class org.apache.hadoop.mapreduce.v2.app.job.event.TaskAttemptStatusUpdateEvent.TaskAttemptStatus
 
postHead(Hamlet.HTML<HtmlPage.__>) - Method in class org.apache.hadoop.mapreduce.v2.app.webapp.CountersPage
 
preempt(AMPreemptionPolicy.Context, PreemptionMessage) - Method in interface org.apache.hadoop.mapreduce.v2.app.rm.preemption.AMPreemptionPolicy
Callback informing the policy of ResourceManager.
preempt(AMPreemptionPolicy.Context, PreemptionMessage) - Method in class org.apache.hadoop.mapreduce.v2.app.rm.preemption.CheckpointAMPreemptionPolicy
 
preempt(AMPreemptionPolicy.Context, PreemptionMessage) - Method in class org.apache.hadoop.mapreduce.v2.app.rm.preemption.KillAMPreemptionPolicy
 
preempt(AMPreemptionPolicy.Context, PreemptionMessage) - Method in class org.apache.hadoop.mapreduce.v2.app.rm.preemption.NoopAMPreemptionPolicy
 
preempted(TaskAttemptID, TaskStatus) - Method in class org.apache.hadoop.mapred.TaskAttemptListenerImpl
 
preHead(Hamlet.HTML<HtmlPage.__>) - Method in class org.apache.hadoop.mapreduce.v2.app.webapp.AppView
 
preHead(Hamlet.HTML<HtmlPage.__>) - Method in class org.apache.hadoop.mapreduce.v2.app.webapp.CountersPage
 
preHead(Hamlet.HTML<HtmlPage.__>) - Method in class org.apache.hadoop.mapreduce.v2.app.webapp.InfoPage
 
preHead(Hamlet.HTML<HtmlPage.__>) - Method in class org.apache.hadoop.mapreduce.v2.app.webapp.JobConfPage
 
preHead(Hamlet.HTML<HtmlPage.__>) - Method in class org.apache.hadoop.mapreduce.v2.app.webapp.JobPage
 
preHead(Hamlet.HTML<HtmlPage.__>) - Method in class org.apache.hadoop.mapreduce.v2.app.webapp.SingleCounterPage
 
preHead(Hamlet.HTML<HtmlPage.__>) - Method in class org.apache.hadoop.mapreduce.v2.app.webapp.TaskPage
 
preHead(Hamlet.HTML<HtmlPage.__>) - Method in class org.apache.hadoop.mapreduce.v2.app.webapp.TasksPage
 
preparingJob(Job) - Method in class org.apache.hadoop.mapreduce.v2.app.metrics.MRAppMetrics
 
processDoneFiles(JobId) - Method in class org.apache.hadoop.mapreduce.jobhistory.JobHistoryEventHandler
 
processEventForJobSummary(HistoryEvent, JobSummary, JobId) - Method in class org.apache.hadoop.mapreduce.jobhistory.JobHistoryEventHandler
 
progress - Variable in class org.apache.hadoop.mapreduce.v2.app.job.event.TaskAttemptStatusUpdateEvent.TaskAttemptStatus
 
progress - Variable in class org.apache.hadoop.mapreduce.v2.app.webapp.dao.TaskAttemptInfo
 
progress - Variable in class org.apache.hadoop.mapreduce.v2.app.webapp.dao.TaskInfo
 
progressing(TaskAttemptId) - Method in class org.apache.hadoop.mapreduce.v2.app.TaskHeartbeatHandler
 
property - Variable in class org.apache.hadoop.mapreduce.v2.app.webapp.dao.ConfInfo
 
proxyConf - Variable in class org.apache.hadoop.mapreduce.v2.app.JobEndNotifier
 
proxyToUse - Variable in class org.apache.hadoop.mapreduce.v2.app.JobEndNotifier
 

Q

queue - Variable in class org.apache.hadoop.mapreduce.v2.app.webapp.dao.JobInfo
 

R

rack - Variable in class org.apache.hadoop.mapreduce.v2.app.webapp.dao.TaskAttemptInfo
 
RAMPDOWN_DIAGNOSTIC - Static variable in class org.apache.hadoop.mapreduce.v2.app.rm.RMContainerAllocator
 
rampDownReduces(int) - Method in class org.apache.hadoop.mapreduce.v2.app.rm.RMContainerAllocator
 
rampUpReduces(int) - Method in class org.apache.hadoop.mapreduce.v2.app.rm.RMContainerAllocator
 
recover(JobHistoryParser.TaskAttemptInfo, OutputCommitter, boolean) - Method in class org.apache.hadoop.mapreduce.v2.app.job.impl.TaskAttemptImpl
 
recovered() - Method in class org.apache.hadoop.mapreduce.v2.app.MRAppMaster
 
reduce - Variable in class org.apache.hadoop.mapreduce.v2.app.webapp.dao.JobCounterInfo
 
reduceCounterValue - Variable in class org.apache.hadoop.mapreduce.v2.app.webapp.dao.CounterInfo
 
reduceProgress - Variable in class org.apache.hadoop.mapreduce.v2.app.webapp.dao.JobInfo
 
reduceProgressPercent - Variable in class org.apache.hadoop.mapreduce.v2.app.webapp.dao.JobInfo
 
reducesCompleted - Variable in class org.apache.hadoop.mapreduce.v2.app.webapp.dao.JobInfo
 
reducesPending - Variable in class org.apache.hadoop.mapreduce.v2.app.webapp.dao.JobInfo
 
reducesRunning - Variable in class org.apache.hadoop.mapreduce.v2.app.webapp.dao.JobInfo
 
reducesTotal - Variable in class org.apache.hadoop.mapreduce.v2.app.webapp.dao.JobInfo
 
ReduceTaskAttemptImpl - Class in org.apache.hadoop.mapred
 
ReduceTaskAttemptImpl(TaskId, int, EventHandler, Path, int, int, JobConf, TaskAttemptListener, Token<JobTokenIdentifier>, Credentials, Clock, AppContext) - Constructor for class org.apache.hadoop.mapred.ReduceTaskAttemptImpl
 
ReduceTaskAttemptInfo - Class in org.apache.hadoop.mapreduce.v2.app.webapp.dao
 
ReduceTaskAttemptInfo() - Constructor for class org.apache.hadoop.mapreduce.v2.app.webapp.dao.ReduceTaskAttemptInfo
 
ReduceTaskAttemptInfo(TaskAttempt) - Constructor for class org.apache.hadoop.mapreduce.v2.app.webapp.dao.ReduceTaskAttemptInfo
 
ReduceTaskAttemptInfo(TaskAttempt, Boolean) - Constructor for class org.apache.hadoop.mapreduce.v2.app.webapp.dao.ReduceTaskAttemptInfo
 
ReduceTaskImpl - Class in org.apache.hadoop.mapreduce.v2.app.job.impl
 
ReduceTaskImpl(JobId, int, EventHandler, Path, JobConf, int, TaskAttemptListener, Token<JobTokenIdentifier>, Credentials, Clock, int, MRAppMetrics, AppContext) - Constructor for class org.apache.hadoop.mapreduce.v2.app.job.impl.ReduceTaskImpl
 
register() - Method in class org.apache.hadoop.mapreduce.v2.app.rm.RMCommunicator
 
register(TaskAttemptId) - Method in class org.apache.hadoop.mapreduce.v2.app.TaskHeartbeatHandler
 
registerHeartbeatHandler(Configuration) - Method in class org.apache.hadoop.mapred.TaskAttemptListenerImpl
 
registerLaunchedTask(TaskAttemptId, WrappedJvmID) - Method in class org.apache.hadoop.mapred.TaskAttemptListenerImpl
 
registerLaunchedTask(TaskAttemptId, WrappedJvmID) - Method in interface org.apache.hadoop.mapreduce.v2.app.TaskAttemptListener
Register task attempt.
registerPendingTask(Task, WrappedJvmID) - Method in class org.apache.hadoop.mapred.TaskAttemptListenerImpl
 
registerPendingTask(Task, WrappedJvmID) - Method in interface org.apache.hadoop.mapreduce.v2.app.TaskAttemptListener
Register a JVM with the listener.
release(ContainerId) - Method in class org.apache.hadoop.mapreduce.v2.app.rm.RMContainerRequestor
 
remoteJobConfFile - Variable in class org.apache.hadoop.mapreduce.v2.app.job.impl.JobImpl
 
removeAll() - Method in class org.apache.hadoop.mapred.YarnOutputFiles
Removes all of the files related to a task.
renameMapOutputForReduce(JobConf, TaskAttemptId, MapOutputFile) - Static method in class org.apache.hadoop.mapred.LocalContainerLauncher
Within the _local_ filesystem (not HDFS), all activity takes place within a subdir inside one of the LOCAL_DIRS (${local.dir}/usercache/$user/appcache/$appId/$contId/), and all sub-MapTasks create the same filename ("file.out").
render(HtmlBlock.Block) - Method in class org.apache.hadoop.mapreduce.v2.app.webapp.ConfBlock
 
render(HtmlBlock.Block) - Method in class org.apache.hadoop.mapreduce.v2.app.webapp.CountersBlock
 
render(HtmlBlock.Block) - Method in class org.apache.hadoop.mapreduce.v2.app.webapp.JobBlock
 
render(HtmlBlock.Block) - Method in class org.apache.hadoop.mapreduce.v2.app.webapp.JobsBlock
 
render(HtmlBlock.Block) - Method in class org.apache.hadoop.mapreduce.v2.app.webapp.NavBlock
 
render(HtmlBlock.Block) - Method in class org.apache.hadoop.mapreduce.v2.app.webapp.SingleCounterBlock
 
render(HtmlBlock.Block) - Method in class org.apache.hadoop.mapreduce.v2.app.webapp.TasksBlock
 
reportDiagnosticInfo(TaskAttemptID, String) - Method in class org.apache.hadoop.mapred.TaskAttemptListenerImpl
 
reportNextRecordRange(TaskAttemptID, SortedRanges.Range) - Method in class org.apache.hadoop.mapred.TaskAttemptListenerImpl
 
reportSuccessfulPreemption(TaskAttemptId) - Method in interface org.apache.hadoop.mapreduce.v2.app.rm.preemption.AMPreemptionPolicy
This method is used to report to the policy that a certain task has been successfully preempted (for bookeeping, counters, etc..)
reportSuccessfulPreemption(TaskAttemptId) - Method in class org.apache.hadoop.mapreduce.v2.app.rm.preemption.CheckpointAMPreemptionPolicy
 
reportSuccessfulPreemption(TaskAttemptId) - Method in class org.apache.hadoop.mapreduce.v2.app.rm.preemption.KillAMPreemptionPolicy
 
reportSuccessfulPreemption(TaskAttemptId) - Method in class org.apache.hadoop.mapreduce.v2.app.rm.preemption.NoopAMPreemptionPolicy
 
requireJob() - Method in class org.apache.hadoop.mapreduce.v2.app.webapp.AppController
Ensure that a JOB_ID was passed into the page.
requireTask() - Method in class org.apache.hadoop.mapreduce.v2.app.webapp.AppController
Ensure that a TASK_ID was passed into the page.
resetIsLastAMRetry() - Method in class org.apache.hadoop.mapreduce.v2.app.MRAppMaster.RunningAppContext
 
resolveHost(String) - Method in class org.apache.hadoop.mapreduce.v2.app.job.impl.TaskAttemptImpl
 
resolveHosts(String[]) - Method in class org.apache.hadoop.mapreduce.v2.app.job.impl.TaskAttemptImpl
 
RESOURCE_REQUEST_CACHE - Static variable in class org.apache.hadoop.mapreduce.v2.app.job.impl.TaskAttemptImpl
 
ResourceCalculatorUtils - Class in org.apache.hadoop.mapreduce.v2.app.rm
 
ResourceCalculatorUtils() - Constructor for class org.apache.hadoop.mapreduce.v2.app.rm.ResourceCalculatorUtils
 
RM_WEB - Static variable in interface org.apache.hadoop.mapreduce.v2.app.webapp.AMParams
 
RMCommunicator - Class in org.apache.hadoop.mapreduce.v2.app.rm
Registers/unregisters to RM and sends heartbeats to RM.
RMCommunicator(ClientService, AppContext) - Constructor for class org.apache.hadoop.mapreduce.v2.app.rm.RMCommunicator
 
RMCommunicator.AllocatorRunnable - Class in org.apache.hadoop.mapreduce.v2.app.rm
 
RMContainerAllocationException - Exception in org.apache.hadoop.mapreduce.v2.app.rm
Exception to denote fatal failure in allocating containers from RM.
RMContainerAllocationException(Throwable) - Constructor for exception org.apache.hadoop.mapreduce.v2.app.rm.RMContainerAllocationException
 
RMContainerAllocationException(String) - Constructor for exception org.apache.hadoop.mapreduce.v2.app.rm.RMContainerAllocationException
 
RMContainerAllocationException(String, Throwable) - Constructor for exception org.apache.hadoop.mapreduce.v2.app.rm.RMContainerAllocationException
 
RMContainerAllocator - Class in org.apache.hadoop.mapreduce.v2.app.rm
Allocates the container from the ResourceManager scheduler.
RMContainerAllocator(ClientService, AppContext, AMPreemptionPolicy) - Constructor for class org.apache.hadoop.mapreduce.v2.app.rm.RMContainerAllocator
 
RMContainerRequestor - Class in org.apache.hadoop.mapreduce.v2.app.rm
Keeps the data structures to send container requests to RM.
RMContainerRequestor(ClientService, AppContext) - Constructor for class org.apache.hadoop.mapreduce.v2.app.rm.RMContainerRequestor
 
RMHeartbeatHandler - Interface in org.apache.hadoop.mapreduce.v2.app.rm
 
run() - Method in class org.apache.hadoop.mapreduce.v2.app.rm.RMCommunicator.AllocatorRunnable
 
RunningAppContext(Configuration, TaskAttemptFinishingMonitor) - Constructor for class org.apache.hadoop.mapreduce.v2.app.MRAppMaster.RunningAppContext
 
runningJob(Job) - Method in class org.apache.hadoop.mapreduce.v2.app.metrics.MRAppMetrics
 
runningMapAttempts - Variable in class org.apache.hadoop.mapreduce.v2.app.webapp.dao.JobInfo
 
runningReduceAttempts - Variable in class org.apache.hadoop.mapreduce.v2.app.webapp.dao.JobInfo
 
runningTask(Task) - Method in class org.apache.hadoop.mapreduce.v2.app.metrics.MRAppMetrics
 
runOnNextHeartbeat(Runnable) - Method in class org.apache.hadoop.mapreduce.v2.app.rm.RMCommunicator
 
runOnNextHeartbeat(Runnable) - Method in interface org.apache.hadoop.mapreduce.v2.app.rm.RMHeartbeatHandler
 
runtimeEstimateVariance(TaskAttemptId) - Method in class org.apache.hadoop.mapreduce.v2.app.speculate.ExponentiallySmoothedTaskRuntimeEstimator
 
runtimeEstimateVariance(TaskAttemptId) - Method in class org.apache.hadoop.mapreduce.v2.app.speculate.LegacyTaskRuntimeEstimator
 
runtimeEstimateVariance(TaskAttemptId) - Method in class org.apache.hadoop.mapreduce.v2.app.speculate.NullTaskRuntimesEngine
 
runtimeEstimateVariance(TaskAttemptId) - Method in class org.apache.hadoop.mapreduce.v2.app.speculate.SimpleExponentialTaskRuntimeEstimator
 
runtimeEstimateVariance(TaskAttemptId) - Method in interface org.apache.hadoop.mapreduce.v2.app.speculate.TaskRuntimeEstimator
Computes the width of the error band of our estimate of the task runtime as returned by TaskRuntimeEstimator.estimatedRuntime(TaskAttemptId)

S

scanForSpeculations() - Method in class org.apache.hadoop.mapreduce.v2.app.speculate.DefaultSpeculator
 
scheduleAllReduces() - Method in class org.apache.hadoop.mapreduce.v2.app.rm.RMContainerAllocator
 
scheduler - Variable in class org.apache.hadoop.mapreduce.v2.app.rm.RMCommunicator
 
scheduleReduces(int, int, int, int, int, int, Resource, Resource, int, float, float) - Method in class org.apache.hadoop.mapreduce.v2.app.rm.RMContainerAllocator
 
scheduleTasks(Set<TaskId>, boolean) - Method in class org.apache.hadoop.mapreduce.v2.app.job.impl.JobImpl
 
serviceInit(Configuration) - Method in class org.apache.hadoop.mapred.TaskAttemptListenerImpl
 
serviceInit(Configuration) - Method in class org.apache.hadoop.mapreduce.jobhistory.JobHistoryCopyService
 
serviceInit(Configuration) - Method in class org.apache.hadoop.mapreduce.jobhistory.JobHistoryEventHandler
 
serviceInit(Configuration) - Method in class org.apache.hadoop.mapreduce.v2.app.commit.CommitterEventHandler
 
serviceInit(Configuration) - Method in class org.apache.hadoop.mapreduce.v2.app.launcher.ContainerLauncherImpl
 
serviceInit(Configuration) - Method in class org.apache.hadoop.mapreduce.v2.app.local.LocalContainerAllocator
 
serviceInit(Configuration) - Method in class org.apache.hadoop.mapreduce.v2.app.MRAppMaster
 
serviceInit(Configuration) - Method in class org.apache.hadoop.mapreduce.v2.app.rm.RMCommunicator
 
serviceInit(Configuration) - Method in class org.apache.hadoop.mapreduce.v2.app.rm.RMContainerAllocator
 
serviceInit(Configuration) - Method in class org.apache.hadoop.mapreduce.v2.app.rm.RMContainerRequestor
 
serviceInit(Configuration) - Method in class org.apache.hadoop.mapreduce.v2.app.TaskHeartbeatHandler
 
serviceStart() - Method in class org.apache.hadoop.mapred.LocalContainerLauncher
 
serviceStart() - Method in class org.apache.hadoop.mapred.TaskAttemptListenerImpl
 
serviceStart() - Method in class org.apache.hadoop.mapreduce.jobhistory.JobHistoryCopyService
 
serviceStart() - Method in class org.apache.hadoop.mapreduce.jobhistory.JobHistoryEventHandler
 
serviceStart() - Method in class org.apache.hadoop.mapreduce.v2.app.client.MRClientService
 
serviceStart() - Method in class org.apache.hadoop.mapreduce.v2.app.commit.CommitterEventHandler
 
serviceStart() - Method in class org.apache.hadoop.mapreduce.v2.app.launcher.ContainerLauncherImpl
 
serviceStart() - Method in class org.apache.hadoop.mapreduce.v2.app.MRAppMaster
 
serviceStart() - Method in class org.apache.hadoop.mapreduce.v2.app.rm.RMCommunicator
 
serviceStart() - Method in class org.apache.hadoop.mapreduce.v2.app.rm.RMContainerAllocator
 
serviceStart() - Method in class org.apache.hadoop.mapreduce.v2.app.speculate.DefaultSpeculator
 
serviceStart() - Method in class org.apache.hadoop.mapreduce.v2.app.TaskHeartbeatHandler
 
serviceStop() - Method in class org.apache.hadoop.mapred.LocalContainerLauncher
 
serviceStop() - Method in class org.apache.hadoop.mapred.TaskAttemptListenerImpl
 
serviceStop() - Method in class org.apache.hadoop.mapreduce.jobhistory.JobHistoryEventHandler
 
serviceStop() - Method in class org.apache.hadoop.mapreduce.v2.app.client.MRClientService
 
serviceStop() - Method in class org.apache.hadoop.mapreduce.v2.app.commit.CommitterEventHandler
 
serviceStop() - Method in class org.apache.hadoop.mapreduce.v2.app.launcher.ContainerLauncherImpl
 
serviceStop() - Method in class org.apache.hadoop.mapreduce.v2.app.MRAppMaster
 
serviceStop() - Method in class org.apache.hadoop.mapreduce.v2.app.rm.RMCommunicator
 
serviceStop() - Method in class org.apache.hadoop.mapreduce.v2.app.rm.RMContainerAllocator
 
serviceStop() - Method in class org.apache.hadoop.mapreduce.v2.app.speculate.DefaultSpeculator
 
serviceStop() - Method in class org.apache.hadoop.mapreduce.v2.app.TaskHeartbeatHandler
 
setAvataar(Avataar) - Method in class org.apache.hadoop.mapreduce.v2.app.job.impl.TaskAttemptImpl
 
setCheckpointID(TaskID, TaskCheckpointID) - Method in class org.apache.hadoop.mapred.TaskAttemptListenerImpl
 
setCheckpointID(TaskId, TaskCheckpointID) - Method in interface org.apache.hadoop.mapreduce.v2.app.rm.preemption.AMPreemptionPolicy
Method to store the latest CheckpointID for a given TaskId.
setCheckpointID(TaskId, TaskCheckpointID) - Method in class org.apache.hadoop.mapreduce.v2.app.rm.preemption.CheckpointAMPreemptionPolicy
 
setCheckpointID(TaskId, TaskCheckpointID) - Method in class org.apache.hadoop.mapreduce.v2.app.rm.preemption.KillAMPreemptionPolicy
 
setCheckpointID(TaskId, TaskCheckpointID) - Method in class org.apache.hadoop.mapreduce.v2.app.rm.preemption.NoopAMPreemptionPolicy
 
setConf(Configuration) - Method in class org.apache.hadoop.mapred.YarnOutputFiles
 
setConf(Configuration) - Method in class org.apache.hadoop.mapreduce.v2.app.JobEndNotifier
Parse the URL that needs to be notified of the end of the job, along with the number of retries in case of failure, the amount of time to wait between retries and proxy settings
setEncryptedSpillKey(byte[]) - Method in class org.apache.hadoop.mapred.LocalContainerLauncher
 
setFirstMapTaskLaunchTime(long) - Method in class org.apache.hadoop.mapreduce.jobhistory.JobSummary
 
setFirstReduceTaskLaunchTime(long) - Method in class org.apache.hadoop.mapreduce.jobhistory.JobSummary
 
setForcejobCompletion(boolean) - Method in class org.apache.hadoop.mapreduce.jobhistory.JobHistoryEventHandler
 
setHistoryUrl(String) - Method in interface org.apache.hadoop.mapreduce.v2.app.AppContext
 
setHistoryUrl(String) - Method in class org.apache.hadoop.mapreduce.v2.app.MRAppMaster.RunningAppContext
 
setIsReduceStarted(boolean) - Method in class org.apache.hadoop.mapreduce.v2.app.rm.RMContainerAllocator
 
setJobFinishTime(long) - Method in class org.apache.hadoop.mapreduce.jobhistory.JobSummary
 
setJobId(JobId) - Method in class org.apache.hadoop.mapreduce.jobhistory.JobSummary
 
setJobLaunchTime(long) - Method in class org.apache.hadoop.mapreduce.jobhistory.JobSummary
 
setJobName(String) - Method in class org.apache.hadoop.mapreduce.jobhistory.JobSummary
 
setJobPriority(Priority) - Method in class org.apache.hadoop.mapreduce.v2.app.job.impl.JobImpl
 
setJobPriority(Priority) - Method in interface org.apache.hadoop.mapreduce.v2.app.job.Job
 
setJobStatus(String) - Method in class org.apache.hadoop.mapreduce.jobhistory.JobSummary
 
setJobSubmitTime(long) - Method in class org.apache.hadoop.mapreduce.jobhistory.JobSummary
 
setLocality(Locality) - Method in class org.apache.hadoop.mapreduce.v2.app.job.impl.TaskAttemptImpl
 
setMapSlotSeconds(long) - Method in class org.apache.hadoop.mapreduce.jobhistory.JobSummary
 
setMaxContainerCapability(Resource) - Method in class org.apache.hadoop.mapreduce.v2.app.ClusterInfo
 
setNumFailedMaps(int) - Method in class org.apache.hadoop.mapreduce.jobhistory.JobSummary
 
setNumFailedReduces(int) - Method in class org.apache.hadoop.mapreduce.jobhistory.JobSummary
 
setNumKilledMaps(int) - Method in class org.apache.hadoop.mapreduce.jobhistory.JobSummary
 
setNumKilledReduces(int) - Method in class org.apache.hadoop.mapreduce.jobhistory.JobSummary
 
setNumSucceededMaps(int) - Method in class org.apache.hadoop.mapreduce.jobhistory.JobSummary
 
setNumSucceededReduces(int) - Method in class org.apache.hadoop.mapreduce.jobhistory.JobSummary
 
setQueue(String) - Method in class org.apache.hadoop.mapreduce.jobhistory.JobSummary
 
setQueueName(String) - Method in class org.apache.hadoop.mapreduce.v2.app.job.impl.JobImpl
 
setQueueName(String) - Method in interface org.apache.hadoop.mapreduce.v2.app.job.Job
 
setReduceSlotSeconds(long) - Method in class org.apache.hadoop.mapreduce.jobhistory.JobSummary
 
setRequestLimit(Priority, Resource, int) - Method in class org.apache.hadoop.mapreduce.v2.app.rm.RMContainerRequestor
 
setResourcesPerMap(int) - Method in class org.apache.hadoop.mapreduce.jobhistory.JobSummary
 
setResourcesPerReduce(int) - Method in class org.apache.hadoop.mapreduce.jobhistory.JobSummary
 
setShouldUnregister(boolean) - Method in class org.apache.hadoop.mapreduce.v2.app.rm.RMCommunicator
 
setSignalled(boolean) - Method in class org.apache.hadoop.mapreduce.v2.app.rm.RMCommunicator
 
setState(String) - Method in class org.apache.hadoop.mapreduce.v2.app.webapp.dao.JobTaskAttemptState
 
setTaskFailFast(boolean) - Method in class org.apache.hadoop.mapreduce.v2.app.job.impl.TaskAttemptImpl
 
setup(JobImpl) - Method in class org.apache.hadoop.mapreduce.v2.app.job.impl.JobImpl.InitTransition
 
setup() - Method in class org.apache.hadoop.mapreduce.v2.app.webapp.AMWebApp
 
setupEventWriter(JobId, AMStartedEvent) - Method in class org.apache.hadoop.mapreduce.jobhistory.JobHistoryEventHandler
Create an event writer for the Job represented by the jobID.
setupJob(JobContext) - Method in class org.apache.hadoop.CustomOutputCommitter
 
setupTask(TaskAttemptContext) - Method in class org.apache.hadoop.CustomOutputCommitter
 
setUser(String) - Method in class org.apache.hadoop.mapreduce.jobhistory.JobSummary
 
setVMEnv(Map<String, String>, Task) - Static method in class org.apache.hadoop.mapred.MapReduceChildJVM
 
shuffleError(TaskAttemptID, String) - Method in class org.apache.hadoop.mapred.TaskAttemptListenerImpl
 
shuffleFinishTime - Variable in class org.apache.hadoop.mapreduce.v2.app.job.event.TaskAttemptStatusUpdateEvent.TaskAttemptStatus
 
shuffleFinishTime - Variable in class org.apache.hadoop.mapreduce.v2.app.webapp.dao.ReduceTaskAttemptInfo
 
SHUTDOWN_HOOK_PRIORITY - Static variable in class org.apache.hadoop.mapreduce.v2.app.MRAppMaster
Priority of the MRAppMaster shutdown hook.
shutDownJob() - Method in class org.apache.hadoop.mapreduce.v2.app.MRAppMaster
 
SimpleExponentialSmoothing - Class in org.apache.hadoop.mapreduce.v2.app.speculate.forecast
Implementation of the static model for Simple exponential smoothing.
SimpleExponentialTaskRuntimeEstimator - Class in org.apache.hadoop.mapreduce.v2.app.speculate
A task Runtime Estimator based on exponential smoothing.
SimpleExponentialTaskRuntimeEstimator() - Constructor for class org.apache.hadoop.mapreduce.v2.app.speculate.SimpleExponentialTaskRuntimeEstimator
 
SingleCounterBlock - Class in org.apache.hadoop.mapreduce.v2.app.webapp
 
singleCounterPage() - Method in class org.apache.hadoop.mapreduce.v2.app.webapp.AppController
 
SingleCounterPage - Class in org.apache.hadoop.mapreduce.v2.app.webapp
Render the counters page
SingleCounterPage() - Constructor for class org.apache.hadoop.mapreduce.v2.app.webapp.SingleCounterPage
 
singleJobCounter() - Method in class org.apache.hadoop.mapreduce.v2.app.webapp.AppController
Render the /singlejobcounter page
singleTaskCounter() - Method in class org.apache.hadoop.mapreduce.v2.app.webapp.AppController
Render the /singletaskcounter page
sortFinishTime - Variable in class org.apache.hadoop.mapreduce.v2.app.job.event.TaskAttemptStatusUpdateEvent.TaskAttemptStatus
 
source - Variable in class org.apache.hadoop.mapreduce.v2.app.webapp.dao.ConfEntryInfo
 
Speculator - Interface in org.apache.hadoop.mapreduce.v2.app.speculate
Speculator component.
Speculator.EventType - Enum in org.apache.hadoop.mapreduce.v2.app.speculate
 
SpeculatorEvent - Class in org.apache.hadoop.mapreduce.v2.app.speculate
 
SpeculatorEvent(JobId, long) - Constructor for class org.apache.hadoop.mapreduce.v2.app.speculate.SpeculatorEvent
 
SpeculatorEvent(TaskAttemptStatusUpdateEvent.TaskAttemptStatus, long) - Constructor for class org.apache.hadoop.mapreduce.v2.app.speculate.SpeculatorEvent
 
SpeculatorEvent(TaskAttemptId, boolean, long) - Constructor for class org.apache.hadoop.mapreduce.v2.app.speculate.SpeculatorEvent
 
SpeculatorEvent(TaskId, int) - Constructor for class org.apache.hadoop.mapreduce.v2.app.speculate.SpeculatorEvent
 
startAllocatorThread() - Method in class org.apache.hadoop.mapreduce.v2.app.rm.RMCommunicator
 
startedOn - Variable in class org.apache.hadoop.mapreduce.v2.app.webapp.dao.AppInfo
 
startJobs() - Method in class org.apache.hadoop.mapreduce.v2.app.MRAppMaster
This can be overridden to instantiate multiple jobs and create a workflow.
startRpcServer() - Method in class org.apache.hadoop.mapred.TaskAttemptListenerImpl
 
startTime - Variable in class org.apache.hadoop.mapreduce.v2.app.webapp.dao.AMAttemptInfo
 
startTime - Variable in class org.apache.hadoop.mapreduce.v2.app.webapp.dao.JobInfo
 
startTime - Variable in class org.apache.hadoop.mapreduce.v2.app.webapp.dao.TaskAttemptInfo
 
startTime - Variable in class org.apache.hadoop.mapreduce.v2.app.webapp.dao.TaskInfo
 
StartTransition() - Constructor for class org.apache.hadoop.mapreduce.v2.app.job.impl.JobImpl.StartTransition
 
state - Variable in class org.apache.hadoop.mapreduce.v2.app.webapp.dao.JobInfo
 
state - Variable in class org.apache.hadoop.mapreduce.v2.app.webapp.dao.TaskAttemptInfo
 
state - Variable in class org.apache.hadoop.mapreduce.v2.app.webapp.dao.TaskInfo
 
stateMachineFactory - Static variable in class org.apache.hadoop.mapreduce.v2.app.job.impl.JobImpl
 
stateString - Variable in class org.apache.hadoop.mapreduce.v2.app.job.event.TaskAttemptStatusUpdateEvent.TaskAttemptStatus
 
status - Variable in class org.apache.hadoop.mapreduce.v2.app.webapp.dao.TaskAttemptInfo
 
status - Variable in class org.apache.hadoop.mapreduce.v2.app.webapp.dao.TaskInfo
 
statusUpdate(TaskAttemptID, TaskStatus) - Method in class org.apache.hadoop.mapred.TaskAttemptListenerImpl
 
statusUpdate(TaskAttemptStatusUpdateEvent.TaskAttemptStatus, long) - Method in class org.apache.hadoop.mapreduce.v2.app.speculate.DefaultSpeculator
Absorbs one TaskAttemptStatus
std() - Method in class org.apache.hadoop.mapreduce.v2.app.speculate.DataStatistics
 
stop() - Method in class org.apache.hadoop.mapreduce.v2.app.MRAppMaster
 
stopRpcServer() - Method in class org.apache.hadoop.mapred.TaskAttemptListenerImpl
 
submittedJob(Job) - Method in class org.apache.hadoop.mapreduce.v2.app.metrics.MRAppMetrics
 
successfulAttempt - Variable in class org.apache.hadoop.mapreduce.v2.app.webapp.dao.TaskInfo
 
successfullyUnregistered - Variable in class org.apache.hadoop.mapreduce.v2.app.MRAppMaster
 
successfulMapAttempts - Variable in class org.apache.hadoop.mapreduce.v2.app.webapp.dao.JobInfo
 
successfulReduceAttempts - Variable in class org.apache.hadoop.mapreduce.v2.app.webapp.dao.JobInfo
 
sysexit() - Method in class org.apache.hadoop.mapreduce.v2.app.MRAppMaster
Exit call.

T

Task - Interface in org.apache.hadoop.mapreduce.v2.app.job
Read only view of Task.
task() - Method in class org.apache.hadoop.mapreduce.v2.app.webapp.AppController
Render the /task page
task - Variable in class org.apache.hadoop.mapreduce.v2.app.webapp.dao.TasksInfo
 
task - Variable in class org.apache.hadoop.mapreduce.v2.app.webapp.SingleCounterBlock
 
TASK_ABORT_FILE_NAME - Static variable in class org.apache.hadoop.CustomOutputCommitter
 
TASK_COMMIT_FILE_NAME - Static variable in class org.apache.hadoop.CustomOutputCommitter
 
TASK_ID - Static variable in interface org.apache.hadoop.mapreduce.v2.app.webapp.AMParams
 
TASK_SETUP_FILE_NAME - Static variable in class org.apache.hadoop.CustomOutputCommitter
 
TASK_STATE - Static variable in interface org.apache.hadoop.mapreduce.v2.app.webapp.AMParams
 
TASK_TYPE - Static variable in interface org.apache.hadoop.mapreduce.v2.app.webapp.AMParams
 
TaskAttempt - Interface in org.apache.hadoop.mapreduce.v2.app.job
Read only view of TaskAttempt.
TaskAttemptContainerAssignedEvent - Class in org.apache.hadoop.mapreduce.v2.app.job.event
 
TaskAttemptContainerAssignedEvent(TaskAttemptId, Container, Map<ApplicationAccessType, String>) - Constructor for class org.apache.hadoop.mapreduce.v2.app.job.event.TaskAttemptContainerAssignedEvent
 
TaskAttemptContainerLaunchedEvent - Class in org.apache.hadoop.mapreduce.v2.app.job.event
 
TaskAttemptContainerLaunchedEvent(TaskAttemptId, int) - Constructor for class org.apache.hadoop.mapreduce.v2.app.job.event.TaskAttemptContainerLaunchedEvent
Create a new TaskAttemptEvent.
taskAttemptCounterGroup - Variable in class org.apache.hadoop.mapreduce.v2.app.webapp.dao.JobTaskAttemptCounterInfo
 
TaskAttemptDiagnosticsUpdateEvent - Class in org.apache.hadoop.mapreduce.v2.app.job.event
 
TaskAttemptDiagnosticsUpdateEvent(TaskAttemptId, String) - Constructor for class org.apache.hadoop.mapreduce.v2.app.job.event.TaskAttemptDiagnosticsUpdateEvent
 
TaskAttemptEvent - Class in org.apache.hadoop.mapreduce.v2.app.job.event
This class encapsulates task attempt related events.
TaskAttemptEvent(TaskAttemptId, TaskAttemptEventType) - Constructor for class org.apache.hadoop.mapreduce.v2.app.job.event.TaskAttemptEvent
Create a new TaskAttemptEvent.
TaskAttemptEventType - Enum in org.apache.hadoop.mapreduce.v2.app.job.event
Event types handled by TaskAttempt.
TaskAttemptFailEvent - Class in org.apache.hadoop.mapreduce.v2.app.job.event
 
TaskAttemptFailEvent(TaskAttemptId) - Constructor for class org.apache.hadoop.mapreduce.v2.app.job.event.TaskAttemptFailEvent
Create a new TaskAttemptFailEvent, with task fastFail disabled.
TaskAttemptFailEvent(TaskAttemptId, boolean) - Constructor for class org.apache.hadoop.mapreduce.v2.app.job.event.TaskAttemptFailEvent
Create a new TaskAttemptFailEvent.
TaskAttemptFinishingMonitor - Class in org.apache.hadoop.mapreduce.v2.app
This class generates TA_TIMED_OUT if the task attempt stays in FINISHING state for too long.
TaskAttemptFinishingMonitor(EventHandler) - Constructor for class org.apache.hadoop.mapreduce.v2.app.TaskAttemptFinishingMonitor
 
TaskAttemptImpl - Class in org.apache.hadoop.mapreduce.v2.app.job.impl
Implementation of TaskAttempt interface.
TaskAttemptImpl(TaskId, int, EventHandler, TaskAttemptListener, Path, int, JobConf, String[], Token<JobTokenIdentifier>, Credentials, Clock, AppContext) - Constructor for class org.apache.hadoop.mapreduce.v2.app.job.impl.TaskAttemptImpl
 
TaskAttemptInfo - Class in org.apache.hadoop.mapreduce.v2.app.webapp.dao
 
TaskAttemptInfo() - Constructor for class org.apache.hadoop.mapreduce.v2.app.webapp.dao.TaskAttemptInfo
 
TaskAttemptInfo(TaskAttempt, TaskType, Boolean) - Constructor for class org.apache.hadoop.mapreduce.v2.app.webapp.dao.TaskAttemptInfo
 
TaskAttemptKillEvent - Class in org.apache.hadoop.mapreduce.v2.app.job.event
 
TaskAttemptKillEvent(TaskAttemptId, String, boolean) - Constructor for class org.apache.hadoop.mapreduce.v2.app.job.event.TaskAttemptKillEvent
 
TaskAttemptKillEvent(TaskAttemptId, String) - Constructor for class org.apache.hadoop.mapreduce.v2.app.job.event.TaskAttemptKillEvent
 
taskAttemptListener - Variable in class org.apache.hadoop.mapreduce.v2.app.job.impl.TaskImpl
 
taskAttemptListener - Variable in class org.apache.hadoop.mapreduce.v2.app.MRAppMaster
 
TaskAttemptListener - Interface in org.apache.hadoop.mapreduce.v2.app
This class listens for changes to the state of a Task.
TaskAttemptListenerImpl - Class in org.apache.hadoop.mapred
This class is responsible for talking to the task umblical.
TaskAttemptListenerImpl(AppContext, JobTokenSecretManager, RMHeartbeatHandler, AMPreemptionPolicy) - Constructor for class org.apache.hadoop.mapred.TaskAttemptListenerImpl
 
TaskAttemptListenerImpl(AppContext, JobTokenSecretManager, RMHeartbeatHandler, AMPreemptionPolicy, byte[]) - Constructor for class org.apache.hadoop.mapred.TaskAttemptListenerImpl
 
TaskAttemptRecoverEvent - Class in org.apache.hadoop.mapreduce.v2.app.job.event
 
TaskAttemptRecoverEvent(TaskAttemptId, JobHistoryParser.TaskAttemptInfo, OutputCommitter, boolean) - Constructor for class org.apache.hadoop.mapreduce.v2.app.job.event.TaskAttemptRecoverEvent
 
taskAttempts - Variable in class org.apache.hadoop.mapreduce.v2.app.webapp.dao.TaskAttemptsInfo
 
TaskAttemptsInfo - Class in org.apache.hadoop.mapreduce.v2.app.webapp.dao
 
TaskAttemptsInfo() - Constructor for class org.apache.hadoop.mapreduce.v2.app.webapp.dao.TaskAttemptsInfo
 
TaskAttemptStateInternal - Enum in org.apache.hadoop.mapreduce.v2.app.job
TaskAttemptImpl internal state machine states.
TaskAttemptStatus() - Constructor for class org.apache.hadoop.mapreduce.v2.app.job.event.TaskAttemptStatusUpdateEvent.TaskAttemptStatus
 
TaskAttemptStatusUpdateEvent - Class in org.apache.hadoop.mapreduce.v2.app.job.event
 
TaskAttemptStatusUpdateEvent(TaskAttemptId, AtomicReference<TaskAttemptStatusUpdateEvent.TaskAttemptStatus>) - Constructor for class org.apache.hadoop.mapreduce.v2.app.job.event.TaskAttemptStatusUpdateEvent
 
TaskAttemptStatusUpdateEvent.TaskAttemptStatus - Class in org.apache.hadoop.mapreduce.v2.app.job.event
The internal TaskAttemptStatus object corresponding to remote Task status.
TaskAttemptTooManyFetchFailureEvent - Class in org.apache.hadoop.mapreduce.v2.app.job.event
TaskAttemptTooManyFetchFailureEvent is used for TA_TOO_MANY_FETCH_FAILURE.
TaskAttemptTooManyFetchFailureEvent(TaskAttemptId, TaskAttemptId, String) - Constructor for class org.apache.hadoop.mapreduce.v2.app.job.event.TaskAttemptTooManyFetchFailureEvent
Create a new TaskAttemptTooManyFetchFailureEvent.
taskCounterGroup - Variable in class org.apache.hadoop.mapreduce.v2.app.webapp.dao.JobTaskCounterInfo
 
TaskCounterGroupInfo - Class in org.apache.hadoop.mapreduce.v2.app.webapp.dao
 
TaskCounterGroupInfo() - Constructor for class org.apache.hadoop.mapreduce.v2.app.webapp.dao.TaskCounterGroupInfo
 
TaskCounterGroupInfo(String, CounterGroup) - Constructor for class org.apache.hadoop.mapreduce.v2.app.webapp.dao.TaskCounterGroupInfo
 
TaskCounterInfo - Class in org.apache.hadoop.mapreduce.v2.app.webapp.dao
 
TaskCounterInfo() - Constructor for class org.apache.hadoop.mapreduce.v2.app.webapp.dao.TaskCounterInfo
 
TaskCounterInfo(String, long) - Constructor for class org.apache.hadoop.mapreduce.v2.app.webapp.dao.TaskCounterInfo
 
taskCounters() - Method in class org.apache.hadoop.mapreduce.v2.app.webapp.AppController
Display a page showing a task's counters
TaskEvent - Class in org.apache.hadoop.mapreduce.v2.app.job.event
this class encapsulates task related events.
TaskEvent(TaskId, TaskEventType) - Constructor for class org.apache.hadoop.mapreduce.v2.app.job.event.TaskEvent
 
TaskEventType - Enum in org.apache.hadoop.mapreduce.v2.app.job.event
Event types handled by Task.
taskHeartbeatHandler - Variable in class org.apache.hadoop.mapred.TaskAttemptListenerImpl
 
TaskHeartbeatHandler - Class in org.apache.hadoop.mapreduce.v2.app
This class keeps track of tasks that have already been launched.
TaskHeartbeatHandler(EventHandler, Clock, int) - Constructor for class org.apache.hadoop.mapreduce.v2.app.TaskHeartbeatHandler
 
TaskImpl - Class in org.apache.hadoop.mapreduce.v2.app.job.impl
Implementation of Task interface.
TaskImpl(JobId, TaskType, int, EventHandler, Path, JobConf, TaskAttemptListener, Token<JobTokenIdentifier>, Credentials, Clock, int, MRAppMetrics, AppContext) - Constructor for class org.apache.hadoop.mapreduce.v2.app.job.impl.TaskImpl
 
TaskInfo - Class in org.apache.hadoop.mapreduce.v2.app.webapp.dao
 
TaskInfo() - Constructor for class org.apache.hadoop.mapreduce.v2.app.webapp.dao.TaskInfo
 
TaskInfo(Task) - Constructor for class org.apache.hadoop.mapreduce.v2.app.webapp.dao.TaskInfo
 
taskPage() - Method in class org.apache.hadoop.mapreduce.v2.app.webapp.AppController
 
TaskPage - Class in org.apache.hadoop.mapreduce.v2.app.webapp
 
TaskPage() - Constructor for class org.apache.hadoop.mapreduce.v2.app.webapp.TaskPage
 
TaskRecoverEvent - Class in org.apache.hadoop.mapreduce.v2.app.job.event
 
TaskRecoverEvent(TaskId, JobHistoryParser.TaskInfo, OutputCommitter, boolean) - Constructor for class org.apache.hadoop.mapreduce.v2.app.job.event.TaskRecoverEvent
 
TaskRuntimeEstimator - Interface in org.apache.hadoop.mapreduce.v2.app.speculate
 
tasks() - Method in class org.apache.hadoop.mapreduce.v2.app.webapp.AppController
Render the /tasks page
TasksBlock - Class in org.apache.hadoop.mapreduce.v2.app.webapp
 
TasksInfo - Class in org.apache.hadoop.mapreduce.v2.app.webapp.dao
 
TasksInfo() - Constructor for class org.apache.hadoop.mapreduce.v2.app.webapp.dao.TasksInfo
 
tasksPage() - Method in class org.apache.hadoop.mapreduce.v2.app.webapp.AppController
 
TasksPage - Class in org.apache.hadoop.mapreduce.v2.app.webapp
 
TasksPage() - Constructor for class org.apache.hadoop.mapreduce.v2.app.webapp.TasksPage
 
TaskSpeculationPredicate - Class in org.apache.hadoop.mapreduce.v2.app.speculate
 
TaskSpeculationPredicate() - Constructor for class org.apache.hadoop.mapreduce.v2.app.speculate.TaskSpeculationPredicate
 
taskState - Variable in class org.apache.hadoop.mapreduce.v2.app.job.event.TaskAttemptStatusUpdateEvent.TaskAttemptStatus
 
TaskStateInternal - Enum in org.apache.hadoop.mapreduce.v2.app.job
 
TaskTAttemptEvent - Class in org.apache.hadoop.mapreduce.v2.app.job.event
 
TaskTAttemptEvent(TaskAttemptId, TaskEventType) - Constructor for class org.apache.hadoop.mapreduce.v2.app.job.event.TaskTAttemptEvent
 
TaskTAttemptFailedEvent - Class in org.apache.hadoop.mapreduce.v2.app.job.event
 
TaskTAttemptFailedEvent(TaskAttemptId) - Constructor for class org.apache.hadoop.mapreduce.v2.app.job.event.TaskTAttemptFailedEvent
 
TaskTAttemptFailedEvent(TaskAttemptId, boolean) - Constructor for class org.apache.hadoop.mapreduce.v2.app.job.event.TaskTAttemptFailedEvent
 
TaskTAttemptKilledEvent - Class in org.apache.hadoop.mapreduce.v2.app.job.event
Task Attempt killed event.
TaskTAttemptKilledEvent(TaskAttemptId, boolean) - Constructor for class org.apache.hadoop.mapreduce.v2.app.job.event.TaskTAttemptKilledEvent
 
thresholdRuntime(TaskId) - Method in class org.apache.hadoop.mapreduce.v2.app.speculate.NullTaskRuntimesEngine
 
thresholdRuntime(TaskId) - Method in interface org.apache.hadoop.mapreduce.v2.app.speculate.TaskRuntimeEstimator
Find a maximum reasonable execution wallclock time.
timelineClient - Variable in class org.apache.hadoop.mapreduce.jobhistory.JobHistoryEventHandler
 
timelineV2Client - Variable in class org.apache.hadoop.mapreduce.jobhistory.JobHistoryEventHandler
 
timeout - Variable in class org.apache.hadoop.mapreduce.v2.app.JobEndNotifier
 
toString() - Method in class org.apache.hadoop.mapreduce.jobhistory.JobHistoryEventHandler.MetaInfo
 
toString() - Method in class org.apache.hadoop.mapreduce.v2.app.launcher.ContainerLauncherEvent
 
toString() - Method in class org.apache.hadoop.mapreduce.v2.app.speculate.DataStatistics
 
toString() - Method in class org.apache.hadoop.mapreduce.v2.app.speculate.forecast.SimpleExponentialSmoothing
 
total - Variable in class org.apache.hadoop.mapreduce.v2.app.webapp.dao.JobCounterInfo
 
total - Variable in class org.apache.hadoop.mapreduce.v2.app.webapp.dao.JobTaskAttemptCounterInfo
 
total - Variable in class org.apache.hadoop.mapreduce.v2.app.webapp.dao.JobTaskCounterInfo
 
totalCounterValue - Variable in class org.apache.hadoop.mapreduce.v2.app.webapp.dao.CounterInfo
 
transition(JobImpl, JobEvent) - Method in class org.apache.hadoop.mapreduce.v2.app.job.impl.JobImpl.InitTransition
Note that this transition method is called directly (and synchronously) by MRAppMaster's init() method (i.e., no RPC, no thread-switching; just plain sequential call within AM context), so we can trigger modifications in AM state from here (at least, if AM is written that way; MR version is).
transition(JobImpl, JobEvent) - Method in class org.apache.hadoop.mapreduce.v2.app.job.impl.JobImpl.StartTransition
This transition executes in the event-dispatcher thread, though it's triggered in MRAppMaster's startJobs() method.
type - Variable in class org.apache.hadoop.mapreduce.v2.app.webapp.dao.TaskAttemptInfo
 
type - Variable in class org.apache.hadoop.mapreduce.v2.app.webapp.dao.TaskInfo
 

U

uberized - Variable in class org.apache.hadoop.mapreduce.v2.app.webapp.dao.JobInfo
 
unregister(TaskAttemptId, WrappedJvmID) - Method in class org.apache.hadoop.mapred.TaskAttemptListenerImpl
 
unregister() - Method in class org.apache.hadoop.mapreduce.v2.app.rm.RMCommunicator
 
unregister(TaskAttemptId, WrappedJvmID) - Method in interface org.apache.hadoop.mapreduce.v2.app.TaskAttemptListener
Unregister the JVM and the attempt associated with it.
unregister(TaskAttemptId) - Method in class org.apache.hadoop.mapreduce.v2.app.TaskHeartbeatHandler
 
updateAttempt(TaskAttemptStatusUpdateEvent.TaskAttemptStatus, long) - Method in class org.apache.hadoop.mapreduce.v2.app.speculate.ExponentiallySmoothedTaskRuntimeEstimator
 
updateAttempt(TaskAttemptStatusUpdateEvent.TaskAttemptStatus, long) - Method in class org.apache.hadoop.mapreduce.v2.app.speculate.LegacyTaskRuntimeEstimator
 
updateAttempt(TaskAttemptStatusUpdateEvent.TaskAttemptStatus, long) - Method in class org.apache.hadoop.mapreduce.v2.app.speculate.NullTaskRuntimesEngine
 
updateAttempt(TaskAttemptStatusUpdateEvent.TaskAttemptStatus, long) - Method in class org.apache.hadoop.mapreduce.v2.app.speculate.SimpleExponentialTaskRuntimeEstimator
 
updateAttempt(TaskAttemptStatusUpdateEvent.TaskAttemptStatus, long) - Method in interface org.apache.hadoop.mapreduce.v2.app.speculate.TaskRuntimeEstimator
 
updateJobTaskAttemptState(JobTaskAttemptState, HttpServletRequest, String, String, String) - Method in class org.apache.hadoop.mapreduce.v2.app.webapp.AMWebServices
 
updateStatistics(double, double) - Method in class org.apache.hadoop.mapreduce.v2.app.speculate.DataStatistics
 
urlToNotify - Variable in class org.apache.hadoop.mapreduce.v2.app.JobEndNotifier
 
user - Variable in class org.apache.hadoop.mapreduce.v2.app.webapp.dao.AppInfo
 
user - Variable in class org.apache.hadoop.mapreduce.v2.app.webapp.dao.JobInfo
 
userUrl - Variable in class org.apache.hadoop.mapreduce.v2.app.JobEndNotifier
 

V

value - Variable in class org.apache.hadoop.mapreduce.v2.app.webapp.dao.ConfEntryInfo
 
value - Variable in class org.apache.hadoop.mapreduce.v2.app.webapp.dao.TaskCounterInfo
 
valueOf(String) - Static method in enum org.apache.hadoop.mapreduce.v2.app.commit.CommitterEventType
Returns the enum constant of this type with the specified name.
valueOf(String) - Static method in enum org.apache.hadoop.mapreduce.v2.app.job.event.JobEventType
Returns the enum constant of this type with the specified name.
valueOf(String) - Static method in enum org.apache.hadoop.mapreduce.v2.app.job.event.JobFinishEvent.Type
Returns the enum constant of this type with the specified name.
valueOf(String) - Static method in enum org.apache.hadoop.mapreduce.v2.app.job.event.TaskAttemptEventType
Returns the enum constant of this type with the specified name.
valueOf(String) - Static method in enum org.apache.hadoop.mapreduce.v2.app.job.event.TaskEventType
Returns the enum constant of this type with the specified name.
valueOf(String) - Static method in enum org.apache.hadoop.mapreduce.v2.app.job.JobStateInternal
Returns the enum constant of this type with the specified name.
valueOf(String) - Static method in enum org.apache.hadoop.mapreduce.v2.app.job.TaskAttemptStateInternal
Returns the enum constant of this type with the specified name.
valueOf(String) - Static method in enum org.apache.hadoop.mapreduce.v2.app.job.TaskStateInternal
Returns the enum constant of this type with the specified name.
valueOf(String) - Static method in enum org.apache.hadoop.mapreduce.v2.app.launcher.ContainerLauncher.EventType
Returns the enum constant of this type with the specified name.
valueOf(String) - Static method in enum org.apache.hadoop.mapreduce.v2.app.rm.ContainerAllocator.EventType
Returns the enum constant of this type with the specified name.
valueOf(String) - Static method in enum org.apache.hadoop.mapreduce.v2.app.speculate.ExponentiallySmoothedTaskRuntimeEstimator.SmoothedValue
Returns the enum constant of this type with the specified name.
valueOf(String) - Static method in enum org.apache.hadoop.mapreduce.v2.app.speculate.Speculator.EventType
Returns the enum constant of this type with the specified name.
values() - Static method in enum org.apache.hadoop.mapreduce.v2.app.commit.CommitterEventType
Returns an array containing the constants of this enum type, in the order they are declared.
values() - Static method in enum org.apache.hadoop.mapreduce.v2.app.job.event.JobEventType
Returns an array containing the constants of this enum type, in the order they are declared.
values() - Static method in enum org.apache.hadoop.mapreduce.v2.app.job.event.JobFinishEvent.Type
Returns an array containing the constants of this enum type, in the order they are declared.
values() - Static method in enum org.apache.hadoop.mapreduce.v2.app.job.event.TaskAttemptEventType
Returns an array containing the constants of this enum type, in the order they are declared.
values() - Static method in enum org.apache.hadoop.mapreduce.v2.app.job.event.TaskEventType
Returns an array containing the constants of this enum type, in the order they are declared.
values() - Static method in enum org.apache.hadoop.mapreduce.v2.app.job.JobStateInternal
Returns an array containing the constants of this enum type, in the order they are declared.
values() - Static method in enum org.apache.hadoop.mapreduce.v2.app.job.TaskAttemptStateInternal
Returns an array containing the constants of this enum type, in the order they are declared.
values() - Static method in enum org.apache.hadoop.mapreduce.v2.app.job.TaskStateInternal
Returns an array containing the constants of this enum type, in the order they are declared.
values() - Static method in enum org.apache.hadoop.mapreduce.v2.app.launcher.ContainerLauncher.EventType
Returns an array containing the constants of this enum type, in the order they are declared.
values() - Static method in enum org.apache.hadoop.mapreduce.v2.app.rm.ContainerAllocator.EventType
Returns an array containing the constants of this enum type, in the order they are declared.
values() - Static method in enum org.apache.hadoop.mapreduce.v2.app.speculate.ExponentiallySmoothedTaskRuntimeEstimator.SmoothedValue
Returns an array containing the constants of this enum type, in the order they are declared.
values() - Static method in enum org.apache.hadoop.mapreduce.v2.app.speculate.Speculator.EventType
Returns an array containing the constants of this enum type, in the order they are declared.
values - Variable in class org.apache.hadoop.mapreduce.v2.app.webapp.SingleCounterBlock
 
var() - Method in class org.apache.hadoop.mapreduce.v2.app.speculate.DataStatistics
 

W

waitingTask(Task) - Method in class org.apache.hadoop.mapreduce.v2.app.metrics.MRAppMetrics
 
waitInterval - Variable in class org.apache.hadoop.mapreduce.v2.app.JobEndNotifier
 
WrappedJvmID - Class in org.apache.hadoop.mapred
A simple wrapper for increasing the visibility.
WrappedJvmID(JobID, boolean, long) - Constructor for class org.apache.hadoop.mapred.WrappedJvmID
 
WrappedPeriodicStatsAccumulator - Class in org.apache.hadoop.mapred
 
WrappedPeriodicStatsAccumulator(PeriodicStatsAccumulator) - Constructor for class org.apache.hadoop.mapred.WrappedPeriodicStatsAccumulator
 
WrappedProgressSplitsBlock - Class in org.apache.hadoop.mapred
 
WrappedProgressSplitsBlock(int) - Constructor for class org.apache.hadoop.mapred.WrappedProgressSplitsBlock
 

Y

YarnOutputFiles - Class in org.apache.hadoop.mapred
Manipulate the working area for the transient store for maps and reduces.
YarnOutputFiles() - Constructor for class org.apache.hadoop.mapred.YarnOutputFiles
 
A B C D E F G H I J K L M N O P Q R S T U V W Y 
Skip navigation links

Copyright © 2008–2024 Apache Software Foundation. All rights reserved.