Package | Description |
---|---|
org.apache.hadoop.yarn.client |
Modifier and Type | Class and Description |
---|---|
class |
ClientRMProxy<T> |
Modifier and Type | Field and Description |
---|---|
protected RMProxy<T> |
ConfiguredRMFailoverProxyProvider.rmProxy |
protected RMProxy<T> |
AutoRefreshNoHARMFailoverProxyProvider.rmProxy |
Modifier and Type | Method and Description |
---|---|
protected static <T> T |
RMProxy.createRMProxy(org.apache.hadoop.conf.Configuration configuration,
Class<T> protocol,
RMProxy<T> instance)
Currently, used by Client and AM only
Create a proxy for the specified protocol.
|
protected static <T> T |
RMProxy.createRMProxy(org.apache.hadoop.conf.Configuration configuration,
Class<T> protocol,
RMProxy<T> instance,
long retryTime,
long retryInterval)
Currently, used by NodeManagers only.
|
protected static <T> T |
RMProxy.createRMProxyFederation(org.apache.hadoop.conf.Configuration configuration,
Class<T> protocol,
RMProxy<T> instance)
This functionality is only used for NodeManager and only in non-HA mode.
|
protected static <T> RMFailoverProxyProvider<T> |
RMProxy.getRMFailoverProxyProvider(org.apache.hadoop.yarn.conf.YarnConfiguration conf,
Class<T> protocol,
RMProxy<T> instance) |
void |
ConfiguredRMFailoverProxyProvider.init(org.apache.hadoop.conf.Configuration configuration,
RMProxy<T> rmProxy,
Class<T> protocol) |
void |
RMFailoverProxyProvider.init(org.apache.hadoop.conf.Configuration conf,
RMProxy<T> proxy,
Class<T> protocol)
Initialize internal data structures, invoked right after instantiation.
|
void |
DefaultNoHARMFailoverProxyProvider.init(org.apache.hadoop.conf.Configuration conf,
RMProxy<T> proxy,
Class<T> protocol)
Initialize internal data structures, invoked right after instantiation.
|
void |
AutoRefreshNoHARMFailoverProxyProvider.init(org.apache.hadoop.conf.Configuration configuration,
RMProxy<T> rmProxy,
Class<T> protocol) |
void |
RequestHedgingRMFailoverProxyProvider.init(org.apache.hadoop.conf.Configuration configuration,
RMProxy<T> rmProxy,
Class<T> protocol) |
protected static <T> T |
RMProxy.newProxyInstanceFederation(org.apache.hadoop.yarn.conf.YarnConfiguration conf,
Class<T> protocol,
RMProxy<T> instance,
org.apache.hadoop.io.retry.RetryPolicy retryPolicy) |
Copyright © 2008–2024 Apache Software Foundation. All rights reserved.