Package | Description |
---|---|
org.apache.hadoop.yarn.ams |
Public api for Application Master Service interceptors.
|
org.apache.hadoop.yarn.api |
Licensed to the Apache Software Foundation (ASF) under one
or more contributor license agreements.
|
org.apache.hadoop.yarn.api.protocolrecords |
Licensed to the Apache Software Foundation (ASF) under one
or more contributor license agreements.
|
Modifier and Type | Method and Description |
---|---|
static void |
ApplicationMasterServiceUtils.addToAllocatedContainers(AllocateResponse allocateResponse,
List<Container> allocatedContainers)
Add allocated containers to
AllocateResponse . |
static void |
ApplicationMasterServiceUtils.addToRejectedSchedulingRequests(AllocateResponse allocateResponse,
List<RejectedSchedulingRequest> rejectedRequests)
Add rejected Scheduling Requests to
AllocateResponse . |
static void |
ApplicationMasterServiceUtils.addToUpdateContainerErrors(AllocateResponse allocateResponse,
List<UpdateContainerError> updateContainerErrors)
Add update container errors to
AllocateResponse . |
static void |
ApplicationMasterServiceUtils.addToUpdatedContainers(AllocateResponse allocateResponse,
ContainerUpdateType updateType,
List<Container> updatedContainers)
Add updated containers to
AllocateResponse . |
void |
ApplicationMasterServiceProcessor.allocate(ApplicationAttemptId appAttemptId,
AllocateRequest request,
AllocateResponse response)
Allocate call.
|
Modifier and Type | Method and Description |
---|---|
AllocateResponse |
ApplicationMasterProtocol.allocate(AllocateRequest request)
The main interface between an
ApplicationMaster and the
ResourceManager . |
Modifier and Type | Method and Description |
---|---|
AllocateResponse |
AllocateResponse.AllocateResponseBuilder.build()
Return generated
AllocateResponse object. |
static AllocateResponse |
AllocateResponse.newInstance(int responseId,
List<ContainerStatus> completedContainers,
List<Container> allocatedContainers,
List<NodeReport> updatedNodes,
Resource availResources,
AMCommand command,
int numClusterNodes,
PreemptionMessage preempt,
List<NMToken> nmTokens) |
static AllocateResponse |
AllocateResponse.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 AllocateResponse |
AllocateResponse.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 AllocateResponse |
AllocateResponse.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 AllocateResponse |
AllocateResponse.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,
EnhancedHeadroom enhancedHeadroom) |
Copyright © 2008–2024 Apache Software Foundation. All rights reserved.