Constructor and Description |
---|
MapTaskAttemptImpl(TaskId taskId,
int attempt,
EventHandler eventHandler,
Path jobFile,
int partition,
JobSplit.TaskSplitMetaInfo splitInfo,
JobConf conf,
TaskAttemptListener taskAttemptListener,
Token<JobTokenIdentifier> jobToken,
Credentials credentials,
Clock clock,
AppContext appContext) |
ReduceTaskAttemptImpl(TaskId id,
int attempt,
EventHandler eventHandler,
Path jobFile,
int partition,
int numMapTasks,
JobConf conf,
TaskAttemptListener taskAttemptListener,
Token<JobTokenIdentifier> jobToken,
Credentials credentials,
Clock clock,
AppContext appContext) |
Modifier and Type | Class and Description |
---|---|
class |
ControlledClock |
Modifier and Type | Method and Description |
---|---|
Clock |
AppContext.getClock() |
Clock |
MRAppMaster.RunningAppContext.getClock() |
Constructor and Description |
---|
ControlledClock(Clock actualClock) |
MRAppMaster(ApplicationAttemptId applicationAttemptId,
ContainerId containerId,
String nmHost,
int nmPort,
int nmHttpPort,
Clock clock,
long appSubmitTime,
int maxAppAttempts) |
TaskHeartbeatHandler(EventHandler eventHandler,
Clock clock,
int numThreads) |
Modifier and Type | Field and Description |
---|---|
protected Clock |
TaskImpl.clock |
Constructor and Description |
---|
JobImpl(JobId jobId,
ApplicationAttemptId applicationAttemptId,
Configuration conf,
EventHandler eventHandler,
TaskAttemptListener taskAttemptListener,
JobTokenSecretManager jobTokenSecretManager,
Credentials jobCredentials,
Clock clock,
Map<TaskId,JobHistoryParser.TaskInfo> completedTasksFromPreviousRun,
MRAppMetrics metrics,
OutputCommitter committer,
boolean newApiCommitter,
String userName,
long appSubmitTime,
List<AMInfo> amInfos,
AppContext appContext,
JobStateInternal forcedState,
String forcedDiagnostic) |
MapTaskImpl(JobId jobId,
int partition,
EventHandler eventHandler,
Path remoteJobConfFile,
JobConf conf,
JobSplit.TaskSplitMetaInfo taskSplitMetaInfo,
TaskAttemptListener taskAttemptListener,
Token<JobTokenIdentifier> jobToken,
Credentials credentials,
Clock clock,
int appAttemptId,
MRAppMetrics metrics,
AppContext appContext) |
ReduceTaskImpl(JobId jobId,
int partition,
EventHandler eventHandler,
Path jobFile,
JobConf conf,
int numMapTasks,
TaskAttemptListener taskAttemptListener,
Token<JobTokenIdentifier> jobToken,
Credentials credentials,
Clock clock,
int appAttemptId,
MRAppMetrics metrics,
AppContext appContext) |
TaskAttemptImpl(TaskId taskId,
int i,
EventHandler eventHandler,
TaskAttemptListener taskAttemptListener,
Path jobFile,
int partition,
JobConf conf,
String[] dataLocalHosts,
Token<JobTokenIdentifier> jobToken,
Credentials credentials,
Clock clock,
AppContext appContext) |
TaskImpl(JobId jobId,
TaskType taskType,
int partition,
EventHandler eventHandler,
Path remoteJobConfFile,
JobConf conf,
TaskAttemptListener taskAttemptListener,
Token<JobTokenIdentifier> jobToken,
Credentials credentials,
Clock clock,
int appAttemptId,
MRAppMetrics metrics,
AppContext appContext) |
Constructor and Description |
---|
DefaultSpeculator(Configuration conf,
AppContext context,
Clock clock) |
DefaultSpeculator(Configuration conf,
AppContext context,
TaskRuntimeEstimator estimator,
Clock clock) |
Modifier and Type | Method and Description |
---|---|
Clock |
JobHistory.getClock() |
Constructor and Description |
---|
ProportionalCapacityPreemptionPolicy(Configuration config,
EventHandler<ContainerPreemptEvent> dispatcher,
CapacityScheduler scheduler,
Clock clock) |
Modifier and Type | Method and Description |
---|---|
Clock |
FairScheduler.getClock() |
Modifier and Type | Method and Description |
---|---|
protected void |
FairScheduler.setClock(Clock clock) |
Modifier and Type | Class and Description |
---|---|
class |
SystemClock
Implementation of
Clock that gives the current time from the system
clock in milliseconds. |
Constructor and Description |
---|
AbstractLivelinessMonitor(String name,
Clock clock) |
Copyright © 2013 Apache Software Foundation. All rights reserved.