Index

A B C D E F G H I J K L M N O P Q R S T U V W Y
All Classes and Interfaces|All Packages|Constant Field Values|Serialized Form

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(AppContext) - 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 - Variable in class org.apache.hadoop.mapreduce.v2.app.webapp.AppController

App - Class in org.apache.hadoop.mapreduce.v2.app.webapp

App(AppContext) - Constructor for class org.apache.hadoop.mapreduce.v2.app.webapp.App

APP_ID - Static variable in interface org.apache.hadoop.mapreduce.v2.app.webapp.AMParams

appContext - Variable in class org.apache.hadoop.mapreduce.v2.app.job.impl.TaskImpl

AppContext - Interface in org.apache.hadoop.mapreduce.v2.app

Context interface for sharing information across components in YARN App.

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) - Constructor for class org.apache.hadoop.mapreduce.v2.app.webapp.AppController

AppController(App, Configuration, Controller.RequestContext, String) - Constructor for class org.apache.hadoop.mapreduce.v2.app.webapp.AppController

appendTo(StringBuilder) - Method in class org.apache.hadoop.mapred.WrappedJvmID

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

ASSIGNED - Enum constant in enum class org.apache.hadoop.mapreduce.v2.app.job.TaskAttemptStateInternal

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_START - Enum constant in enum class org.apache.hadoop.mapreduce.v2.app.speculate.Speculator.EventType

ATTEMPT_STATE - Static variable in interface org.apache.hadoop.mapreduce.v2.app.webapp.AMParams

ATTEMPT_STATUS_UPDATE - Enum constant in enum class org.apache.hadoop.mapreduce.v2.app.speculate.Speculator.EventType

attemptEnrolledTime(TaskAttemptId) - Method in class org.apache.hadoop.mapreduce.v2.app.speculate.NullTaskRuntimesEngine

attemptEnrolledTime(TaskAttemptId) - Method in class org.apache.hadoop.mapreduce.v2.app.speculate.ExponentiallySmoothedTaskRuntimeEstimator

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

ClassSerializationConfig - Class in org.apache.hadoop.mapreduce.v2.app.webapp.jsonprovider

ClassSerializationConfig() - Constructor for class org.apache.hadoop.mapreduce.v2.app.webapp.jsonprovider.ClassSerializationConfig

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

COMMIT_PENDING - Enum constant in enum class org.apache.hadoop.mapreduce.v2.app.job.TaskAttemptStateInternal

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 Class 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

COMMITTING - Enum constant in enum class org.apache.hadoop.mapreduce.v2.app.job.JobStateInternal

commonPreHead(Hamlet.HTML<HtmlPage.__>) - Method in class org.apache.hadoop.mapreduce.v2.app.webapp.AppView

compareTo(JVMId) - Method in class org.apache.hadoop.mapred.WrappedJvmID

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

configure() - Method in class org.apache.hadoop.mapreduce.v2.app.client.MRClientService

configure(FeatureContext) - Method in class org.apache.hadoop.mapreduce.v2.app.webapp.jsonprovider.JsonProviderFeature

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

CONTAINER_COMPLETED - Enum constant in enum class org.apache.hadoop.mapreduce.v2.app.launcher.ContainerLauncher.EventType

CONTAINER_DEALLOCATE - Enum constant in enum class org.apache.hadoop.mapreduce.v2.app.rm.ContainerAllocator.EventType

CONTAINER_FAILED - Enum constant in enum class org.apache.hadoop.mapreduce.v2.app.rm.ContainerAllocator.EventType

CONTAINER_REMOTE_CLEANUP - Enum constant in enum class org.apache.hadoop.mapreduce.v2.app.launcher.ContainerLauncher.EventType

CONTAINER_REMOTE_LAUNCH - Enum constant in enum class org.apache.hadoop.mapreduce.v2.app.launcher.ContainerLauncher.EventType

