P - Protocol classpublic abstract class YarnRpc<P>
extends java.lang.Object
implements java.lang.AutoCloseable
| Constructor and Description |
|---|
YarnRpc(java.lang.Class<P> protocolType,
Configuration cfg) |
| Modifier and Type | Method and Description |
|---|---|
void |
close() |
protected P |
proxy() |
protected abstract java.net.InetSocketAddress |
resolveEndpoint(Configuration cfg) |
void |
start() |
public YarnRpc(java.lang.Class<P> protocolType, Configuration cfg)
public void start()
protected P proxy()
public void close()
close in interface java.lang.AutoCloseableprotected abstract java.net.InetSocketAddress resolveEndpoint(Configuration cfg) throws java.io.IOException
java.io.IOException