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

All Methods Static Methods Instance Methods Concrete Methods
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

Class RDDReadServer

Constructor Summary

Method Summary

Methods inherited from class java.lang.Object

Constructor Detail

RDDReadServer

Method Detail

getLocalHostLANAddress

start

blockUntilShutdown