CONTAINER_REQ - Enum constant in enum class org.apache.hadoop.mapreduce.v2.app.rm.ContainerAllocator.EventType

ContainerAllocator - Interface in org.apache.hadoop.mapreduce.v2.app.rm

ContainerAllocator.EventType - Enum Class 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 Class 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 - Variable in class org.apache.hadoop.mapreduce.v2.app.speculate.ExponentiallySmoothedTaskRuntimeEstimator

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 class org.apache.hadoop.mapreduce.v2.app.speculate.LegacyTaskRuntimeEstimator

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

dataStatisticsForTask(TaskId) - Method in class org.apache.hadoop.mapreduce.v2.app.speculate.ExponentiallySmoothedTaskRuntimeEstimator

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, TaskRuntimeEstimator, Clock) - 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

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

doneTasks - Variable in class org.apache.hadoop.mapreduce.v2.app.speculate.ExponentiallySmoothedTaskRuntimeEstimator

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 class org.apache.hadoop.mapreduce.v2.app.speculate.ExponentiallySmoothedTaskRuntimeEstimator

enrollAttempt(TaskAttemptStatusUpdateEvent.TaskAttemptStatus, long) - Method in interface org.apache.hadoop.mapreduce.v2.app.speculate.TaskRuntimeEstimator

equals(Object) - Method in class org.apache.hadoop.mapred.WrappedJvmID

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

ERROR - Enum constant in enum class org.apache.hadoop.mapreduce.v2.app.job.JobStateInternal

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 class org.apache.hadoop.mapreduce.v2.app.speculate.ExponentiallySmoothedTaskRuntimeEstimator

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

ExcludeRootJSONProvider - Class in org.apache.hadoop.mapreduce.v2.app.webapp.jsonprovider

ExcludeRootJSONProvider() - Constructor for class org.apache.hadoop.mapreduce.v2.app.webapp.jsonprovider.ExcludeRootJSONProvider

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 Class in org.apache.hadoop.mapreduce.v2.app.speculate

extend(double, int) - Method in class org.apache.hadoop.mapred.WrappedPeriodicStatsAccumulator

F

FAIL_ABORT - Enum constant in enum class org.apache.hadoop.mapreduce.v2.app.job.JobStateInternal

FAIL_CONTAINER_CLEANUP - Enum constant in enum class org.apache.hadoop.mapreduce.v2.app.job.TaskAttemptStateInternal

FAIL_FINISHING_CONTAINER - Enum constant in enum class org.apache.hadoop.mapreduce.v2.app.job.TaskAttemptStateInternal

FAIL_TASK_CLEANUP - Enum constant in enum class org.apache.hadoop.mapreduce.v2.app.job.TaskAttemptStateInternal

FAIL_WAIT - Enum constant in enum class org.apache.hadoop.mapreduce.v2.app.job.JobStateInternal

FAILED - Enum constant in enum class org.apache.hadoop.mapreduce.v2.app.job.JobStateInternal

FAILED - Enum constant in enum class org.apache.hadoop.mapreduce.v2.app.job.TaskAttemptStateInternal

FAILED - Enum constant in enum class org.apache.hadoop.mapreduce.v2.app.job.TaskStateInternal

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

forName(String) - Static method in class org.apache.hadoop.mapred.WrappedJvmID

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.webapp.dao.TaskAttemptInfo

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

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.webapp.dao.AMAttemptInfo

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

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.webapp.dao.AMAttemptInfo

getContainerID() - Method in class org.apache.hadoop.mapreduce.v2.app.launcher.ContainerLauncherEvent

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.webapp.dao.JobInfo

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

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.mapred.WrappedJvmID

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

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

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() - Method in class org.apache.hadoop.mapreduce.v2.app.rm.RMCommunicator

getJob() - Method in class org.apache.hadoop.mapreduce.v2.app.webapp.App

getJob(HttpServletRequest, String) - Method in class org.apache.hadoop.mapreduce.v2.app.webapp.AMWebServices

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

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

