Package | Description |
---|---|
org.apache.hadoop.yarn.api.protocolrecords | |
org.apache.hadoop.yarn.api.records | |
org.apache.hadoop.yarn.client.api |
Licensed to the Apache Software Foundation (ASF) under one
or more contributor license agreements.
|
org.apache.hadoop.yarn.client.api.async | |
org.apache.hadoop.yarn.security |
Modifier and Type | Method and Description |
---|---|
abstract Resource |
AllocateResponse.getAvailableResources()
Get the available headroom for resources in the cluster for the
application.
|
abstract Resource |
GetNewApplicationResponse.getMaximumResourceCapability()
Get the maximum capability for any
Resource allocated by the
ResourceManager in the cluster. |
abstract Resource |
RegisterApplicationMasterResponse.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<org.apache.hadoop.yarn.api.records.ContainerResourceIncrease> increasedContainers,
List<org.apache.hadoop.yarn.api.records.ContainerResourceDecrease> decreasedContainers) |
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<org.apache.hadoop.yarn.api.records.ContainerResourceIncrease> increasedContainers,
List<org.apache.hadoop.yarn.api.records.ContainerResourceDecrease> decreasedContainers) |
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 |
GetNewApplicationResponse.setMaximumResourceCapability(Resource capability) |
abstract void |
RegisterApplicationMasterResponse.setMaximumResourceCapability(Resource capability) |
Modifier and Type | Method and Description |
---|---|
abstract Resource |
ContainerReport.getAllocatedResource()
Get the allocated
Resource of the container. |
abstract Resource |
ReservationRequest.getCapability()
Get the
Resource capability of the request. |
abstract Resource |
ContainerResourceIncreaseRequest.getCapability() |
abstract Resource |
NodeReport.getCapability()
Get the total
Resource on the node. |
abstract Resource |
ResourceRequest.getCapability()
Get the
Resource capability of the request. |
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 |
ApplicationSubmissionContext.getResource()
Get the resource required by the
ApplicationMaster for this
application. |
abstract Resource |
Container.getResource()
Get the
Resource allocated to the container. |
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) |
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) |
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 ApplicationResourceUsageReport |
ApplicationResourceUsageReport.newInstance(int numUsedContainers,
int numReservedContainers,
Resource usedResources,
Resource reservedResources,
Resource neededResources,
long memorySeconds,
long vcoreSeconds) |
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 ReservationRequest |
ReservationRequest.newInstance(Resource capability,
int numContainers) |
static ResourceOption |
ResourceOption.newInstance(Resource resource,
int overCommitTimeout) |
static ReservationRequest |
ReservationRequest.newInstance(Resource capability,
int numContainers,
int concurrency,
long duration) |
abstract void |
ContainerReport.setAllocatedResource(Resource resource) |
abstract void |
ReservationRequest.setCapability(Resource capability)
Set the
Resource capability of the request |
abstract void |
ContainerResourceIncreaseRequest.setCapability(Resource capability) |
abstract void |
NodeReport.setCapability(Resource capability) |
abstract void |
ResourceRequest.setCapability(Resource capability)
Set the
Resource capability of the request |
abstract void |
ApplicationResourceUsageReport.setNeededResources(Resource needed_resources) |
abstract void |
ApplicationResourceUsageReport.setReservedResources(Resource reserved_resources) |
protected abstract void |
ResourceOption.setResource(Resource resource) |
abstract void |
ApplicationSubmissionContext.setResource(Resource resource)
Set the resource required by the
ApplicationMaster for this
application. |
abstract void |
Container.setResource(Resource resource) |
abstract void |
NodeReport.setUsed(Resource used) |
abstract void |
ApplicationResourceUsageReport.setUsedResources(Resource resources) |
Modifier and Type | Method and Description |
---|---|
abstract Resource |
AMRMClient.getAvailableResources()
Get the currently available resources in the cluster.
|
Modifier and Type | Method and Description |
---|---|
abstract List<? extends Collection<T>> |
AMRMClient.getMatchingRequests(Priority priority,
String resourceName,
Resource capability)
Get outstanding
ContainerRequest s matching the given
parameters. |
Modifier and Type | Method and Description |
---|---|
abstract Resource |
AMRMClientAsync.getAvailableResources()
Get the currently available resources in the cluster.
|
Modifier and Type | Method and Description |
---|---|
abstract List<? extends Collection<T>> |
AMRMClientAsync.getMatchingRequests(Priority priority,
String resourceName,
Resource capability) |
Modifier and Type | Method and Description |
---|---|
Resource |
ContainerTokenIdentifier.getResource() |
Constructor and Description |
---|
ContainerTokenIdentifier(ContainerId containerID,
String hostName,
String appSubmitter,
Resource r,
long expiryTimeStamp,
int masterKeyId,
long rmIdentifier,
Priority priority,
long creationTime) |
ContainerTokenIdentifier(ContainerId containerID,
String hostName,
String appSubmitter,
Resource r,
long expiryTimeStamp,
int masterKeyId,
long rmIdentifier,
Priority priority,
long creationTime,
LogAggregationContext logAggregationContext) |
Copyright © 2016 Apache Software Foundation. All Rights Reserved.