public class BuilderUtils extends Object
Modifier and Type | Class and Description |
---|---|
static class |
BuilderUtils.ApplicationIdComparator |
static class |
BuilderUtils.ContainerIdComparator |
Constructor and Description |
---|
BuilderUtils() |
Modifier and Type | Method and Description |
---|---|
static ApplicationId |
convert(long clustertimestamp,
CharSequence id) |
static AllocateResponse |
newAllocateResponse(int responseId,
List<ContainerStatus> completedContainers,
List<Container> allocatedContainers,
List<NodeReport> updatedNodes,
Resource availResources,
AMCommand command,
int numClusterNodes,
PreemptionMessage preempt) |
static Token |
newAMRMToken(byte[] identifier,
String kind,
byte[] password,
String service) |
static ApplicationAttemptId |
newApplicationAttemptId(ApplicationId appId,
int attemptId) |
static ApplicationId |
newApplicationId(long clusterTimeStamp,
int id) |
static ApplicationId |
newApplicationId(RecordFactory recordFactory,
long clustertimestamp,
CharSequence id) |
static ApplicationId |
newApplicationId(RecordFactory recordFactory,
long clusterTimeStamp,
int id) |
static ApplicationReport |
newApplicationReport(ApplicationId applicationId,
ApplicationAttemptId applicationAttemptId,
String user,
String queue,
String name,
String host,
int rpcPort,
Token clientToAMToken,
YarnApplicationState state,
String diagnostics,
String url,
long startTime,
long finishTime,
FinalApplicationStatus finalStatus,
ApplicationResourceUsageReport appResources,
String origTrackingUrl,
float progress,
String appType,
Token amRmToken) |
static ApplicationResourceUsageReport |
newApplicationResourceUsageReport(int numUsedContainers,
int numReservedContainers,
Resource usedResources,
Resource reservedResources,
Resource neededResources) |
static ApplicationSubmissionContext |
newApplicationSubmissionContext(ApplicationId applicationId,
String applicationName,
String queue,
Priority priority,
ContainerLaunchContext amContainer,
boolean isUnmanagedAM,
boolean cancelTokensWhenComplete,
int maxAppAttempts,
Resource resource) |
static ApplicationSubmissionContext |
newApplicationSubmissionContext(ApplicationId applicationId,
String applicationName,
String queue,
Priority priority,
ContainerLaunchContext amContainer,
boolean isUnmanagedAM,
boolean cancelTokensWhenComplete,
int maxAppAttempts,
Resource resource,
String applicationType) |
static Token |
newClientToAMToken(byte[] identifier,
String kind,
byte[] password,
String service) |
static Container |
newContainer(ContainerId containerId,
NodeId nodeId,
String nodeHttpAddress,
Resource resource,
Priority priority,
Token containerToken) |
static ContainerId |
newContainerId(ApplicationAttemptId appAttemptId,
int containerId) |
static ContainerId |
newContainerId(int appId,
int appAttemptId,
long timestamp,
int id) |
static ContainerId |
newContainerId(RecordFactory recordFactory,
ApplicationId appId,
ApplicationAttemptId appAttemptId,
int containerId) |
static ContainerLaunchContext |
newContainerLaunchContext(Map<String,LocalResource> localResources,
Map<String,String> environment,
List<String> commands,
Map<String,ByteBuffer> serviceData,
ByteBuffer tokens,
Map<ApplicationAccessType,String> acls) |
static ContainerStatus |
newContainerStatus(ContainerId containerId,
ContainerState containerState,
String diagnostics,
int exitStatus) |
static Token |
newContainerToken(ContainerId cId,
String host,
int port,
String user,
Resource r,
long expiryTime,
int masterKeyId,
byte[] password,
long rmIdentifier) |
static Token |
newContainerToken(NodeId nodeId,
byte[] password,
ContainerTokenIdentifier tokenIdentifier) |
static ContainerTokenIdentifier |
newContainerTokenIdentifier(Token containerToken) |
static Token |
newDelegationToken(byte[] identifier,
String kind,
byte[] password,
String service) |
static LocalResource |
newLocalResource(URI uri,
LocalResourceType type,
LocalResourceVisibility visibility,
long size,
long timestamp) |
static LocalResource |
newLocalResource(URL url,
LocalResourceType type,
LocalResourceVisibility visibility,
long size,
long timestamp) |
static NodeId |
newNodeId(String host,
int port) |
static NodeReport |
newNodeReport(NodeId nodeId,
NodeState nodeState,
String httpAddress,
String rackName,
Resource used,
Resource capability,
int numContainers,
String healthReport,
long lastHealthReportTime) |
static Priority |
newPriority(int p) |
static Resource |
newResource(int memory,
int vCores) |
static ResourceRequest |
newResourceRequest(Priority priority,
String hostName,
Resource capability,
int numContainers) |
static ResourceRequest |
newResourceRequest(ResourceRequest r) |
static <T extends Token> |
newToken(Class<T> tokenClass,
byte[] identifier,
String kind,
byte[] password,
String service) |
static URL |
newURL(String scheme,
String host,
int port,
String file) |
public static LocalResource newLocalResource(URL url, LocalResourceType type, LocalResourceVisibility visibility, long size, long timestamp)
public static LocalResource newLocalResource(URI uri, LocalResourceType type, LocalResourceVisibility visibility, long size, long timestamp)
public static ApplicationId newApplicationId(RecordFactory recordFactory, long clustertimestamp, CharSequence id)
public static ApplicationId newApplicationId(RecordFactory recordFactory, long clusterTimeStamp, int id)
public static ApplicationId newApplicationId(long clusterTimeStamp, int id)
public static ApplicationAttemptId newApplicationAttemptId(ApplicationId appId, int attemptId)
public static ApplicationId convert(long clustertimestamp, CharSequence id)
public static ContainerId newContainerId(ApplicationAttemptId appAttemptId, int containerId)
public static ContainerId newContainerId(int appId, int appAttemptId, long timestamp, int id)
public static Token newContainerToken(ContainerId cId, String host, int port, String user, Resource r, long expiryTime, int masterKeyId, byte[] password, long rmIdentifier) throws IOException
IOException
public static ContainerId newContainerId(RecordFactory recordFactory, ApplicationId appId, ApplicationAttemptId appAttemptId, int containerId)
public static NodeReport newNodeReport(NodeId nodeId, NodeState nodeState, String httpAddress, String rackName, Resource used, Resource capability, int numContainers, String healthReport, long lastHealthReportTime)
public static ContainerStatus newContainerStatus(ContainerId containerId, ContainerState containerState, String diagnostics, int exitStatus)
public static Container newContainer(ContainerId containerId, NodeId nodeId, String nodeHttpAddress, Resource resource, Priority priority, Token containerToken)
public static <T extends Token> T newToken(Class<T> tokenClass, byte[] identifier, String kind, byte[] password, String service)
public static Token newDelegationToken(byte[] identifier, String kind, byte[] password, String service)
public static Token newClientToAMToken(byte[] identifier, String kind, byte[] password, String service)
public static Token newAMRMToken(byte[] identifier, String kind, byte[] password, String service)
@InterfaceAudience.Private public static Token newContainerToken(NodeId nodeId, byte[] password, ContainerTokenIdentifier tokenIdentifier)
public static ContainerTokenIdentifier newContainerTokenIdentifier(Token containerToken) throws IOException
IOException
public static ContainerLaunchContext newContainerLaunchContext(Map<String,LocalResource> localResources, Map<String,String> environment, List<String> commands, Map<String,ByteBuffer> serviceData, ByteBuffer tokens, Map<ApplicationAccessType,String> acls)
public static Priority newPriority(int p)
public static ResourceRequest newResourceRequest(Priority priority, String hostName, Resource capability, int numContainers)
public static ResourceRequest newResourceRequest(ResourceRequest r)
public static ApplicationReport newApplicationReport(ApplicationId applicationId, ApplicationAttemptId applicationAttemptId, String user, String queue, String name, String host, int rpcPort, Token clientToAMToken, YarnApplicationState state, String diagnostics, String url, long startTime, long finishTime, FinalApplicationStatus finalStatus, ApplicationResourceUsageReport appResources, String origTrackingUrl, float progress, String appType, Token amRmToken)
public static ApplicationSubmissionContext newApplicationSubmissionContext(ApplicationId applicationId, String applicationName, String queue, Priority priority, ContainerLaunchContext amContainer, boolean isUnmanagedAM, boolean cancelTokensWhenComplete, int maxAppAttempts, Resource resource, String applicationType)
public static ApplicationSubmissionContext newApplicationSubmissionContext(ApplicationId applicationId, String applicationName, String queue, Priority priority, ContainerLaunchContext amContainer, boolean isUnmanagedAM, boolean cancelTokensWhenComplete, int maxAppAttempts, Resource resource)
public static ApplicationResourceUsageReport newApplicationResourceUsageReport(int numUsedContainers, int numReservedContainers, Resource usedResources, Resource reservedResources, Resource neededResources)
public static Resource newResource(int memory, int vCores)
public static AllocateResponse newAllocateResponse(int responseId, List<ContainerStatus> completedContainers, List<Container> allocatedContainers, List<NodeReport> updatedNodes, Resource availResources, AMCommand command, int numClusterNodes, PreemptionMessage preempt)
Copyright © 2013 Apache Software Foundation. All rights reserved.