org.apache.hadoop.yarn.ipc

Class YarnRPC

java.lang.Object

org.apache.hadoop.yarn.ipc.YarnRPC

Direct Known Subclasses:

HadoopYarnProtoRPC

@InterfaceAudience.LimitedPrivate(value={"MapReduce","YARN"})
public abstract class YarnRPC
extends Object

Abstraction to get the RPC implementation for Yarn.

Constructor Summary

Constructors

Constructor and Description
YarnRPC()

Method Summary

Modifier and Type	Method and Description
static YarnRPC	create(org.apache.hadoop.conf.Configuration conf)
abstract Object	getProxy(Class protocol, InetSocketAddress addr, org.apache.hadoop.conf.Configuration conf)
org.apache.hadoop.ipc.Server	getServer(Class protocol, Object instance, InetSocketAddress addr, org.apache.hadoop.conf.Configuration conf, org.apache.hadoop.security.token.SecretManager<? extends org.apache.hadoop.security.token.TokenIdentifier> secretManager, int numHandlers)
abstract org.apache.hadoop.ipc.Server	getServer(Class protocol, Object instance, InetSocketAddress addr, org.apache.hadoop.conf.Configuration conf, org.apache.hadoop.security.token.SecretManager<? extends org.apache.hadoop.security.token.TokenIdentifier> secretManager, int numHandlers, String portRangeConfig)
abstract void	stopProxy(Object proxy, org.apache.hadoop.conf.Configuration conf)

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

YarnRPC

public YarnRPC()

Method Detail

getProxy

public abstract Object getProxy(Class protocol,
                                InetSocketAddress addr,
                                org.apache.hadoop.conf.Configuration conf)

stopProxy

public abstract void stopProxy(Object proxy,
                               org.apache.hadoop.conf.Configuration conf)

getServer

public abstract org.apache.hadoop.ipc.Server getServer(Class protocol,
                                                       Object instance,
                                                       InetSocketAddress addr,
                                                       org.apache.hadoop.conf.Configuration conf,
                                                       org.apache.hadoop.security.token.SecretManager<? extends org.apache.hadoop.security.token.TokenIdentifier> secretManager,
                                                       int numHandlers,
                                                       String portRangeConfig)

getServer

public org.apache.hadoop.ipc.Server getServer(Class protocol,
                                              Object instance,
                                              InetSocketAddress addr,
                                              org.apache.hadoop.conf.Configuration conf,
                                              org.apache.hadoop.security.token.SecretManager<? extends org.apache.hadoop.security.token.TokenIdentifier> secretManager,
                                              int numHandlers)

create

public static YarnRPC create(org.apache.hadoop.conf.Configuration conf)