getJobFromContainerIdString(String, AppContext) - Static method in class org.apache.hadoop.mapreduce.v2.app.webapp.AMWebServices

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.mapred.WrappedJvmID

getJobId() - Method in class org.apache.hadoop.mapreduce.jobhistory.JobSummary

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.jobhistory.JobHistoryEvent

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.speculate.SpeculatorEvent

getJobLaunchTime() - Method in class org.apache.hadoop.mapreduce.jobhistory.JobSummary

getJobName() - Method in class org.apache.hadoop.mapreduce.jobhistory.JobSummary

getJobs() - Method in class org.apache.hadoop.mapreduce.v2.app.webapp.dao.JobsInfo

getJobs(HttpServletRequest) - Method in class org.apache.hadoop.mapreduce.v2.app.webapp.AMWebServices

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() - Method in class org.apache.hadoop.mapreduce.v2.app.webapp.App

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

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() - Method in interface org.apache.hadoop.mapreduce.v2.app.job.Job

getTasks() - Method in class org.apache.hadoop.mapreduce.v2.app.webapp.dao.TasksInfo

getTasks(TaskType) - Method in class org.apache.hadoop.mapreduce.v2.app.job.impl.JobImpl

getTasks(TaskType) - Method in interface org.apache.hadoop.mapreduce.v2.app.job.Job

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

getUnWrappedClasses() - Method in class org.apache.hadoop.mapreduce.v2.app.webapp.jsonprovider.ClassSerializationConfig

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

getWebAppFilterClass() - Method in class org.apache.hadoop.mapreduce.v2.app.webapp.AMWebApp

getWrappedClasses() - Method in class org.apache.hadoop.mapreduce.v2.app.webapp.jsonprovider.ClassSerializationConfig

H

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.mapred.LocalContainerLauncher

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.mapred.WrappedJvmID

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

IncludeRootJSONProvider - Class in org.apache.hadoop.mapreduce.v2.app.webapp.jsonprovider

IncludeRootJSONProvider() - Constructor for class org.apache.hadoop.mapreduce.v2.app.webapp.jsonprovider.IncludeRootJSONProvider

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(Configuration) - Method in class org.apache.hadoop.mapreduce.v2.app.TaskAttemptFinishingMonitor

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

initAndStartAppMaster(MRAppMaster, JobConf, String) - Static method in class org.apache.hadoop.mapreduce.v2.app.MRAppMaster

INITED - Enum constant in enum class org.apache.hadoop.mapreduce.v2.app.job.JobStateInternal

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

INTERNAL_ERROR - Enum constant in enum class org.apache.hadoop.mapreduce.v2.app.job.event.JobEventType

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 - Variable in class org.apache.hadoop.mapreduce.v2.app.MRAppMaster

isLastAMRetry() - Method in interface org.apache.hadoop.mapreduce.v2.app.AppContext

isLastAMRetry() - Method in class org.apache.hadoop.mapreduce.v2.app.MRAppMaster

isLastAMRetry() - Method in class org.apache.hadoop.mapreduce.v2.app.MRAppMaster.RunningAppContext

isMapJVM() - Method in class org.apache.hadoop.mapred.WrappedJvmID

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

isReadable(Class<?>, Type, Annotation[], MediaType) - Method in class org.apache.hadoop.mapreduce.v2.app.webapp.jsonprovider.ExcludeRootJSONProvider

isReadable(Class<?>, Type, Annotation[], MediaType) - Method in class org.apache.hadoop.mapreduce.v2.app.webapp.jsonprovider.IncludeRootJSONProvider

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

isWriteable(Class<?>, Type, Annotation[], MediaType) - Method in class org.apache.hadoop.mapreduce.v2.app.webapp.jsonprovider.ExcludeRootJSONProvider

isWriteable(Class<?>, Type, Annotation[], MediaType) - Method in class org.apache.hadoop.mapreduce.v2.app.webapp.jsonprovider.IncludeRootJSONProvider

