|
||||||||||
PREV NEXT | FRAMES NO FRAMES |
Packages that use Priority | |
---|---|
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 |
Uses of Priority in org.apache.hadoop.yarn.api.records |
---|
Fields in org.apache.hadoop.yarn.api.records declared as Priority | |
---|---|
static Priority |
Priority.UNDEFINED
|
Methods in org.apache.hadoop.yarn.api.records that return Priority | |
---|---|
abstract Priority |
ResourceRequest.getPriority()
Get the Priority of the request. |
abstract Priority |
ContainerReport.getPriority()
Get the allocated Priority of the container. |
abstract Priority |
Container.getPriority()
Get the Priority at which the Container was
allocated. |
abstract Priority |
ApplicationSubmissionContext.getPriority()
Get the Priority of the application. |
static Priority |
Priority.newInstance(int p)
|
Methods in org.apache.hadoop.yarn.api.records with parameters of type Priority | |
---|---|
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 Container |
Container.newInstance(ContainerId containerId,
NodeId nodeId,
String nodeHttpAddress,
Resource resource,
Priority priority,
Token containerToken)
|
static ContainerReport |
ContainerReport.newInstance(ContainerId containerId,
Resource allocatedResource,
NodeId assignedNode,
Priority priority,
long creationTime,
long finishTime,
String diagnosticInfo,
String logUrl,
int containerExitStatus,
ContainerState containerState)
|
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)
|
abstract void |
ResourceRequest.setPriority(Priority priority)
Set the Priority of the request |
abstract void |
ContainerReport.setPriority(Priority priority)
|
abstract void |
Container.setPriority(Priority priority)
|
abstract void |
ApplicationSubmissionContext.setPriority(Priority priority)
Set the Priority of the application. |
Uses of Priority in org.apache.hadoop.yarn.client.api |
---|
Methods in org.apache.hadoop.yarn.client.api with parameters of type Priority | |
---|---|
abstract List<? extends Collection<T>> |
AMRMClient.getMatchingRequests(Priority priority,
String resourceName,
Resource capability)
Get outstanding ContainerRequest s matching the given
parameters. |
Uses of Priority in org.apache.hadoop.yarn.client.api.async |
---|
Methods in org.apache.hadoop.yarn.client.api.async with parameters of type Priority | |
---|---|
abstract List<? extends Collection<T>> |
AMRMClientAsync.getMatchingRequests(Priority priority,
String resourceName,
Resource capability)
|
Uses of Priority in org.apache.hadoop.yarn.security |
---|
Methods in org.apache.hadoop.yarn.security that return Priority | |
---|---|
Priority |
ContainerTokenIdentifier.getPriority()
|
Constructors in org.apache.hadoop.yarn.security with parameters of type Priority | |
---|---|
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)
|
|
||||||||||
PREV NEXT | FRAMES NO FRAMES |