Class VolumeAMSProcessor
java.lang.Object
org.apache.hadoop.yarn.server.resourcemanager.volume.csi.processor.VolumeAMSProcessor
- All Implemented Interfaces:
org.apache.hadoop.yarn.ams.ApplicationMasterServiceProcessor
public class VolumeAMSProcessor
extends Object
implements org.apache.hadoop.yarn.ams.ApplicationMasterServiceProcessor
AMS processor that handles volume resource requests.
-
Constructor Summary
Constructors -
Method Summary
Modifier and TypeMethodDescriptionvoidallocate(org.apache.hadoop.yarn.api.records.ApplicationAttemptId appAttemptId, org.apache.hadoop.yarn.api.protocolrecords.AllocateRequest request, org.apache.hadoop.yarn.api.protocolrecords.AllocateResponse response) voidfinishApplicationMaster(org.apache.hadoop.yarn.api.records.ApplicationAttemptId applicationAttemptId, org.apache.hadoop.yarn.api.protocolrecords.FinishApplicationMasterRequest request, org.apache.hadoop.yarn.api.protocolrecords.FinishApplicationMasterResponse response) voidinit(org.apache.hadoop.yarn.ams.ApplicationMasterServiceContext amsContext, org.apache.hadoop.yarn.ams.ApplicationMasterServiceProcessor nextProcessor) voidregisterApplicationMaster(org.apache.hadoop.yarn.api.records.ApplicationAttemptId applicationAttemptId, org.apache.hadoop.yarn.api.protocolrecords.RegisterApplicationMasterRequest request, org.apache.hadoop.yarn.api.protocolrecords.RegisterApplicationMasterResponse response)
-
Constructor Details
-
VolumeAMSProcessor
public VolumeAMSProcessor()
-
-
Method Details
-
init
public void init(org.apache.hadoop.yarn.ams.ApplicationMasterServiceContext amsContext, org.apache.hadoop.yarn.ams.ApplicationMasterServiceProcessor nextProcessor) - Specified by:
initin interfaceorg.apache.hadoop.yarn.ams.ApplicationMasterServiceProcessor
-
registerApplicationMaster
public void registerApplicationMaster(org.apache.hadoop.yarn.api.records.ApplicationAttemptId applicationAttemptId, org.apache.hadoop.yarn.api.protocolrecords.RegisterApplicationMasterRequest request, org.apache.hadoop.yarn.api.protocolrecords.RegisterApplicationMasterResponse response) throws IOException, org.apache.hadoop.yarn.exceptions.YarnException - Specified by:
registerApplicationMasterin interfaceorg.apache.hadoop.yarn.ams.ApplicationMasterServiceProcessor- Throws:
IOExceptionorg.apache.hadoop.yarn.exceptions.YarnException
-
allocate
public void allocate(org.apache.hadoop.yarn.api.records.ApplicationAttemptId appAttemptId, org.apache.hadoop.yarn.api.protocolrecords.AllocateRequest request, org.apache.hadoop.yarn.api.protocolrecords.AllocateResponse response) throws org.apache.hadoop.yarn.exceptions.YarnException - Specified by:
allocatein interfaceorg.apache.hadoop.yarn.ams.ApplicationMasterServiceProcessor- Throws:
org.apache.hadoop.yarn.exceptions.YarnException
-
finishApplicationMaster
public void finishApplicationMaster(org.apache.hadoop.yarn.api.records.ApplicationAttemptId applicationAttemptId, org.apache.hadoop.yarn.api.protocolrecords.FinishApplicationMasterRequest request, org.apache.hadoop.yarn.api.protocolrecords.FinishApplicationMasterResponse response) - Specified by:
finishApplicationMasterin interfaceorg.apache.hadoop.yarn.ams.ApplicationMasterServiceProcessor
-