Package | Description |
---|---|
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 | Field and Description |
---|---|
static Priority |
Priority.UNDEFINED |
Modifier and Type | Method and Description |
---|---|
abstract Priority |
ContainerReport.getPriority()
Get the allocated
Priority of the container. |
abstract Priority |
ResourceRequest.getPriority()
Get the
Priority of the request. |
abstract Priority |
ApplicationSubmissionContext.getPriority()
Get the
Priority of the application. |
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 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,
String nodeHttpAddress) |
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 |
ContainerReport.setPriority(Priority priority) |
abstract void |
ResourceRequest.setPriority(Priority priority)
Set the
Priority of the request |
abstract void |
ApplicationSubmissionContext.setPriority(Priority priority)
Set the
Priority of the application. |
abstract void |
Container.setPriority(Priority priority) |
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 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,
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 © 2015 Apache Software Foundation. All rights reserved.