public abstract class AbstractRequestInterceptor extends Object implements RequestInterceptor
Constructor and Description |
---|
AbstractRequestInterceptor() |
Modifier and Type | Method and Description |
---|---|
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.
|
AMRMProxyApplicationContext |
getApplicationContext()
Gets the
AMRMProxyApplicationContext . |
org.apache.hadoop.conf.Configuration |
getConf()
Gets the
Configuration . |
RequestInterceptor |
getNextInterceptor()
Gets the next
RequestInterceptor in the chain. |
NMStateStoreService |
getNMStateStore()
A helper method for getting NM state store.
|
void |
init(AMRMProxyApplicationContext appContext)
Initializes the
RequestInterceptor . |
void |
recover(Map<String,byte[]> recoveredDataMap)
Recover
RequestInterceptor state from store. |
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 |
setConf(org.apache.hadoop.conf.Configuration conf)
Sets the
Configuration . |
void |
setNextInterceptor(RequestInterceptor nextInterceptor)
Sets the
RequestInterceptor in the chain. |
void |
shutdown()
Disposes the
RequestInterceptor . |
public void setNextInterceptor(RequestInterceptor nextInterceptor)
RequestInterceptor
in the chain.setNextInterceptor
in interface RequestInterceptor
nextInterceptor
- the next intercepter to setpublic void setConf(org.apache.hadoop.conf.Configuration conf)
Configuration
.setConf
in interface org.apache.hadoop.conf.Configurable
public org.apache.hadoop.conf.Configuration getConf()
Configuration
.getConf
in interface org.apache.hadoop.conf.Configurable
public void init(AMRMProxyApplicationContext appContext)
RequestInterceptor
.init
in interface RequestInterceptor
appContext
- AMRMProxy application contextpublic void recover(Map<String,byte[]> recoveredDataMap)
RequestInterceptor
state from store.recover
in interface RequestInterceptor
recoveredDataMap
- states for all intercepters recovered from NMSSpublic void shutdown()
RequestInterceptor
.shutdown
in interface RequestInterceptor
public RequestInterceptor getNextInterceptor()
RequestInterceptor
in the chain.getNextInterceptor
in interface RequestInterceptor
public AMRMProxyApplicationContext getApplicationContext()
AMRMProxyApplicationContext
.getApplicationContext
in interface RequestInterceptor
public 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
allocateForDistributedScheduling
in interface org.apache.hadoop.yarn.server.api.DistributedSchedulingAMProtocol
request
- ApplicationMaster allocate requestorg.apache.hadoop.yarn.exceptions.YarnException
- if failsIOException
- if failspublic 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
registerApplicationMasterForDistributedScheduling
in interface org.apache.hadoop.yarn.server.api.DistributedSchedulingAMProtocol
request
- ApplicationMaster registration requestorg.apache.hadoop.yarn.exceptions.YarnException
- if failsIOException
- if failspublic NMStateStoreService getNMStateStore()
Copyright © 2008–2023 Apache Software Foundation. All rights reserved.