public class NettyMasterServer extends Object implements MasterServer
MasterServer
Constructor and Description |
---|
NettyMasterServer(ImmutableClassesGiraphConfiguration conf,
CentralizedServiceMaster<?,?,?> service,
org.apache.hadoop.util.Progressable progressable,
Thread.UncaughtExceptionHandler exceptionHandler)
Constructor
|
Modifier and Type | Method and Description |
---|---|
void |
close()
Shuts down.
|
String |
getLocalHostOrIp()
Get server host or IP
|
InetSocketAddress |
getMyAddress()
Get server address
|
void |
setFlowControl(FlowControl flowControl)
Inform the server about the flow control policy used in sending requests
|
public NettyMasterServer(ImmutableClassesGiraphConfiguration conf, CentralizedServiceMaster<?,?,?> service, org.apache.hadoop.util.Progressable progressable, Thread.UncaughtExceptionHandler exceptionHandler)
conf
- Hadoop configurationservice
- Centralized serviceprogressable
- Progressable for reporting progressexceptionHandler
- to handle uncaught exceptionspublic InetSocketAddress getMyAddress()
MasterServer
getMyAddress
in interface MasterServer
public String getLocalHostOrIp()
MasterServer
getLocalHostOrIp
in interface MasterServer
public void close()
MasterServer
close
in interface MasterServer
public void setFlowControl(FlowControl flowControl)
MasterServer
setFlowControl
in interface MasterServer
flowControl
- reference to flow control policyCopyright © 2011-2020 The Apache Software Foundation. All Rights Reserved.