Class DriverRPCServer


  • @NotThreadSafe
    public final class DriverRPCServer
    extends Object
    Client-side RPC implementation for communication from/to Nemo Driver.
    • Constructor Detail

      • DriverRPCServer

        public DriverRPCServer()
    • Method Detail

      • run

        public void run()
        Runs the RPC server. Specifically, creates a NettyMessagingTransport and binds it to a listening port.
      • getListeningPort

        public int getListeningPort()
        Returns:
        the listening port
      • getListeningHost

        public String getListeningHost()
        Returns:
        the host of the client
      • getListeningConfiguration

        public org.apache.reef.tang.Configuration getListeningConfiguration()
        Returns:
        the configuration for RPC server listening information
      • shutdown

        public void shutdown()
        Shut down the server.