Package | Description |
---|---|
org.apache.hadoop.yarn.server.nodemanager.amrmproxy | |
org.apache.hadoop.yarn.server.nodemanager.scheduler |
Modifier and Type | Class and Description |
---|---|
class |
AbstractRequestInterceptor
Implements the RequestInterceptor interface and provides common functionality
which can can be used and/or extended by other concrete intercepter classes.
|
class |
DefaultRequestInterceptor
Extends the AbstractRequestInterceptor class and provides an implementation
that simply forwards the AM requests to the cluster resource manager.
|
class |
FederationInterceptor
Extends the AbstractRequestInterceptor and provides an implementation for
federation of YARN RM and scaling an application across multiple YARN
sub-clusters.
|
Modifier and Type | Method and Description |
---|---|
protected RequestInterceptor |
AMRMProxyService.createRequestInterceptorChain()
This method creates and returns reference of the first intercepter in the
chain of request intercepter instances.
|
RequestInterceptor |
RequestInterceptor.getNextInterceptor()
Returns the next intercepter in the chain.
|
RequestInterceptor |
AbstractRequestInterceptor.getNextInterceptor()
Gets the next
RequestInterceptor in the chain. |
RequestInterceptor |
AMRMProxyService.RequestInterceptorChainWrapper.getRootInterceptor()
Gets the root request intercepter.
|
Modifier and Type | Method and Description |
---|---|
void |
AMRMProxyService.RequestInterceptorChainWrapper.init(RequestInterceptor rootInterceptor,
org.apache.hadoop.yarn.api.records.ApplicationAttemptId applicationAttemptId)
Initializes the wrapper with the specified parameters.
|
void |
DefaultRequestInterceptor.setNextInterceptor(RequestInterceptor next) |
void |
RequestInterceptor.setNextInterceptor(RequestInterceptor nextInterceptor)
Sets the next intercepter in the pipeline.
|
void |
FederationInterceptor.setNextInterceptor(RequestInterceptor next) |
void |
AbstractRequestInterceptor.setNextInterceptor(RequestInterceptor nextInterceptor)
Sets the
RequestInterceptor in the chain. |
Modifier and Type | Class and Description |
---|---|
class |
DistributedScheduler
The DistributedScheduler runs on the NodeManager and is modeled as an
AMRMProxy request interceptor. |
Copyright © 2008–2023 Apache Software Foundation. All rights reserved.