Package | Description |
---|---|
org.apache.hadoop.yarn.api.protocolrecords | |
org.apache.hadoop.yarn.api.records | |
org.apache.hadoop.yarn.server.api |
Modifier and Type | Method and Description |
---|---|
abstract Resource |
AllocateResponse.getAvailableResources()
Get the available headroom for resources in the cluster for the
application.
|
abstract Resource |
RegisterApplicationMasterResponse.getMaximumResourceCapability()
Get the maximum capability for any
Resource allocated by the
ResourceManager in the cluster. |
abstract Resource |
GetNewApplicationResponse.getMaximumResourceCapability()
Get the maximum capability for any
Resource allocated by the
ResourceManager in the cluster. |
Modifier and Type | Method and Description |
---|---|
static GetNewApplicationResponse |
GetNewApplicationResponse.newInstance(ApplicationId applicationId,
Resource minCapability,
Resource maxCapability) |
static AllocateResponse |
AllocateResponse.newInstance(int responseId,
List<ContainerStatus> completedContainers,
List<Container> allocatedContainers,
List<NodeReport> updatedNodes,
Resource availResources,
AMCommand command,
int numClusterNodes,
PreemptionMessage preempt,
List<NMToken> nmTokens) |
static AllocateResponse |
AllocateResponse.newInstance(int responseId,
List<ContainerStatus> completedContainers,
List<Container> allocatedContainers,
List<NodeReport> updatedNodes,
Resource availResources,
AMCommand command,
int numClusterNodes,
PreemptionMessage preempt,
List<NMToken> nmTokens,
List<ContainerResourceIncrease> increasedContainers,
List<ContainerResourceDecrease> decreasedContainers)
Deprecated.
|
static AllocateResponse |
AllocateResponse.newInstance(int responseId,
List<ContainerStatus> completedContainers,
List<Container> allocatedContainers,
List<NodeReport> updatedNodes,
Resource availResources,
AMCommand command,
int numClusterNodes,
PreemptionMessage preempt,
List<NMToken> nmTokens,
List<UpdatedContainer> updatedContainers) |
static AllocateResponse |
AllocateResponse.newInstance(int responseId,
List<ContainerStatus> completedContainers,
List<Container> allocatedContainers,
List<NodeReport> updatedNodes,
Resource availResources,
AMCommand command,
int numClusterNodes,
PreemptionMessage preempt,
List<NMToken> nmTokens,
Token amRMToken,
List<UpdatedContainer> updatedContainers) |
static RegisterApplicationMasterResponse |
RegisterApplicationMasterResponse.newInstance(Resource minCapability,
Resource maxCapability,
Map<ApplicationAccessType,String> acls,
ByteBuffer key,
List<Container> containersFromPreviousAttempt,
String queue,
List<NMToken> nmTokensFromPreviousAttempts) |
abstract void |
AllocateResponse.setAvailableResources(Resource limit) |
abstract void |
RegisterApplicationMasterResponse.setMaximumResourceCapability(Resource capability) |
abstract void |
GetNewApplicationResponse.setMaximumResourceCapability(Resource capability) |
Modifier and Type | Method and Description |
---|---|
abstract Resource |
ContainerReport.getAllocatedResource()
Get the allocated
Resource of the container. |
abstract Resource |
UpdateContainerRequest.getCapability()
Get the
Resource capability of the container. |
abstract Resource |
ResourceRequest.getCapability()
Get the
Resource capability of the request. |
abstract Resource |
ResourceAllocationRequest.getCapability()
Get the allocated resource.
|
abstract Resource |
ReservationRequest.getCapability()
Get the
Resource capability of the request. |
abstract Resource |
NodeReport.getCapability()
Get the total
Resource on the node. |
Resource |
ContainerStatus.getCapability()
Get the
Resource allocated to the container. |
abstract Resource |
ContainerResourceIncreaseRequest.getCapability()
Deprecated.
|
abstract Resource |
ContainerResourceIncrease.getCapability()
Deprecated.
|
abstract Resource |
ContainerResourceDecrease.getCapability()
Deprecated.
|
abstract Resource |
ApplicationResourceUsageReport.getNeededResources()
Get the needed
Resource . |
abstract Resource |
ApplicationResourceUsageReport.getReservedResources()
Get the reserved
Resource . |
abstract Resource |
ResourceOption.getResource()
Get the resource of the ResourceOption.
|
abstract Resource |
Container.getResource()
Get the
Resource allocated to the container. |
abstract Resource |
ApplicationSubmissionContext.getResource()
Get the resource required by the
ApplicationMaster for this
application. |
abstract Resource |
NodeReport.getUsed()
Get used
Resource on the node. |
abstract Resource |
ApplicationResourceUsageReport.getUsedResources()
Get the used
Resource . |
static Resource |
Resource.newInstance(int memory,
int vCores) |
static Resource |
Resource.newInstance(long memory,
int vCores) |
Modifier and Type | Method and Description |
---|---|
static ApplicationSubmissionContext |
ApplicationSubmissionContext.newInstance(ApplicationId applicationId,
String applicationName,
String queue,
Priority priority,
ContainerLaunchContext amContainer,
boolean isUnmanagedAM,
boolean cancelTokensWhenComplete,
int maxAppAttempts,
Resource resource) |
static ApplicationSubmissionContext |
ApplicationSubmissionContext.newInstance(ApplicationId applicationId,
String applicationName,
String queue,
Priority priority,
ContainerLaunchContext amContainer,
boolean isUnmanagedAM,
boolean cancelTokensWhenComplete,
int maxAppAttempts,
Resource resource,
String applicationType) |
static ApplicationSubmissionContext |
ApplicationSubmissionContext.newInstance(ApplicationId applicationId,
String applicationName,
String queue,
Priority priority,
ContainerLaunchContext amContainer,
boolean isUnmanagedAM,
boolean cancelTokensWhenComplete,
int maxAppAttempts,
Resource resource,
String applicationType,
boolean keepContainers) |
static ApplicationSubmissionContext |
ApplicationSubmissionContext.newInstance(ApplicationId applicationId,
String applicationName,
String queue,
Priority priority,
ContainerLaunchContext amContainer,
boolean isUnmanagedAM,
boolean cancelTokensWhenComplete,
int maxAppAttempts,
Resource resource,
String applicationType,
boolean keepContainers,
LogAggregationContext logAggregationContext) |
static ApplicationSubmissionContext |
ApplicationSubmissionContext.newInstance(ApplicationId applicationId,
String applicationName,
String queue,
Priority priority,
ContainerLaunchContext amContainer,
boolean isUnmanagedAM,
boolean cancelTokensWhenComplete,
int maxAppAttempts,
Resource resource,
String applicationType,
boolean keepContainers,
long attemptFailuresValidityInterval) |
static ApplicationSubmissionContext |
ApplicationSubmissionContext.newInstance(ApplicationId applicationId,
String applicationName,
String queue,
Priority priority,
ContainerLaunchContext amContainer,
boolean isUnmanagedAM,
boolean cancelTokensWhenComplete,
int maxAppAttempts,
Resource resource,
String applicationType,
boolean keepContainers,
String appLabelExpression,
String amContainerLabelExpression) |
static Container |
Container.newInstance(ContainerId containerId,
NodeId nodeId,
String nodeHttpAddress,
Resource resource,
Priority priority,
Token containerToken) |
static ContainerResourceIncreaseRequest |
ContainerResourceIncreaseRequest.newInstance(ContainerId existingContainerId,
Resource targetCapability)
Deprecated.
|
static ContainerResourceDecrease |
ContainerResourceDecrease.newInstance(ContainerId existingContainerId,
Resource targetCapability)
Deprecated.
|
static ContainerReport |
ContainerReport.newInstance(ContainerId containerId,
Resource allocatedResource,
NodeId assignedNode,
Priority priority,
long creationTime,
long finishTime,
String diagnosticInfo,
String logUrl,
int containerExitStatus,
ContainerState containerState,
String nodeHttpAddress) |
static ContainerResourceIncrease |
ContainerResourceIncrease.newInstance(ContainerId existingContainerId,
Resource targetCapability,
Token token)
Deprecated.
|
static UpdateContainerRequest |
UpdateContainerRequest.newInstance(int version,
ContainerId containerId,
ContainerUpdateType updateType,
Resource targetCapability) |
static ApplicationResourceUsageReport |
ApplicationResourceUsageReport.newInstance(int numUsedContainers,
int numReservedContainers,
Resource usedResources,
Resource reservedResources,
Resource neededResources,
long memorySeconds,
long vcoreSeconds,
float queueUsagePerc,
float clusterUsagePerc,
long preemptedMemorySeconds,
long preemptedVcoresSeconds) |
static ResourceAllocationRequest |
ResourceAllocationRequest.newInstance(long startTime,
long endTime,
Resource capability) |
static NodeReport |
NodeReport.newInstance(NodeId nodeId,
NodeState nodeState,
String httpAddress,
String rackName,
Resource used,
Resource capability,
int numContainers,
String healthReport,
long lastHealthReportTime) |
static NodeReport |
NodeReport.newInstance(NodeId nodeId,
NodeState nodeState,
String httpAddress,
String rackName,
Resource used,
Resource capability,
int numContainers,
String healthReport,
long lastHealthReportTime,
Set<String> nodeLabels) |
static ResourceRequest |
ResourceRequest.newInstance(Priority priority,
String hostName,
Resource capability,
int numContainers) |
static ResourceRequest |
ResourceRequest.newInstance(Priority priority,
String hostName,
Resource capability,
int numContainers,
boolean relaxLocality) |
static ResourceRequest |
ResourceRequest.newInstance(Priority priority,
String hostName,
Resource capability,
int numContainers,
boolean relaxLocality,
String labelExpression) |
static ResourceOption |
ResourceOption.newInstance(Resource resource,
int overCommitTimeout) |
static ReservationRequest |
ReservationRequest.newInstance(Resource capability,
int numContainers) |
static ReservationRequest |
ReservationRequest.newInstance(Resource capability,
int numContainers,
int concurrency,
long duration) |
abstract void |
ContainerReport.setAllocatedResource(Resource resource) |
abstract void |
UpdateContainerRequest.setCapability(Resource capability)
Set the
Resource capability of the container. |
abstract void |
ResourceRequest.setCapability(Resource capability)
Set the
Resource capability of the request |
abstract void |
ResourceAllocationRequest.setCapability(Resource resource)
Set the allocated resource.
|
abstract void |
ReservationRequest.setCapability(Resource capability)
Set the
Resource capability of the request |
abstract void |
NodeReport.setCapability(Resource capability) |
void |
ContainerStatus.setCapability(Resource capability) |
abstract void |
ContainerResourceIncreaseRequest.setCapability(Resource capability)
Deprecated.
|
abstract void |
ContainerResourceIncrease.setCapability(Resource capability)
Deprecated.
|
abstract void |
ContainerResourceDecrease.setCapability(Resource capability)
Deprecated.
|
abstract void |
ApplicationResourceUsageReport.setNeededResources(Resource needed_resources) |
abstract void |
ApplicationResourceUsageReport.setReservedResources(Resource reserved_resources) |
protected abstract void |
ResourceOption.setResource(Resource resource) |
abstract void |
Container.setResource(Resource resource) |
abstract void |
ApplicationSubmissionContext.setResource(Resource resource)
Set the resource required by the
ApplicationMaster for this
application. |
abstract void |
NodeReport.setUsed(Resource used) |
abstract void |
ApplicationResourceUsageReport.setUsedResources(Resource resources) |
Modifier and Type | Method and Description |
---|---|
Resource |
ContainerContext.getResource()
Get
Resource the resource capability allocated to the container
being initialized or stopped. |
Constructor and Description |
---|
ContainerContext(String user,
ContainerId containerId,
Resource resource) |
ContainerContext(String user,
ContainerId containerId,
Resource resource,
ContainerType containerType) |
ContainerInitializationContext(String user,
ContainerId containerId,
Resource resource) |
ContainerInitializationContext(String user,
ContainerId containerId,
Resource resource,
ContainerType containerType) |
ContainerTerminationContext(String user,
ContainerId containerId,
Resource resource) |
ContainerTerminationContext(String user,
ContainerId containerId,
Resource resource,
ContainerType containerType) |
Copyright © 2017 Apache Software Foundation. All Rights Reserved.