@InterfaceAudience.Private
public class ApplicationMasterService
extends org.apache.hadoop.service.AbstractService
implements org.apache.hadoop.yarn.api.ApplicationMasterProtocol
Modifier and Type | Class and Description |
---|---|
static class |
ApplicationMasterService.AllocateResponseLock |
Modifier and Type | Field and Description |
---|---|
protected static Allocation |
EMPTY_ALLOCATION |
protected static List<org.apache.hadoop.yarn.api.records.Container> |
EMPTY_CONTAINER_LIST |
Constructor and Description |
---|
ApplicationMasterService(RMContext rmContext,
YarnScheduler scheduler) |
Modifier and Type | Method and Description |
---|---|
org.apache.hadoop.yarn.api.protocolrecords.AllocateResponse |
allocate(org.apache.hadoop.yarn.api.protocolrecords.AllocateRequest request) |
org.apache.hadoop.yarn.api.protocolrecords.FinishApplicationMasterResponse |
finishApplicationMaster(org.apache.hadoop.yarn.api.protocolrecords.FinishApplicationMasterRequest request) |
InetSocketAddress |
getBindAddress() |
org.apache.hadoop.ipc.Server |
getServer() |
boolean |
hasApplicationMasterRegistered(org.apache.hadoop.yarn.api.records.ApplicationAttemptId appAttemptId) |
void |
refreshServiceAcls(org.apache.hadoop.conf.Configuration configuration,
org.apache.hadoop.security.authorize.PolicyProvider policyProvider) |
void |
registerAppAttempt(org.apache.hadoop.yarn.api.records.ApplicationAttemptId attemptId) |
org.apache.hadoop.yarn.api.protocolrecords.RegisterApplicationMasterResponse |
registerApplicationMaster(org.apache.hadoop.yarn.api.protocolrecords.RegisterApplicationMasterRequest request) |
protected void |
serviceInit(org.apache.hadoop.conf.Configuration conf) |
protected void |
serviceStart() |
protected void |
serviceStop() |
protected boolean |
setAttemptLastResponseId(org.apache.hadoop.yarn.api.records.ApplicationAttemptId attemptId,
int lastResponseId) |
void |
unregisterAttempt(org.apache.hadoop.yarn.api.records.ApplicationAttemptId attemptId) |
close, getBlockers, getConfig, getFailureCause, getFailureState, getLifecycleHistory, getName, getServiceState, getStartTime, init, isInState, noteFailure, putBlocker, registerGlobalListener, registerServiceListener, removeBlocker, setConfig, start, stop, toString, unregisterGlobalListener, unregisterServiceListener, waitForServiceToStop
protected static final List<org.apache.hadoop.yarn.api.records.Container> EMPTY_CONTAINER_LIST
protected static final Allocation EMPTY_ALLOCATION
public ApplicationMasterService(RMContext rmContext, YarnScheduler scheduler)
protected void serviceInit(org.apache.hadoop.conf.Configuration conf) throws Exception
serviceInit
in class org.apache.hadoop.service.AbstractService
Exception
protected void serviceStart() throws Exception
serviceStart
in class org.apache.hadoop.service.AbstractService
Exception
@InterfaceAudience.Private public InetSocketAddress getBindAddress()
public org.apache.hadoop.yarn.api.protocolrecords.RegisterApplicationMasterResponse registerApplicationMaster(org.apache.hadoop.yarn.api.protocolrecords.RegisterApplicationMasterRequest request) throws org.apache.hadoop.yarn.exceptions.YarnException, IOException
registerApplicationMaster
in interface org.apache.hadoop.yarn.api.ApplicationMasterProtocol
org.apache.hadoop.yarn.exceptions.YarnException
IOException
public org.apache.hadoop.yarn.api.protocolrecords.FinishApplicationMasterResponse finishApplicationMaster(org.apache.hadoop.yarn.api.protocolrecords.FinishApplicationMasterRequest request) throws org.apache.hadoop.yarn.exceptions.YarnException, IOException
finishApplicationMaster
in interface org.apache.hadoop.yarn.api.ApplicationMasterProtocol
org.apache.hadoop.yarn.exceptions.YarnException
IOException
public boolean hasApplicationMasterRegistered(org.apache.hadoop.yarn.api.records.ApplicationAttemptId appAttemptId)
appAttemptId
- public org.apache.hadoop.yarn.api.protocolrecords.AllocateResponse allocate(org.apache.hadoop.yarn.api.protocolrecords.AllocateRequest request) throws org.apache.hadoop.yarn.exceptions.YarnException, IOException
allocate
in interface org.apache.hadoop.yarn.api.ApplicationMasterProtocol
org.apache.hadoop.yarn.exceptions.YarnException
IOException
public void registerAppAttempt(org.apache.hadoop.yarn.api.records.ApplicationAttemptId attemptId)
protected boolean setAttemptLastResponseId(org.apache.hadoop.yarn.api.records.ApplicationAttemptId attemptId, int lastResponseId)
public void unregisterAttempt(org.apache.hadoop.yarn.api.records.ApplicationAttemptId attemptId)
public void refreshServiceAcls(org.apache.hadoop.conf.Configuration configuration, org.apache.hadoop.security.authorize.PolicyProvider policyProvider)
protected void serviceStop() throws Exception
serviceStop
in class org.apache.hadoop.service.AbstractService
Exception
public org.apache.hadoop.ipc.Server getServer()
Copyright © 2017 Apache Software Foundation. All Rights Reserved.