Package org.apache.hadoop.yarn.ipc

Class HadoopYarnProtoRPC

java.lang.Object

org.apache.hadoop.yarn.ipc.YarnRPC

org.apache.hadoop.yarn.ipc.HadoopYarnProtoRPC

@LimitedPrivate({"MapReduce","YARN"})
public class HadoopYarnProtoRPC
extends YarnRPC

This uses Hadoop RPC. Uses a tunnel ProtoSpecificRpcEngine over Hadoop connection. This does not give cross-language wire compatibility, since the Hadoop RPC wire format is non-standard, but it does permit use of Protocol Buffers protocol versioning features for inter-Java RPCs.

Constructor Summary

Constructors

Constructor	Description
HadoopYarnProtoRPC()

Method Summary

Modifier and Type	Method	Description
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, String portRangeConfig)
void	stopProxy(Object proxy, org.apache.hadoop.conf.Configuration conf)

Methods inherited from class org.apache.hadoop.yarn.ipc.YarnRPC

create, getServer

Methods inherited from class java.lang.Object

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

Constructor Details

HadoopYarnProtoRPC

public HadoopYarnProtoRPC()

Method Details

getProxy

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

Specified by:

getProxy in class YarnRPC

stopProxy

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

Specified by:

stopProxy in class YarnRPC

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,
 String portRangeConfig)

Specified by:

getServer in class YarnRPC