org.apache.hive.spark.client.rpc

Class Rpc

java.lang.Object

org.apache.hive.spark.client.rpc.Rpc

All Implemented Interfaces:

Closeable, AutoCloseable

@InterfaceAudience.Private
public class Rpc
extends Object
implements Closeable

Encapsulates the RPC functionality. Provides higher-level methods to talk to the remote endpoint.

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
static interface	Rpc.Listener

Method Summary

Methods

Modifier and Type	Method and Description
void	addListener(Rpc.Listener l)
io.netty.util.concurrent.Future<Void>	call(Object msg) Send an RPC call to the remote endpoint and returns a future that can be used to monitor the operation.
<T> io.netty.util.concurrent.Future<T>	call(Object msg, Class<T> retType) Send an RPC call to the remote endpoint and returns a future that can be used to monitor the operation.
void	close()
static io.netty.util.concurrent.Promise<Rpc>	createClient(Map<String,String> config, io.netty.channel.nio.NioEventLoopGroup eloop, String host, int port, String clientId, String secret, RpcDispatcher dispatcher) Creates an RPC client for a server running on the given remote host and port.
<T> io.netty.util.concurrent.Promise<T>	createPromise() Creates a promise backed by this RPC's event loop.

Methods inherited from class java.lang.Object

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

Method Detail

createClient

public static io.netty.util.concurrent.Promise<Rpc> createClient(Map<String,String> config,
                                                 io.netty.channel.nio.NioEventLoopGroup eloop,
                                                 String host,
                                                 int port,
                                                 String clientId,
                                                 String secret,
                                                 RpcDispatcher dispatcher)
                                                          throws Exception

Creates an RPC client for a server running on the given remote host and port.

Parameters:

config - RPC configuration data.

eloop - Event loop for managing the connection.

host - Host name or IP address to connect to.

port - Port where server is listening.

clientId - The client ID that identifies the connection.

secret - Secret for authenticating the client with the server.

dispatcher - Dispatcher used to handle RPC calls.

Returns:

A future that can be used to monitor the creation of the RPC object.

Throws:

Exception

addListener

public void addListener(Rpc.Listener l)

call

public io.netty.util.concurrent.Future<Void> call(Object msg)

Send an RPC call to the remote endpoint and returns a future that can be used to monitor the operation.

call

public <T> io.netty.util.concurrent.Future<T> call(Object msg,
                                          Class<T> retType)

Send an RPC call to the remote endpoint and returns a future that can be used to monitor the operation.

Parameters:

msg - RPC call to send.

retType - Type of expected reply.

Returns:

A future used to monitor the operation.

createPromise

public <T> io.netty.util.concurrent.Promise<T> createPromise()

Creates a promise backed by this RPC's event loop.

close

public void close()

Specified by:

close in interface Closeable

Specified by:

close in interface AutoCloseable