public final class DefaultRequestInterceptor extends AbstractRequestInterceptor
Constructor and Description |
---|
DefaultRequestInterceptor() |
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.server.api.protocolrecords.DistributedSchedulingAllocateResponse |
allocateForDistributedScheduling(org.apache.hadoop.yarn.server.api.protocolrecords.DistributedSchedulingAllocateRequest request)
Default implementation that invokes the distributed scheduling version
of the register method.
|
org.apache.hadoop.yarn.api.protocolrecords.FinishApplicationMasterResponse |
finishApplicationMaster(org.apache.hadoop.yarn.api.protocolrecords.FinishApplicationMasterRequest request) |
static org.apache.hadoop.io.Text |
getTokenService(org.apache.hadoop.conf.Configuration conf,
String address,
String defaultAddr,
int defaultPort) |
void |
init(AMRMProxyApplicationContext appContext)
Initializes the
RequestInterceptor . |
org.apache.hadoop.yarn.api.protocolrecords.RegisterApplicationMasterResponse |
registerApplicationMaster(org.apache.hadoop.yarn.api.protocolrecords.RegisterApplicationMasterRequest request) |
org.apache.hadoop.yarn.server.api.protocolrecords.RegisterDistributedSchedulingAMResponse |
registerApplicationMasterForDistributedScheduling(org.apache.hadoop.yarn.api.protocolrecords.RegisterApplicationMasterRequest request)
Default implementation that invokes the distributed scheduling version
of the allocate method.
|
void |
setNextInterceptor(RequestInterceptor next)
Sets the
RequestInterceptor in the chain. |
void |
setRMClient(org.apache.hadoop.yarn.api.ApplicationMasterProtocol rmClient) |
getApplicationContext, getConf, getNextInterceptor, getNMStateStore, recover, setConf, shutdown
public void init(AMRMProxyApplicationContext appContext)
AbstractRequestInterceptor
RequestInterceptor
.init
in interface RequestInterceptor
init
in class AbstractRequestInterceptor
appContext
- AMRMProxy application contextpublic org.apache.hadoop.yarn.api.protocolrecords.RegisterApplicationMasterResponse registerApplicationMaster(org.apache.hadoop.yarn.api.protocolrecords.RegisterApplicationMasterRequest request) throws org.apache.hadoop.yarn.exceptions.YarnException, IOException
org.apache.hadoop.yarn.exceptions.YarnException
IOException
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
org.apache.hadoop.yarn.exceptions.YarnException
IOException
public org.apache.hadoop.yarn.server.api.protocolrecords.RegisterDistributedSchedulingAMResponse registerApplicationMasterForDistributedScheduling(org.apache.hadoop.yarn.api.protocolrecords.RegisterApplicationMasterRequest request) throws org.apache.hadoop.yarn.exceptions.YarnException, IOException
AbstractRequestInterceptor
registerApplicationMasterForDistributedScheduling
in interface org.apache.hadoop.yarn.server.api.DistributedSchedulingAMProtocol
registerApplicationMasterForDistributedScheduling
in class AbstractRequestInterceptor
request
- ApplicationMaster registration requestorg.apache.hadoop.yarn.exceptions.YarnException
- if failsIOException
- if failspublic org.apache.hadoop.yarn.server.api.protocolrecords.DistributedSchedulingAllocateResponse allocateForDistributedScheduling(org.apache.hadoop.yarn.server.api.protocolrecords.DistributedSchedulingAllocateRequest request) throws org.apache.hadoop.yarn.exceptions.YarnException, IOException
AbstractRequestInterceptor
allocateForDistributedScheduling
in interface org.apache.hadoop.yarn.server.api.DistributedSchedulingAMProtocol
allocateForDistributedScheduling
in class AbstractRequestInterceptor
request
- ApplicationMaster allocate requestorg.apache.hadoop.yarn.exceptions.YarnException
- if failsIOException
- if failspublic org.apache.hadoop.yarn.api.protocolrecords.FinishApplicationMasterResponse finishApplicationMaster(org.apache.hadoop.yarn.api.protocolrecords.FinishApplicationMasterRequest request) throws org.apache.hadoop.yarn.exceptions.YarnException, IOException
org.apache.hadoop.yarn.exceptions.YarnException
IOException
public void setNextInterceptor(RequestInterceptor next)
AbstractRequestInterceptor
RequestInterceptor
in the chain.setNextInterceptor
in interface RequestInterceptor
setNextInterceptor
in class AbstractRequestInterceptor
next
- the next intercepter to setpublic void setRMClient(org.apache.hadoop.yarn.api.ApplicationMasterProtocol rmClient)
Copyright © 2008–2023 Apache Software Foundation. All rights reserved.