All Classes and Interfaces
Class
Description
Params constants for the AM webapp and the history webapp.
Policy encoding the
MRAppMaster
response to preemption requests from the ResourceManager.Application master webapp
Context interface for sharing information across components in YARN App.
This class renders the various pages that the web app supports.
This policy works in combination with an implementation of task
checkpointing.
PolicyProvider for MapReduce history server protocols.Render the configuration for this job.
This class is responsible for launching of containers.
This estimator exponentially smooths the rate of progress versus wallclock
time.
Main interface to interact with the job.
Render a page with the configuration for a given job in it.
This class handles job end notification.
This class encapsulates job related events.
Event types handled by Job.
Reads in history events from the JobHistoryFile and sends them out again
to be recorded.
The job history events get routed to this class.
Implementation of Job interface.
Job task attempt state.
Sample policy that aggressively kills tasks when requested.
Allocates containers locally.
Runs the container task locally in a thread.
PolicyProvider for YARN MapReduce protocols.The Map-Reduce Application Master.
This module is responsible for talking to the
jobclient (user facing).
NoOp policy that ignores all the requests for preemption.
Registers/unregisters to RM and sends heartbeats to RM.
Exception to denote fatal failure in allocating containers from RM.
Allocates the container from the ResourceManager scheduler.
Keeps the data structures to send container requests to RM.
Implementation of the static model for Simple exponential smoothing.
A task Runtime Estimator based on exponential smoothing.
Render the counters page
Speculator component.
Read only view of Task.
Read only view of TaskAttempt.
This class encapsulates task attempt related events.
Event types handled by TaskAttempt.
This class generates TA_TIMED_OUT if the task attempt stays in FINISHING
state for too long.
Implementation of TaskAttempt interface.
This class listens for changes to the state of a Task.
This class is responsible for talking to the task umblical.
TaskAttemptImpl internal state machine states.
The internal TaskAttemptStatus object corresponding to remote Task status.
TaskAttemptTooManyFetchFailureEvent is used for TA_TOO_MANY_FETCH_FAILURE.
this class encapsulates task related events.
Event types handled by Task.
This class keeps track of tasks that have already been launched.
Implementation of Task interface.
Task Attempt killed event.
A simple wrapper for increasing the visibility.
Manipulate the working area for the transient store for maps and reduces.