Uses of Class
org.apache.hadoop.yarn.api.records.Resource
Packages that use Resource
Package
Description
Licensed to the Apache Software Foundation (ASF) under one
or more contributor license agreements.
Licensed to the Apache Software Foundation (ASF) under one
or more contributor license agreements.
Licensed to the Apache Software Foundation (ASF) under one
or more contributor license agreements.
Licensed to the Apache Software Foundation (ASF) under one
or more contributor license agreements.
-
Uses of Resource in org.apache.hadoop.yarn.api.protocolrecords
Methods in org.apache.hadoop.yarn.api.protocolrecords that return ResourceModifier and TypeMethodDescriptionabstract ResourceAllocateResponse.getAvailableResources()Get the available headroom for resources in the cluster for the application.abstract ResourceGetNewApplicationResponse.getMaximumResourceCapability()Get the maximum capability for anyResourceallocated by theResourceManagerin the cluster.abstract ResourceRegisterApplicationMasterResponse.getMaximumResourceCapability()Get the maximum capability for anyResourceallocated by theResourceManagerin the cluster.abstract ResourceGetResourceProfileResponse.getResource()Get the resources that will be allocated if the profile was used.Methods in org.apache.hadoop.yarn.api.protocolrecords that return types with arguments of type ResourceModifier and TypeMethodDescriptionGetAllResourceProfilesResponse.getResourceProfiles()RegisterApplicationMasterResponse.getResourceProfiles()Get list of supported resource profiles from RM.Methods in org.apache.hadoop.yarn.api.protocolrecords with parameters of type ResourceModifier and TypeMethodDescriptionstatic AllocateResponseAllocateResponse.newInstance(int responseId, List<ContainerStatus> completedContainers, List<Container> allocatedContainers, List<NodeReport> updatedNodes, Resource availResources, AMCommand command, int numClusterNodes, PreemptionMessage preempt, List<NMToken> nmTokens) static AllocateResponseAllocateResponse.newInstance(int responseId, List<ContainerStatus> completedContainers, List<Container> allocatedContainers, List<NodeReport> updatedNodes, Resource availResources, AMCommand command, int numClusterNodes, PreemptionMessage preempt, List<NMToken> nmTokens, CollectorInfo collectorInfo) static AllocateResponseAllocateResponse.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<UpdatedContainer> updatedContainers) static AllocateResponseAllocateResponse.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<UpdatedContainer> updatedContainers, CollectorInfo collectorInfo) static AllocateResponseAllocateResponse.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<UpdatedContainer> updatedContainers, CollectorInfo collectorInfo, org.apache.hadoop.yarn.api.records.EnhancedHeadroom enhancedHeadroom) static GetNewApplicationResponseGetNewApplicationResponse.newInstance(ApplicationId applicationId, Resource minCapability, Resource maxCapability) RegisterApplicationMasterResponse.newInstance(Resource minCapability, Resource maxCapability, Map<ApplicationAccessType, String> acls, ByteBuffer key, List<Container> containersFromPreviousAttempt, String queue, List<NMToken> nmTokensFromPreviousAttempts) abstract voidAllocateResponse.setAvailableResources(Resource limit) abstract voidGetNewApplicationResponse.setMaximumResourceCapability(Resource capability) abstract voidRegisterApplicationMasterResponse.setMaximumResourceCapability(Resource capability) abstract voidGetResourceProfileResponse.setResource(Resource r) Set the resources that will be allocated if the profile is used.Method parameters in org.apache.hadoop.yarn.api.protocolrecords with type arguments of type Resource -
Uses of Resource in org.apache.hadoop.yarn.api.records
Methods in org.apache.hadoop.yarn.api.records that return ResourceModifier and TypeMethodDescriptionabstract ResourceContainerReport.getAllocatedResource()Get the allocatedResourceof the container.ContainerStatus.getCapability()Get theResourceallocated to the container.abstract ResourceNodeReport.getCapability()Get the totalResourceon the node.abstract ResourceReservationRequest.getCapability()Get theResourcecapability of the request.abstract ResourceResourceAllocationRequest.getCapability()Get the allocated resource.abstract ResourceResourceRequest.getCapability()Get theResourcecapability of the request.abstract ResourceUpdateContainerRequest.getCapability()Get theResourcecapability of the request.abstract ResourceApplicationResourceUsageReport.getNeededResources()Get the neededResource.abstract ResourceApplicationResourceUsageReport.getReservedResources()Get the reservedResource.abstract ResourceApplicationSubmissionContext.getResource()Get the resource required by theApplicationMasterfor this application.abstract ResourceContainer.getResource()Get theResourceallocated to the container.abstract ResourceResourceOption.getResource()Get the resource of the ResourceOption.abstract ResourceResourceSizing.getResources()abstract ResourceNodeReport.getUsed()Get usedResourceon the node.abstract ResourceApplicationResourceUsageReport.getUsedResources()Get the usedResource.static ResourceResource.newInstance(int memory, int vCores) static ResourceResource.newInstance(long memory, int vCores) static ResourceResource.newInstance(long memory, int vCores, Map<String, Long> others) Create a newResourceinstance with the given CPU and memory values and additional resource values as set in theothersparameter.static ResourceResource.newInstance(Resource resource) Methods in org.apache.hadoop.yarn.api.records with parameters of type ResourceModifier and TypeMethodDescriptionResourceRequest.ResourceRequestBuilder.capability(Resource capability) Set thecapabilityof the request.intstatic voidApplicationResourceUsageReport.newInstance(int numUsedContainers, int numReservedContainers, Resource usedResources, Resource reservedResources, Resource neededResources, Map<String, Long> resourceSecondsMap, float queueUsagePerc, float clusterUsagePerc, Map<String, Long> preemtedResourceSecondsMap) static ApplicationSubmissionContextApplicationSubmissionContext.newInstance(ApplicationId applicationId, String applicationName, String queue, Priority priority, ContainerLaunchContext amContainer, boolean isUnmanagedAM, boolean cancelTokensWhenComplete, int maxAppAttempts, Resource resource) static ApplicationSubmissionContextApplicationSubmissionContext.newInstance(ApplicationId applicationId, String applicationName, String queue, Priority priority, ContainerLaunchContext amContainer, boolean isUnmanagedAM, boolean cancelTokensWhenComplete, int maxAppAttempts, Resource resource, String applicationType) static ApplicationSubmissionContextApplicationSubmissionContext.newInstance(ApplicationId applicationId, String applicationName, String queue, Priority priority, ContainerLaunchContext amContainer, boolean isUnmanagedAM, boolean cancelTokensWhenComplete, int maxAppAttempts, Resource resource, String applicationType, boolean keepContainers) static ApplicationSubmissionContextApplicationSubmissionContext.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 ApplicationSubmissionContextApplicationSubmissionContext.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 ApplicationSubmissionContextApplicationSubmissionContext.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 ContainerContainer.newInstance(ContainerId containerId, NodeId nodeId, String nodeHttpAddress, Resource resource, Priority priority, Token containerToken) static ContainerContainer.newInstance(ContainerId containerId, NodeId nodeId, String nodeHttpAddress, Resource resource, Priority priority, Token containerToken, ExecutionType executionType) static ContainerReportContainerReport.newInstance(ContainerId containerId, Resource allocatedResource, NodeId assignedNode, Priority priority, long creationTime, long finishTime, String diagnosticInfo, String logUrl, int containerExitStatus, ContainerState containerState, String nodeHttpAddress) static ContainerReportContainerReport.newInstance(ContainerId containerId, Resource allocatedResource, NodeId assignedNode, Priority priority, long creationTime, long finishTime, String diagnosticInfo, String logUrl, int containerExitStatus, ContainerState containerState, String nodeHttpAddress, ExecutionType executionType) static NodeReportNodeReport.newInstance(NodeId nodeId, NodeState nodeState, String httpAddress, String rackName, Resource used, Resource capability, int numContainers, String healthReport, long lastHealthReportTime) static NodeReportNodeReport.newInstance(NodeId nodeId, NodeState nodeState, String httpAddress, String rackName, Resource used, Resource capability, int numContainers, String healthReport, long lastHealthReportTime, Set<String> nodeLabels, Integer decommissioningTimeout, NodeUpdateType nodeUpdateType) static ReservationRequestReservationRequest.newInstance(Resource capability, int numContainers) static ReservationRequestReservationRequest.newInstance(Resource capability, int numContainers, int concurrency, long duration) static ResourceResource.newInstance(Resource resource) static ResourceAllocationRequestResourceAllocationRequest.newInstance(long startTime, long endTime, Resource capability) static ResourceOptionResourceOption.newInstance(Resource resource, int overCommitTimeout) static ResourceRequestResourceRequest.newInstance(Priority priority, String hostName, Resource capability, int numContainers) static ResourceRequestResourceRequest.newInstance(Priority priority, String hostName, Resource capability, int numContainers, boolean relaxLocality) static ResourceRequestResourceRequest.newInstance(Priority priority, String hostName, Resource capability, int numContainers, boolean relaxLocality, String labelExpression) static ResourceRequestResourceRequest.newInstance(Priority priority, String hostName, Resource capability, int numContainers, boolean relaxLocality, String labelExpression, ExecutionTypeRequest executionTypeRequest) static ResourceSizingResourceSizing.newInstance(int numAllocations, Resource resources) static ResourceSizingResourceSizing.newInstance(Resource resources) static UpdateContainerRequestUpdateContainerRequest.newInstance(int version, ContainerId containerId, ContainerUpdateType updateType, Resource targetCapability, ExecutionType targetExecutionType) abstract voidContainerReport.setAllocatedResource(Resource resource) voidContainerStatus.setCapability(Resource capability) abstract voidNodeReport.setCapability(Resource capability) abstract voidReservationRequest.setCapability(Resource capability) Set theResourcecapability of the requestabstract voidResourceAllocationRequest.setCapability(Resource resource) Set the allocated resource.abstract voidResourceRequest.setCapability(Resource capability) Set theResourcecapability of the request.abstract voidUpdateContainerRequest.setCapability(Resource capability) Set theResourcecapability of the request.abstract voidApplicationResourceUsageReport.setNeededResources(Resource needed_resources) abstract voidApplicationResourceUsageReport.setReservedResources(Resource reserved_resources) abstract voidApplicationSubmissionContext.setResource(Resource resource) Set the resource required by theApplicationMasterfor this application.abstract voidContainer.setResource(Resource resource) protected abstract voidResourceOption.setResource(Resource resource) abstract voidResourceSizing.setResources(Resource resources) abstract voidNodeReport.setUsed(Resource used) abstract voidApplicationResourceUsageReport.setUsedResources(Resource resources) -
Uses of Resource in org.apache.hadoop.yarn.client.api
Methods in org.apache.hadoop.yarn.client.api that return ResourceModifier and TypeMethodDescriptionabstract ResourceAMRMClient.getAvailableResources()Get the currently available resources in the cluster.abstract ResourceYarnClient.getResourceProfile(String profile) Get the details of a specific resource profile from the RM.Methods in org.apache.hadoop.yarn.client.api that return types with arguments of type ResourceModifier and TypeMethodDescriptionYarnClient.getResourceProfiles()Get the resource profiles available in the RM.Methods in org.apache.hadoop.yarn.client.api with parameters of type ResourceModifier and TypeMethodDescriptionList<? extends Collection<T>>AMRMClient.getMatchingRequests(Priority priority, String resourceName, ExecutionType executionType, Resource capability) Get outstandingContainerRequests 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 outstandingContainerRequests matching the given parameters.voidAMRMClient.requestContainerResourceChange(Container container, Resource capability) Deprecated. -
Uses of Resource in org.apache.hadoop.yarn.client.api.async
Methods in org.apache.hadoop.yarn.client.api.async that return ResourceModifier and TypeMethodDescriptionabstract ResourceAMRMClientAsync.getAvailableResources()Get the currently available resources in the cluster.Methods in org.apache.hadoop.yarn.client.api.async with parameters of type ResourceModifier and TypeMethodDescriptionList<? 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) voidAMRMClientAsync.requestContainerResourceChange(Container container, Resource capability) -
Uses of Resource in org.apache.hadoop.yarn.exceptions
Constructors in org.apache.hadoop.yarn.exceptions with parameters of type ResourceModifierConstructorDescriptionResourceNotFoundException(Resource resource, String type) ResourceNotFoundException(Resource resource, String type, Throwable cause) -
Uses of Resource in org.apache.hadoop.yarn.security
Methods in org.apache.hadoop.yarn.security that return ResourceConstructors in org.apache.hadoop.yarn.security with parameters of type ResourceModifierConstructorDescriptionContainerTokenIdentifier(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)
AMRMClient.requestContainerUpdate(Container, UpdateContainerRequest)