Package com.alibaba.RDDReaderTransfer

Class RDDReadServer

java.lang.Object

com.alibaba.RDDReaderTransfer.RDDReadServer

public class RDDReadServer
extends Object

Constructor Summary

Constructors

Constructor	Description
RDDReadServer(int port_shift, int partition_id, Iterator iter, String data_type, int part_cnt)

Method Summary

Modifier and Type	Method	Description
void	blockUntilShutdown()	Await termination on the main thread since the grpc library uses daemon threads.
static String	getLocalHostLANAddress()
void	start()

Methods inherited from class java.lang.Object

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

Constructor Detail

RDDReadServer

public RDDReadServer(int port_shift,
                     int partition_id,
                     Iterator iter,
                     String data_type,
                     int part_cnt)

Method Detail

getLocalHostLANAddress

public static String getLocalHostLANAddress()
                                     throws UnknownHostException

Throws:

UnknownHostException

start

public void start()
           throws IOException

Throws:

IOException

blockUntilShutdown

public void blockUntilShutdown()
                        throws InterruptedException

Await termination on the main thread since the grpc library uses daemon threads.

Throws:

InterruptedException