J

JAXBContextResolver - Class in org.apache.hadoop.mapreduce.v2.app.webapp

JAXBContextResolver() - Constructor for class org.apache.hadoop.mapreduce.v2.app.webapp.JAXBContextResolver

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() - Method in class org.apache.hadoop.mapreduce.v2.app.webapp.AppController

Render the /job page

Job - Interface in org.apache.hadoop.mapreduce.v2.app.job

Main interface to interact with the job.

JOB_ABORT - Enum constant in enum class org.apache.hadoop.mapreduce.v2.app.commit.CommitterEventType

JOB_ABORT_COMPLETED - Enum constant in enum class org.apache.hadoop.mapreduce.v2.app.job.event.JobEventType

JOB_ABORT_FILE_NAME - Static variable in class org.apache.hadoop.CustomOutputCommitter

JOB_AM_REBOOT - Enum constant in enum class org.apache.hadoop.mapreduce.v2.app.job.event.JobEventType

JOB_COMMIT - Enum constant in enum class org.apache.hadoop.mapreduce.v2.app.commit.CommitterEventType

JOB_COMMIT_COMPLETED - Enum constant in enum class org.apache.hadoop.mapreduce.v2.app.job.event.JobEventType

JOB_COMMIT_FAILED - Enum constant in enum class org.apache.hadoop.mapreduce.v2.app.job.event.JobEventType

JOB_COMMIT_FILE_NAME - Static variable in class org.apache.hadoop.CustomOutputCommitter

JOB_COMPLETED - Enum constant in enum class org.apache.hadoop.mapreduce.v2.app.job.event.JobEventType

JOB_COUNTER_UPDATE - Enum constant in enum class org.apache.hadoop.mapreduce.v2.app.job.event.JobEventType

JOB_CREATE - Enum constant in enum class org.apache.hadoop.mapreduce.v2.app.speculate.Speculator.EventType

JOB_DIAGNOSTIC_UPDATE - Enum constant in enum class org.apache.hadoop.mapreduce.v2.app.job.event.JobEventType

JOB_FAIL_WAIT_TIMEDOUT - Enum constant in enum class org.apache.hadoop.mapreduce.v2.app.job.event.JobEventType

JOB_ID - Static variable in interface org.apache.hadoop.mapreduce.v2.app.webapp.AMParams

JOB_INIT - Enum constant in enum class org.apache.hadoop.mapreduce.v2.app.job.event.JobEventType

JOB_INIT_FAILED - Enum constant in enum class org.apache.hadoop.mapreduce.v2.app.job.event.JobEventType

JOB_KILL - Enum constant in enum class org.apache.hadoop.mapreduce.v2.app.job.event.JobEventType

JOB_KILLED_DIAG - Static variable in class org.apache.hadoop.mapreduce.v2.app.job.impl.JobImpl

JOB_MAP_TASK_RESCHEDULED - Enum constant in enum class org.apache.hadoop.mapreduce.v2.app.job.event.JobEventType

JOB_SETUP - Enum constant in enum class org.apache.hadoop.mapreduce.v2.app.commit.CommitterEventType

JOB_SETUP_COMPLETED - Enum constant in enum class org.apache.hadoop.mapreduce.v2.app.job.event.JobEventType

JOB_SETUP_FAILED - Enum constant in enum class org.apache.hadoop.mapreduce.v2.app.job.event.JobEventType

JOB_SETUP_FILE_NAME - Static variable in class org.apache.hadoop.CustomOutputCommitter

JOB_START - Enum constant in enum class org.apache.hadoop.mapreduce.v2.app.job.event.JobEventType

JOB_TASK_ATTEMPT_COMPLETED - Enum constant in enum class org.apache.hadoop.mapreduce.v2.app.job.event.JobEventType

JOB_TASK_ATTEMPT_FETCH_FAILURE - Enum constant in enum class org.apache.hadoop.mapreduce.v2.app.job.event.JobEventType

