@InterfaceAudience.Public @InterfaceStability.Stable public class ClientRMProxy<T> extends RMProxy<T>
Modifier and Type | Method and Description |
---|---|
static <T> T |
createRMProxy(Configuration configuration,
Class<T> protocol)
Create a proxy to the ResourceManager for the specified protocol.
|
static Text |
getAMRMTokenService(Configuration conf) |
static Text |
getRMDelegationTokenService(Configuration conf)
Get the token service name to be used for RMDelegationToken.
|
static Text |
getTokenService(Configuration conf,
String address,
String defaultAddr,
int defaultPort) |
createRetryPolicy
public static <T> T createRMProxy(Configuration configuration, Class<T> protocol) throws IOException
T
- Type of proxy.configuration
- Configuration with all the required information.protocol
- Client protocol for which proxy is being requested.IOException
@InterfaceStability.Unstable public static Text getRMDelegationTokenService(Configuration conf)
conf
- Configuration corresponding to the cluster we need the
RMDelegationToken for@InterfaceStability.Unstable public static Text getAMRMTokenService(Configuration conf)
@InterfaceStability.Unstable public static Text getTokenService(Configuration conf, String address, String defaultAddr, int defaultPort)
Copyright © 2021 Apache Software Foundation. All rights reserved.