Package | Description |
---|---|
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.
|
org.apache.hadoop.yarn.client.api | |
org.apache.hadoop.yarn.client.api.async | |
org.apache.hadoop.yarn.security |
Licensed to the Apache Software Foundation (ASF) under one
or more contributor license agreements.
|
Modifier and Type | Method and Description |
---|---|
abstract Priority |
UpdateApplicationPriorityRequest.getApplicationPriority()
Get the
Priority of the application to be set. |
abstract Priority |
AllocateResponse.getApplicationPriority()
Priority of the application
|
abstract Priority |
UpdateApplicationPriorityResponse.getApplicationPriority()
Get the
Priority of the application to be set. |
Modifier and Type | Method and Description |
---|---|
static UpdateApplicationPriorityRequest |
UpdateApplicationPriorityRequest.newInstance(ApplicationId applicationId,
Priority priority) |
static UpdateApplicationPriorityResponse |
UpdateApplicationPriorityResponse.newInstance(Priority priority) |
abstract void |
UpdateApplicationPriorityRequest.setApplicationPriority(Priority priority)
Set the
Priority of the application. |
abstract void |
UpdateApplicationPriorityResponse.setApplicationPriority(Priority priority)
Set the
Priority of the application. |
Modifier and Type | Field and Description |
---|---|
static Priority |
Priority.UNDEFINED |
Modifier and Type | Method and Description |
---|---|
abstract Priority |
ApplicationReport.getPriority()
Get priority of the application
|
abstract Priority |
ContainerReport.getPriority()
Get the allocated
Priority of the container. |
abstract Priority |
SchedulingRequest.getPriority() |
abstract Priority |
ApplicationSubmissionContext.getPriority()
Get the
Priority of the application. |
abstract Priority |
ReservationDefinition.getPriority()
Get the priority for this reservation.
|
abstract Priority |
ResourceRequest.getPriority()
Get the
Priority of the request. |
abstract Priority |
Container.getPriority()
Get the
Priority at which the Container was
allocated. |
static Priority |
Priority.newInstance(int p) |
Modifier and Type | Method and Description |
---|---|
int |
Priority.compareTo(Priority other) |
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 ReservationDefinition |
ReservationDefinition.newInstance(long arrival,
long deadline,
ReservationRequests reservationRequests,
String name,
String recurrenceExpression,
Priority priority) |
static SchedulingRequest |
SchedulingRequest.newInstance(long allocationRequestId,
Priority priority,
ExecutionTypeRequest executionType,
Set<String> allocationTags,
ResourceSizing resourceSizing,
PlacementConstraint placementConstraintExpression) |
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 ResourceRequest |
ResourceRequest.newInstance(Priority priority,
String hostName,
Resource capability,
int numContainers,
boolean relaxLocality,
String labelExpression,
ExecutionTypeRequest executionTypeRequest) |
SchedulingRequest.SchedulingRequestBuilder |
SchedulingRequest.SchedulingRequestBuilder.priority(Priority priority)
Set the
priority of the request. |
ResourceRequest.ResourceRequestBuilder |
ResourceRequest.ResourceRequestBuilder.priority(Priority priority)
Set the
priority of the request. |
abstract void |
ContainerReport.setPriority(Priority priority) |
abstract void |
SchedulingRequest.setPriority(Priority priority) |
abstract void |
ReservationDefinition.setPriority(Priority priority)
Set the priority for this reservation.
|
abstract void |
ResourceRequest.setPriority(Priority priority)
Set the
Priority of the request |
Modifier and Type | Method and Description |
---|---|
abstract Priority |
YarnClient.updateApplicationPriority(ApplicationId applicationId,
Priority priority)
The interface used by client to set priority of an application
|
Modifier and Type | Method and Description |
---|---|
List<? extends Collection<T>> |
AMRMClient.getMatchingRequests(Priority priority,
String resourceName,
ExecutionType executionType,
Resource capability)
Get outstanding
ContainerRequest s matching the given
parameters. |
List<? extends Collection<T>> |
AMRMClient.getMatchingRequests(Priority priority,
String resourceName,
ExecutionType executionType,
Resource capability,
String profile) |
abstract List<? extends Collection<T>> |
AMRMClient.getMatchingRequests(Priority priority,
String resourceName,
Resource capability)
Get outstanding
ContainerRequest s matching the given
parameters. |
abstract Priority |
YarnClient.updateApplicationPriority(ApplicationId applicationId,
Priority priority)
The interface used by client to set priority of an application
|
Modifier and Type | Method and Description |
---|---|
List<? extends Collection<T>> |
AMRMClientAsync.getMatchingRequests(Priority priority,
String resourceName,
ExecutionType executionType,
Resource capability)
Returns all matching ContainerRequests that match the given Priority,
ResourceName, ExecutionType and Capability.
|
abstract List<? extends Collection<T>> |
AMRMClientAsync.getMatchingRequests(Priority priority,
String resourceName,
Resource capability) |
Modifier and Type | Method and Description |
---|---|
Priority |
ContainerTokenIdentifier.getPriority() |
Constructor and Description |
---|
ContainerTokenIdentifier(ContainerId containerID,
int containerVersion,
String hostName,
String appSubmitter,
Resource r,
long expiryTimeStamp,
int masterKeyId,
long rmIdentifier,
Priority priority,
long creationTime,
LogAggregationContext logAggregationContext,
String nodeLabelExpression,
org.apache.hadoop.yarn.server.api.ContainerType containerType,
ExecutionType executionType) |
ContainerTokenIdentifier(ContainerId containerID,
int containerVersion,
String hostName,
String appSubmitter,
Resource r,
long expiryTimeStamp,
int masterKeyId,
long rmIdentifier,
Priority priority,
long creationTime,
LogAggregationContext logAggregationContext,
String nodeLabelExpression,
org.apache.hadoop.yarn.server.api.ContainerType containerType,
ExecutionType executionType,
long allocationRequestId)
Convenience Constructor for existing clients.
|
ContainerTokenIdentifier(ContainerId containerID,
int containerVersion,
String hostName,
String appSubmitter,
Resource r,
long expiryTimeStamp,
int masterKeyId,
long rmIdentifier,
Priority priority,
long creationTime,
LogAggregationContext logAggregationContext,
String nodeLabelExpression,
org.apache.hadoop.yarn.server.api.ContainerType containerType,
ExecutionType executionType,
long allocationRequestId,
Set<String> allocationTags)
Create a Container Token Identifier.
|
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)
Deprecated.
Use one of the other constructors instead.
|
ContainerTokenIdentifier(ContainerId containerID,
String hostName,
String appSubmitter,
Resource r,
long expiryTimeStamp,
int masterKeyId,
long rmIdentifier,
Priority priority,
long creationTime,
LogAggregationContext logAggregationContext,
String nodeLabelExpression) |
ContainerTokenIdentifier(ContainerId containerID,
String hostName,
String appSubmitter,
Resource r,
long expiryTimeStamp,
int masterKeyId,
long rmIdentifier,
Priority priority,
long creationTime,
LogAggregationContext logAggregationContext,
String nodeLabelExpression,
org.apache.hadoop.yarn.server.api.ContainerType containerType) |
Copyright © 2024 Apache Software Foundation. All rights reserved.