JOB_TASK_COMPLETED - Enum constant in enum class org.apache.hadoop.mapreduce.v2.app.job.event.JobEventType

JOB_UPDATED_NODES - Enum constant in enum class org.apache.hadoop.mapreduce.v2.app.job.event.JobEventType

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 Class 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 Class 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 Class 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

JsonProviderFeature - Class in org.apache.hadoop.mapreduce.v2.app.webapp.jsonprovider

JsonProviderFeature() - Constructor for class org.apache.hadoop.mapreduce.v2.app.webapp.jsonprovider.JsonProviderFeature

K

keepJobFiles(JobConf, String) - Method in class org.apache.hadoop.mapreduce.v2.app.MRAppMaster

KILL_ABORT - Enum constant in enum class org.apache.hadoop.mapreduce.v2.app.job.JobStateInternal

KILL_CONTAINER_CLEANUP - Enum constant in enum class org.apache.hadoop.mapreduce.v2.app.job.TaskAttemptStateInternal

KILL_TASK_CLEANUP - Enum constant in enum class org.apache.hadoop.mapreduce.v2.app.job.TaskAttemptStateInternal

KILL_WAIT - Enum constant in enum class org.apache.hadoop.mapreduce.v2.app.job.JobStateInternal

KILL_WAIT - Enum constant in enum class org.apache.hadoop.mapreduce.v2.app.job.TaskStateInternal

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

KILLED - Enum constant in enum class org.apache.hadoop.mapreduce.v2.app.job.JobStateInternal

KILLED - Enum constant in enum class org.apache.hadoop.mapreduce.v2.app.job.TaskAttemptStateInternal

KILLED - Enum constant in enum class org.apache.hadoop.mapreduce.v2.app.job.TaskStateInternal

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

mapperStatistics - Variable in class org.apache.hadoop.mapreduce.v2.app.speculate.ExponentiallySmoothedTaskRuntimeEstimator

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. 1.96 is standard for 95 %

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

NEW - Enum constant in enum class org.apache.hadoop.mapreduce.v2.app.job.JobStateInternal

NEW - Enum constant in enum class org.apache.hadoop.mapreduce.v2.app.job.TaskAttemptStateInternal

NEW - Enum constant in enum class org.apache.hadoop.mapreduce.v2.app.job.TaskStateInternal

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

org.apache.hadoop.mapreduce.v2.app.webapp.jsonprovider - package org.apache.hadoop.mapreduce.v2.app.webapp.jsonprovider

Jersey2 JSON provider classes for the MapReduce Application web UI.

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. requests for resources to return to the cluster.

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

preReadFrom(Class<Object>, Type, Annotation[], MediaType, MultivaluedMap<String, String>, Unmarshaller) - Method in class org.apache.hadoop.mapreduce.v2.app.webapp.jsonprovider.ExcludeRootJSONProvider

preReadFrom(Class<Object>, Type, Annotation[], MediaType, MultivaluedMap<String, String>, Unmarshaller) - Method in class org.apache.hadoop.mapreduce.v2.app.webapp.jsonprovider.IncludeRootJSONProvider

preWriteTo(Object, Class<?>, Type, Annotation[], MediaType, MultivaluedMap<String, Object>, Marshaller) - Method in class org.apache.hadoop.mapreduce.v2.app.webapp.jsonprovider.ExcludeRootJSONProvider

preWriteTo(Object, Class<?>, Type, Annotation[], MediaType, MultivaluedMap<String, Object>, Marshaller) - Method in class org.apache.hadoop.mapreduce.v2.app.webapp.jsonprovider.IncludeRootJSONProvider

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

RATE - Enum constant in enum class org.apache.hadoop.mapreduce.v2.app.speculate.ExponentiallySmoothedTaskRuntimeEstimator.SmoothedValue

readFields(DataInput) - Method in class org.apache.hadoop.mapred.WrappedJvmID

