Modifier and Type | Method and Description |
---|---|
ApplicationAttemptId |
AMStartedEvent.getAppAttemptId() |
ApplicationAttemptId |
JobHistoryParser.AMInfo.getAppAttemptId() |
Modifier and Type | Method and Description |
---|---|
static FSDataInputStream |
JobHistoryCopyService.getPreviousJobHistoryFileStream(Configuration conf,
ApplicationAttemptId applicationAttemptId) |
Constructor and Description |
---|
AMStartedEvent(ApplicationAttemptId appAttemptId,
long startTime,
ContainerId containerId,
String nodeManagerHost,
int nodeManagerPort,
int nodeManagerHttpPort)
Create an event to record the start of an MR AppMaster
|
JobHistoryCopyService(ApplicationAttemptId applicationAttemptId,
EventHandler handler) |
JobHistoryParser.AMInfo(ApplicationAttemptId appAttemptId,
long startTime,
ContainerId containerId,
String nodeManagerHost,
int nodeManagerPort,
int nodeManagerHttpPort) |
Modifier and Type | Method and Description |
---|---|
ApplicationAttemptId |
AMInfo.getAppAttemptId() |
Modifier and Type | Method and Description |
---|---|
void |
AMInfo.setAppAttemptId(ApplicationAttemptId appAttemptId) |
Modifier and Type | Method and Description |
---|---|
ApplicationAttemptId |
AMInfoPBImpl.getAppAttemptId() |
Modifier and Type | Method and Description |
---|---|
void |
AMInfoPBImpl.setAppAttemptId(ApplicationAttemptId appAttemptId) |
Modifier and Type | Method and Description |
---|---|
ApplicationAttemptId |
AppContext.getApplicationAttemptId() |
ApplicationAttemptId |
MRAppMaster.RunningAppContext.getApplicationAttemptId() |
ApplicationAttemptId |
MRAppMaster.getAttemptID() |
Constructor and Description |
---|
MRAppMaster(ApplicationAttemptId applicationAttemptId,
ContainerId containerId,
String nmHost,
int nmPort,
int nmHttpPort,
Clock clock,
long appSubmitTime,
int maxAppAttempts) |
MRAppMaster(ApplicationAttemptId applicationAttemptId,
ContainerId containerId,
String nmHost,
int nmPort,
int nmHttpPort,
long appSubmitTime,
int maxAppAttempts) |
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) |
Modifier and Type | Method and Description |
---|---|
ApplicationAttemptId |
JobHistory.getApplicationAttemptId() |
Modifier and Type | Method and Description |
---|---|
static Path |
JobHistoryUtils.getPreviousJobHistoryPath(Configuration conf,
ApplicationAttemptId applicationAttemptId) |
Modifier and Type | Method and Description |
---|---|
static AMInfo |
MRBuilderUtils.newAMInfo(ApplicationAttemptId appAttemptId,
long startTime,
ContainerId containerId,
String nmHost,
int nmPort,
int nmHttpPort) |
Modifier and Type | Method and Description |
---|---|
abstract ApplicationAttemptId |
ContainerId.getApplicationAttemptId()
Get the
ApplicationAttemptId of the application to which
the Container was assigned. |
abstract ApplicationAttemptId |
ApplicationReport.getCurrentApplicationAttemptId()
Get the
ApplicationAttemptId of the current
attempt of the application |
static ApplicationAttemptId |
ApplicationAttemptId.newInstance(ApplicationId appId,
int attemptId) |
Modifier and Type | Method and Description |
---|---|
int |
ApplicationAttemptId.compareTo(ApplicationAttemptId other) |
static ContainerId |
ContainerId.newInstance(ApplicationAttemptId appAttemptId,
int containerId) |
static ApplicationReport |
ApplicationReport.newInstance(ApplicationId applicationId,
ApplicationAttemptId applicationAttemptId,
String user,
String queue,
String name,
String host,
int rpcPort,
Token clientToAMToken,
YarnApplicationState state,
String diagnostics,
String url,
long startTime,
long finishTime,
FinalApplicationStatus finalStatus,
ApplicationResourceUsageReport appResources,
String origTrackingUrl,
float progress,
String applicationType,
Token amRmToken) |
protected abstract void |
ContainerId.setApplicationAttemptId(ApplicationAttemptId atId) |
abstract void |
ApplicationReport.setCurrentApplicationAttemptId(ApplicationAttemptId applicationAttemptId) |
Modifier and Type | Class and Description |
---|---|
class |
ApplicationAttemptIdPBImpl |
Modifier and Type | Method and Description |
---|---|
ApplicationAttemptId |
ContainerIdPBImpl.getApplicationAttemptId() |
ApplicationAttemptId |
ApplicationReportPBImpl.getCurrentApplicationAttemptId() |
Modifier and Type | Method and Description |
---|---|
protected void |
ContainerIdPBImpl.setApplicationAttemptId(ApplicationAttemptId atId) |
void |
ApplicationReportPBImpl.setCurrentApplicationAttemptId(ApplicationAttemptId applicationAttemptId) |
Modifier and Type | Method and Description |
---|---|
void |
UnmanagedAMLauncher.launchAM(ApplicationAttemptId attemptId) |
Modifier and Type | Method and Description |
---|---|
ApplicationAttemptId |
NMTokenIdentifier.getApplicationAttemptId() |
ApplicationAttemptId |
AMRMTokenIdentifier.getApplicationAttemptId() |
Constructor and Description |
---|
AMRMTokenIdentifier(ApplicationAttemptId appAttemptId) |
NMTokenIdentifier(ApplicationAttemptId appAttemptId,
NodeId nodeId,
String applicationSubmitter,
int masterKeyId) |
Modifier and Type | Method and Description |
---|---|
ApplicationAttemptId |
ClientToAMTokenIdentifier.getApplicationAttemptID() |
Modifier and Type | Method and Description |
---|---|
SecretKey |
ClientToAMTokenSecretManager.getMasterKey(ApplicationAttemptId applicationAttemptID) |
abstract SecretKey |
BaseClientToAMTokenSecretManager.getMasterKey(ApplicationAttemptId applicationAttemptId) |
Constructor and Description |
---|
ClientToAMTokenIdentifier(ApplicationAttemptId id,
String client) |
ClientToAMTokenSecretManager(ApplicationAttemptId applicationAttemptID,
byte[] key) |
Modifier and Type | Method and Description |
---|---|
boolean |
NMTokenSecretManagerInNM.isAppAttemptNMTokenKeyPresent(ApplicationAttemptId appAttemptId) |
Modifier and Type | Method and Description |
---|---|
boolean |
ApplicationMasterService.hasApplicationMasterRegistered(ApplicationAttemptId appAttemptId) |
static void |
RMAuditLogger.logFailure(String user,
String operation,
String perm,
String target,
String description,
ApplicationId appId,
ApplicationAttemptId attemptId)
Create a readable and parseable audit log string for a failed event.
|
static void |
RMAuditLogger.logSuccess(String user,
String operation,
String target,
ApplicationId appId,
ApplicationAttemptId attemptId)
Create a readable and parseable audit log string for a successful event.
|
void |
ApplicationMasterService.registerAppAttempt(ApplicationAttemptId attemptId) |
void |
ApplicationMasterService.unregisterAttempt(ApplicationAttemptId attemptId) |
static void |
RMServerUtils.validateContainerReleaseRequest(List<ContainerId> containerReleaseList,
ApplicationAttemptId appAttemptId)
It will validate to make sure all the containers belong to correct
application attempt id.
|
Modifier and Type | Method and Description |
---|---|
ApplicationAttemptId |
RMStateStore.ApplicationAttemptState.getAttemptId() |
Modifier and Type | Method and Description |
---|---|
RMStateStore.ApplicationAttemptState |
RMStateStore.ApplicationState.getAttempt(ApplicationAttemptId attemptId) |
Constructor and Description |
---|
RMStateStore.ApplicationAttemptState(ApplicationAttemptId attemptId,
Container masterContainer,
Credentials appAttemptCredentials) |
Modifier and Type | Method and Description |
---|---|
ApplicationAttemptId |
ApplicationAttemptStateData.getAttemptId()
The ApplicationAttemptId for the application attempt
|
Modifier and Type | Method and Description |
---|---|
void |
ApplicationAttemptStateData.setAttemptId(ApplicationAttemptId attemptId) |
Modifier and Type | Method and Description |
---|---|
ApplicationAttemptId |
ApplicationAttemptStateDataPBImpl.getAttemptId() |
Modifier and Type | Method and Description |
---|---|
static ApplicationAttemptStateData |
ApplicationAttemptStateDataPBImpl.newApplicationAttemptStateData(ApplicationAttemptId attemptId,
Container container,
ByteBuffer attemptTokens) |
void |
ApplicationAttemptStateDataPBImpl.setAttemptId(ApplicationAttemptId attemptId) |
Modifier and Type | Method and Description |
---|---|
Map<ApplicationAttemptId,RMAppAttempt> |
RMApp.getAppAttempts()
RMApp can have multiple application attempts RMAppAttempt . |
Map<ApplicationAttemptId,RMAppAttempt> |
RMAppImpl.getAppAttempts() |
Modifier and Type | Method and Description |
---|---|
RMAppAttempt |
RMApp.getRMAppAttempt(ApplicationAttemptId appAttemptId)
RMApp can have multiple application attempts RMAppAttempt . |
RMAppAttempt |
RMAppImpl.getRMAppAttempt(ApplicationAttemptId appAttemptId) |
Modifier and Type | Method and Description |
---|---|
ApplicationAttemptId |
RMAppAttempt.getAppAttemptId()
Get the application attempt id for this
RMAppAttempt . |
ApplicationAttemptId |
RMAppAttemptImpl.getAppAttemptId() |
ApplicationAttemptId |
RMAppAttemptEvent.getApplicationAttemptId() |
Modifier and Type | Method and Description |
---|---|
protected void |
AMLivelinessMonitor.expire(ApplicationAttemptId id) |
Constructor and Description |
---|
RMAppAttemptEvent(ApplicationAttemptId appAttemptId,
RMAppAttemptEventType type) |
RMAppAttemptImpl(ApplicationAttemptId appAttemptId,
RMContext rmContext,
YarnScheduler scheduler,
ApplicationMasterService masterService,
ApplicationSubmissionContext submissionContext,
Configuration conf,
String user) |
Modifier and Type | Method and Description |
---|---|
ApplicationAttemptId |
RMContainerImpl.getApplicationAttemptId() |
ApplicationAttemptId |
RMContainer.getApplicationAttemptId() |
Constructor and Description |
---|
RMContainerImpl(Container container,
ApplicationAttemptId appAttemptId,
NodeId nodeId,
EventHandler handler,
ContainerAllocationExpirer containerAllocationExpirer) |
Modifier and Type | Method and Description |
---|---|
ApplicationAttemptId |
ContainerPreemptEvent.getAppId() |
abstract ApplicationAttemptId |
SchedulerApplication.getApplicationAttemptId()
Get
ApplicationAttemptId of the application master. |
ApplicationAttemptId |
AppSchedulingInfo.getApplicationAttemptId() |
Modifier and Type | Method and Description |
---|---|
Allocation |
YarnScheduler.allocate(ApplicationAttemptId appAttemptId,
List<ResourceRequest> ask,
List<ContainerId> release,
List<String> blacklistAdditions,
List<String> blacklistRemovals)
The main api between the ApplicationMaster and the Scheduler.
|
SchedulerAppReport |
YarnScheduler.getSchedulerAppInfo(ApplicationAttemptId appAttemptId)
Get the Scheduler app for a given app attempt Id.
|
void |
PreemptableResourceScheduler.preemptContainer(ApplicationAttemptId aid,
RMContainer container)
Ask the scheduler to obtain back the container from a specific application
by issuing a preemption request
|
Constructor and Description |
---|
AppSchedulingInfo(ApplicationAttemptId appAttemptId,
String user,
Queue queue,
ActiveUsersManager activeUsersManager) |
ContainerPreemptEvent(ApplicationAttemptId aid,
RMContainer container,
ContainerPreemptEventType type) |
Modifier and Type | Field and Description |
---|---|
protected Map<ApplicationAttemptId,FiCaSchedulerApp> |
CapacityScheduler.applications |
Modifier and Type | Method and Description |
---|---|
Allocation |
CapacityScheduler.allocate(ApplicationAttemptId applicationAttemptId,
List<ResourceRequest> ask,
List<ContainerId> release,
List<String> blacklistAdditions,
List<String> blacklistRemovals) |
SchedulerAppReport |
CapacityScheduler.getSchedulerAppInfo(ApplicationAttemptId applicationAttemptId) |
void |
CapacityScheduler.preemptContainer(ApplicationAttemptId aid,
RMContainer cont) |
Modifier and Type | Method and Description |
---|---|
ApplicationAttemptId |
FiCaSchedulerApp.getApplicationAttemptId() |
Constructor and Description |
---|
FiCaSchedulerApp(ApplicationAttemptId applicationAttemptId,
String user,
Queue queue,
ActiveUsersManager activeUsersManager,
RMContext rmContext) |
Modifier and Type | Method and Description |
---|---|
ApplicationAttemptId |
AppAddedSchedulerEvent.getApplicationAttemptId() |
ApplicationAttemptId |
AppRemovedSchedulerEvent.getApplicationAttemptID() |
Constructor and Description |
---|
AppAddedSchedulerEvent(ApplicationAttemptId applicationAttemptId,
String queue,
String user) |
AppRemovedSchedulerEvent(ApplicationAttemptId applicationAttemptId,
RMAppAttemptState finalAttemptState) |
Modifier and Type | Field and Description |
---|---|
protected Map<ApplicationAttemptId,FSSchedulerApp> |
FairScheduler.applications |
Modifier and Type | Method and Description |
---|---|
ApplicationAttemptId |
FSSchedulerApp.getApplicationAttemptId() |
Modifier and Type | Method and Description |
---|---|
protected void |
FairScheduler.addApplication(ApplicationAttemptId applicationAttemptId,
String queueName,
String user)
Add a new application to the scheduler, with a given id, queue name, and
user.
|
Allocation |
FairScheduler.allocate(ApplicationAttemptId appAttemptId,
List<ResourceRequest> ask,
List<ContainerId> release,
List<String> blacklistAdditions,
List<String> blacklistRemovals) |
FSSchedulerApp |
FairScheduler.getSchedulerApp(ApplicationAttemptId appAttemptId) |
SchedulerAppReport |
FairScheduler.getSchedulerAppInfo(ApplicationAttemptId appAttemptId) |
Constructor and Description |
---|
FSSchedulerApp(ApplicationAttemptId applicationAttemptId,
String user,
Queue queue,
ActiveUsersManager activeUsersManager,
RMContext rmContext) |
Modifier and Type | Field and Description |
---|---|
protected Map<ApplicationAttemptId,FiCaSchedulerApp> |
FifoScheduler.applications |
Modifier and Type | Method and Description |
---|---|
Allocation |
FifoScheduler.allocate(ApplicationAttemptId applicationAttemptId,
List<ResourceRequest> ask,
List<ContainerId> release,
List<String> blacklistAdditions,
List<String> blacklistRemovals) |
SchedulerAppReport |
FifoScheduler.getSchedulerAppInfo(ApplicationAttemptId applicationAttemptId) |
Modifier and Type | Method and Description |
---|---|
void |
AMRMTokenSecretManager.applicationMasterFinished(ApplicationAttemptId appAttemptId) |
List<NMToken> |
NMTokenSecretManagerInRM.createAndGetNMTokens(String applicationSubmitter,
ApplicationAttemptId appAttemptId,
List<Container> containers) |
SecretKey |
ClientToAMTokenSecretManagerInRM.createMasterKey(ApplicationAttemptId applicationAttemptID) |
SecretKey |
ClientToAMTokenSecretManagerInRM.getMasterKey(ApplicationAttemptId applicationAttemptID) |
boolean |
NMTokenSecretManagerInRM.isApplicationAttemptNMTokenPresent(ApplicationAttemptId appAttemptId,
NodeId nodeId) |
boolean |
NMTokenSecretManagerInRM.isApplicationAttemptRegistered(ApplicationAttemptId appAttemptId) |
void |
ClientToAMTokenSecretManagerInRM.registerApplication(ApplicationAttemptId applicationAttemptID,
SecretKey key) |
void |
NMTokenSecretManagerInRM.registerApplicationAttempt(ApplicationAttemptId appAttemptId) |
SecretKey |
ClientToAMTokenSecretManagerInRM.registerMasterKey(ApplicationAttemptId applicationAttemptID,
byte[] keyData) |
void |
ClientToAMTokenSecretManagerInRM.unRegisterApplication(ApplicationAttemptId applicationAttemptID) |
void |
NMTokenSecretManagerInRM.unregisterApplicationAttempt(ApplicationAttemptId appAttemptId) |
Modifier and Type | Method and Description |
---|---|
int |
FairSchedulerInfo.getAppFairShare(ApplicationAttemptId appAttemptId) |
Modifier and Type | Method and Description |
---|---|
Token |
BaseNMTokenSecretManager.createNMToken(ApplicationAttemptId applicationAttemptId,
NodeId nodeId,
String applicationSubmitter)
Helper function for creating NMTokens.
|
Modifier and Type | Method and Description |
---|---|
static ApplicationAttemptId |
BuilderUtils.newApplicationAttemptId(ApplicationId appId,
int attemptId) |
Modifier and Type | Method and Description |
---|---|
static ApplicationReport |
BuilderUtils.newApplicationReport(ApplicationId applicationId,
ApplicationAttemptId applicationAttemptId,
String user,
String queue,
String name,
String host,
int rpcPort,
Token clientToAMToken,
YarnApplicationState state,
String diagnostics,
String url,
long startTime,
long finishTime,
FinalApplicationStatus finalStatus,
ApplicationResourceUsageReport appResources,
String origTrackingUrl,
float progress,
String appType,
Token amRmToken) |
static ContainerId |
BuilderUtils.newContainerId(ApplicationAttemptId appAttemptId,
int containerId) |
static ContainerId |
BuilderUtils.newContainerId(RecordFactory recordFactory,
ApplicationId appId,
ApplicationAttemptId appAttemptId,
int containerId) |
Modifier and Type | Method and Description |
---|---|
static ApplicationAttemptId |
ConverterUtils.toApplicationAttemptId(String applicationAttmeptIdStr) |
Copyright © 2013 Apache Software Foundation. All rights reserved.