Package | Description |
---|---|
org.apache.hadoop.yarn.ams |
Public api for Application Master Service interceptors.
|
org.apache.hadoop.yarn.api.protocolrecords |
Licensed to the Apache Software Foundation (ASF) under one
or more contributor license agreements.
|
org.apache.hadoop.yarn.api.records |
Licensed to the Apache Software Foundation (ASF) under one
or more contributor license agreements.
|
Modifier and Type | Method and Description |
---|---|
void |
ApplicationMasterServiceProcessor.allocate(ApplicationAttemptId appAttemptId,
AllocateRequest request,
AllocateResponse response)
Allocate call.
|
void |
ApplicationMasterServiceProcessor.finishApplicationMaster(ApplicationAttemptId applicationAttemptId,
FinishApplicationMasterRequest request,
FinishApplicationMasterResponse response)
Finish AM.
|
void |
ApplicationMasterServiceProcessor.registerApplicationMaster(ApplicationAttemptId applicationAttemptId,
RegisterApplicationMasterRequest request,
RegisterApplicationMasterResponse response)
Register AM attempt.
|
Modifier and Type | Method and Description |
---|---|
abstract ApplicationAttemptId |
GetApplicationAttemptReportRequest.getApplicationAttemptId()
Get the
ApplicationAttemptId of an application attempt. |
abstract ApplicationAttemptId |
GetContainersRequest.getApplicationAttemptId()
Get the
ApplicationAttemptId of an application attempt. |
abstract ApplicationAttemptId |
FailApplicationAttemptRequest.getApplicationAttemptId()
Get the
ApplicationAttemptId of the attempt to be failed. |
Modifier and Type | Method and Description |
---|---|
static GetApplicationAttemptReportRequest |
GetApplicationAttemptReportRequest.newInstance(ApplicationAttemptId applicationAttemptId) |
static GetContainersRequest |
GetContainersRequest.newInstance(ApplicationAttemptId applicationAttemptId) |
static FailApplicationAttemptRequest |
FailApplicationAttemptRequest.newInstance(ApplicationAttemptId attemptId) |
abstract void |
GetApplicationAttemptReportRequest.setApplicationAttemptId(ApplicationAttemptId applicationAttemptId)
Set the
ApplicationAttemptId of an application attempt |
abstract void |
GetContainersRequest.setApplicationAttemptId(ApplicationAttemptId applicationAttemptId)
Set the
ApplicationAttemptId of an application attempt |
abstract void |
FailApplicationAttemptRequest.setApplicationAttemptId(ApplicationAttemptId applicationAttemptId) |
Modifier and Type | Method and Description |
---|---|
static ApplicationAttemptId |
ApplicationAttemptId.fromString(String appAttemptIdStr) |
abstract ApplicationAttemptId |
ApplicationAttemptReport.getApplicationAttemptId()
Get the
ApplicationAttemptId of this attempt of the
application |
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.newContainerId(ApplicationAttemptId appAttemptId,
long containerId) |
static ContainerId |
ContainerId.newInstance(ApplicationAttemptId appAttemptId,
int containerId)
Deprecated.
|
static ApplicationAttemptReport |
ApplicationAttemptReport.newInstance(ApplicationAttemptId applicationAttemptId,
String host,
int rpcPort,
String url,
String oUrl,
String diagnostics,
YarnApplicationAttemptState state,
ContainerId amContainerId) |
static ApplicationAttemptReport |
ApplicationAttemptReport.newInstance(ApplicationAttemptId applicationAttemptId,
String host,
int rpcPort,
String url,
String oUrl,
String diagnostics,
YarnApplicationAttemptState state,
ContainerId amContainerId,
long startTime,
long finishTime) |
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,
Set<String> tags,
boolean unmanagedApplication,
Priority priority,
String appNodeLabelExpression,
String amNodeLabelExpression) |
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 launchTime,
long finishTime,
FinalApplicationStatus finalStatus,
ApplicationResourceUsageReport appResources,
String origTrackingUrl,
float progress,
String applicationType,
Token amRmToken) |
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 launchTime,
long finishTime,
FinalApplicationStatus finalStatus,
ApplicationResourceUsageReport appResources,
String origTrackingUrl,
float progress,
String applicationType,
Token amRmToken,
Set<String> tags,
boolean unmanagedApplication,
Priority priority,
String appNodeLabelExpression,
String amNodeLabelExpression) |
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 submitTime,
long launchTime,
long finishTime,
FinalApplicationStatus finalStatus,
ApplicationResourceUsageReport appResources,
String origTrackingUrl,
float progress,
String applicationType,
Token amRmToken) |
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 submitTime,
long launchTime,
long finishTime,
FinalApplicationStatus finalStatus,
ApplicationResourceUsageReport appResources,
String origTrackingUrl,
float progress,
String applicationType,
Token amRmToken,
Set<String> tags,
boolean unmanagedApplication,
Priority priority,
String appNodeLabelExpression,
String amNodeLabelExpression) |
abstract void |
ApplicationAttemptReport.setApplicationAttemptId(ApplicationAttemptId applicationAttemptId) |
protected abstract void |
ContainerId.setApplicationAttemptId(ApplicationAttemptId atId) |
abstract void |
ApplicationReport.setCurrentApplicationAttemptId(ApplicationAttemptId applicationAttemptId) |
Copyright © 2008–2024 Apache Software Foundation. All rights reserved.