REBOOT - Enum constant in enum class org.apache.hadoop.mapreduce.v2.app.job.JobStateInternal

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

reducerStatistics - Variable in class org.apache.hadoop.mapreduce.v2.app.speculate.ExponentiallySmoothedTaskRuntimeEstimator

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(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

RMContainerAllocationException(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

RUNNING - Enum constant in enum class org.apache.hadoop.mapreduce.v2.app.job.JobStateInternal

RUNNING - Enum constant in enum class org.apache.hadoop.mapreduce.v2.app.job.TaskAttemptStateInternal

RUNNING - Enum constant in enum class org.apache.hadoop.mapreduce.v2.app.job.TaskStateInternal

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

SCHEDULED - Enum constant in enum class org.apache.hadoop.mapreduce.v2.app.job.TaskStateInternal

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() - Method in class org.apache.hadoop.mapreduce.v2.app.webapp.AMWebApp

setup(JobImpl) - Method in class org.apache.hadoop.mapreduce.v2.app.job.impl.JobImpl.InitTransition

SETUP - Enum constant in enum class org.apache.hadoop.mapreduce.v2.app.job.JobStateInternal

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 Class 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(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

SpeculatorEvent(TaskAttemptStatusUpdateEvent.TaskAttemptStatus, long) - 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

startTimes - Variable in class org.apache.hadoop.mapreduce.v2.app.speculate.ExponentiallySmoothedTaskRuntimeEstimator

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

STATE_CHANGED - Enum constant in enum class org.apache.hadoop.mapreduce.v2.app.job.event.JobFinishEvent.Type

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

SUCCEEDED - Enum constant in enum class org.apache.hadoop.mapreduce.v2.app.job.JobStateInternal

SUCCEEDED - Enum constant in enum class org.apache.hadoop.mapreduce.v2.app.job.TaskAttemptStateInternal

SUCCEEDED - Enum constant in enum class org.apache.hadoop.mapreduce.v2.app.job.TaskStateInternal

SUCCESS_CONTAINER_CLEANUP - Enum constant in enum class org.apache.hadoop.mapreduce.v2.app.job.TaskAttemptStateInternal

SUCCESS_FINISHING_CONTAINER - Enum constant in enum class org.apache.hadoop.mapreduce.v2.app.job.TaskAttemptStateInternal

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

T_ADD_SPEC_ATTEMPT - Enum constant in enum class org.apache.hadoop.mapreduce.v2.app.job.event.TaskEventType

T_ATTEMPT_COMMIT_PENDING - Enum constant in enum class org.apache.hadoop.mapreduce.v2.app.job.event.TaskEventType

T_ATTEMPT_FAILED - Enum constant in enum class org.apache.hadoop.mapreduce.v2.app.job.event.TaskEventType

T_ATTEMPT_KILLED - Enum constant in enum class org.apache.hadoop.mapreduce.v2.app.job.event.TaskEventType

T_ATTEMPT_LAUNCHED - Enum constant in enum class org.apache.hadoop.mapreduce.v2.app.job.event.TaskEventType

T_ATTEMPT_SUCCEEDED - Enum constant in enum class org.apache.hadoop.mapreduce.v2.app.job.event.TaskEventType

T_KILL - Enum constant in enum class org.apache.hadoop.mapreduce.v2.app.job.event.TaskEventType

T_RECOVER - Enum constant in enum class org.apache.hadoop.mapreduce.v2.app.job.event.TaskEventType

T_SCHEDULE - Enum constant in enum class org.apache.hadoop.mapreduce.v2.app.job.event.TaskEventType

TA_ASSIGNED - Enum constant in enum class org.apache.hadoop.mapreduce.v2.app.job.event.TaskAttemptEventType

TA_CLEANUP_DONE - Enum constant in enum class org.apache.hadoop.mapreduce.v2.app.job.event.TaskAttemptEventType

TA_COMMIT_PENDING - Enum constant in enum class org.apache.hadoop.mapreduce.v2.app.job.event.TaskAttemptEventType

TA_CONTAINER_CLEANED - Enum constant in enum class org.apache.hadoop.mapreduce.v2.app.job.event.TaskAttemptEventType

TA_CONTAINER_COMPLETED - Enum constant in enum class org.apache.hadoop.mapreduce.v2.app.job.event.TaskAttemptEventType

TA_CONTAINER_LAUNCH_FAILED - Enum constant in enum class org.apache.hadoop.mapreduce.v2.app.job.event.TaskAttemptEventType

TA_CONTAINER_LAUNCHED - Enum constant in enum class org.apache.hadoop.mapreduce.v2.app.job.event.TaskAttemptEventType

TA_DIAGNOSTICS_UPDATE - Enum constant in enum class org.apache.hadoop.mapreduce.v2.app.job.event.TaskAttemptEventType

TA_DONE - Enum constant in enum class org.apache.hadoop.mapreduce.v2.app.job.event.TaskAttemptEventType

TA_FAILMSG - Enum constant in enum class org.apache.hadoop.mapreduce.v2.app.job.event.TaskAttemptEventType

TA_FAILMSG_BY_CLIENT - Enum constant in enum class org.apache.hadoop.mapreduce.v2.app.job.event.TaskAttemptEventType

TA_KILL - Enum constant in enum class org.apache.hadoop.mapreduce.v2.app.job.event.TaskAttemptEventType

TA_PREEMPTED - Enum constant in enum class org.apache.hadoop.mapreduce.v2.app.job.event.TaskAttemptEventType

TA_RECOVER - Enum constant in enum class org.apache.hadoop.mapreduce.v2.app.job.event.TaskAttemptEventType

TA_RESCHEDULE - Enum constant in enum class org.apache.hadoop.mapreduce.v2.app.job.event.TaskAttemptEventType

TA_SCHEDULE - Enum constant in enum class org.apache.hadoop.mapreduce.v2.app.job.event.TaskAttemptEventType

TA_TIMED_OUT - Enum constant in enum class org.apache.hadoop.mapreduce.v2.app.job.event.TaskAttemptEventType

TA_TOO_MANY_FETCH_FAILURE - Enum constant in enum class org.apache.hadoop.mapreduce.v2.app.job.event.TaskAttemptEventType

TA_UPDATE - Enum constant in enum class org.apache.hadoop.mapreduce.v2.app.job.event.TaskAttemptEventType

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() - Method in class org.apache.hadoop.mapreduce.v2.app.webapp.AppController

Render the /task page

Task - Interface in org.apache.hadoop.mapreduce.v2.app.job

Read only view of Task.

TASK_ABORT - Enum constant in enum class org.apache.hadoop.mapreduce.v2.app.commit.CommitterEventType

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_CONTAINER_NEED_UPDATE - Enum constant in enum class org.apache.hadoop.mapreduce.v2.app.speculate.Speculator.EventType

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 Class 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) - Constructor for class org.apache.hadoop.mapreduce.v2.app.job.event.TaskAttemptKillEvent

TaskAttemptKillEvent(TaskAttemptId, String, boolean) - 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 Class 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 Class 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 Class 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 class org.apache.hadoop.mapreduce.v2.app.speculate.ExponentiallySmoothedTaskRuntimeEstimator

thresholdRuntime(TaskId) - Method in interface org.apache.hadoop.mapreduce.v2.app.speculate.TaskRuntimeEstimator

Find a maximum reasonable execution wallclock time.

TIME_PER_UNIT_PROGRESS - Enum constant in enum class org.apache.hadoop.mapreduce.v2.app.speculate.ExponentiallySmoothedTaskRuntimeEstimator.SmoothedValue

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.mapred.WrappedJvmID

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

UNASSIGNED - Enum constant in enum class org.apache.hadoop.mapreduce.v2.app.job.TaskAttemptStateInternal

unregister() - Method in class org.apache.hadoop.mapreduce.v2.app.rm.RMCommunicator

unregister(TaskAttemptId) - Method in class org.apache.hadoop.mapreduce.v2.app.TaskHeartbeatHandler

unregister(TaskAttemptId, WrappedJvmID) - Method in class org.apache.hadoop.mapred.TaskAttemptListenerImpl

unregister(TaskAttemptId, WrappedJvmID) - Method in interface org.apache.hadoop.mapreduce.v2.app.TaskAttemptListener

Unregister the JVM and the attempt associated with it.

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 class org.apache.hadoop.mapreduce.v2.app.commit.CommitterEventType

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

valueOf(String) - Static method in enum class org.apache.hadoop.mapreduce.v2.app.job.event.JobEventType

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

valueOf(String) - Static method in enum class org.apache.hadoop.mapreduce.v2.app.job.event.JobFinishEvent.Type

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

valueOf(String) - Static method in enum class org.apache.hadoop.mapreduce.v2.app.job.event.TaskAttemptEventType

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

valueOf(String) - Static method in enum class org.apache.hadoop.mapreduce.v2.app.job.event.TaskEventType

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

valueOf(String) - Static method in enum class org.apache.hadoop.mapreduce.v2.app.job.JobStateInternal

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

valueOf(String) - Static method in enum class org.apache.hadoop.mapreduce.v2.app.job.TaskAttemptStateInternal

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

valueOf(String) - Static method in enum class org.apache.hadoop.mapreduce.v2.app.job.TaskStateInternal

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

valueOf(String) - Static method in enum class org.apache.hadoop.mapreduce.v2.app.launcher.ContainerLauncher.EventType

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

valueOf(String) - Static method in enum class org.apache.hadoop.mapreduce.v2.app.rm.ContainerAllocator.EventType

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

valueOf(String) - Static method in enum class org.apache.hadoop.mapreduce.v2.app.speculate.ExponentiallySmoothedTaskRuntimeEstimator.SmoothedValue

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

valueOf(String) - Static method in enum class org.apache.hadoop.mapreduce.v2.app.speculate.Speculator.EventType

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

values - Variable in class org.apache.hadoop.mapreduce.v2.app.webapp.SingleCounterBlock

values() - Static method in enum class org.apache.hadoop.mapreduce.v2.app.commit.CommitterEventType

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

values() - Static method in enum class org.apache.hadoop.mapreduce.v2.app.job.event.JobEventType

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

values() - Static method in enum class org.apache.hadoop.mapreduce.v2.app.job.event.JobFinishEvent.Type

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

values() - Static method in enum class org.apache.hadoop.mapreduce.v2.app.job.event.TaskAttemptEventType

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

values() - Static method in enum class org.apache.hadoop.mapreduce.v2.app.job.event.TaskEventType

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

values() - Static method in enum class org.apache.hadoop.mapreduce.v2.app.job.JobStateInternal

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

values() - Static method in enum class org.apache.hadoop.mapreduce.v2.app.job.TaskAttemptStateInternal

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

values() - Static method in enum class org.apache.hadoop.mapreduce.v2.app.job.TaskStateInternal

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

values() - Static method in enum class org.apache.hadoop.mapreduce.v2.app.launcher.ContainerLauncher.EventType

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

values() - Static method in enum class org.apache.hadoop.mapreduce.v2.app.rm.ContainerAllocator.EventType

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

values() - Static method in enum class org.apache.hadoop.mapreduce.v2.app.speculate.ExponentiallySmoothedTaskRuntimeEstimator.SmoothedValue

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

values() - Static method in enum class org.apache.hadoop.mapreduce.v2.app.speculate.Speculator.EventType

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

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

write(DataOutput) - Method in class org.apache.hadoop.mapred.WrappedJvmID

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
All Classes and Interfaces|All Packages|Constant Field Values|Serialized Form