Package com.alibaba.graphscope.parallel.netty

Class NettyClient

java.lang.Object

com.alibaba.graphscope.parallel.netty.NettyClient

public class NettyClient
extends Object

Field Summary

Fields

Modifier and Type	Field	Description
static int	MAX_CONNECTION_MILLISECONDS_DEFAULT	30 seconds to connect by default

Constructor Summary

Constructors

Constructor	Description
NettyClient(ImmutableClassesGiraphConfiguration conf, NetworkMap networkMap, Thread.UncaughtExceptionHandler exceptionHandler)

Method Summary

Modifier and Type	Method	Description
void	close()
void	connectToAllAddress()	Put connectToAllAddress out size of Constructor.
void	postSuperStep()
void	sendMessage(int dstFragId, WritableRequest request)
String	toString()
void	waitAllRequests()

Methods inherited from class java.lang.Object

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

Field Detail

MAX_CONNECTION_MILLISECONDS_DEFAULT

public static final int MAX_CONNECTION_MILLISECONDS_DEFAULT

30 seconds to connect by default

See Also:

Constant Field Values

Constructor Detail

NettyClient

public NettyClient(ImmutableClassesGiraphConfiguration conf,
                   NetworkMap networkMap,
                   Thread.UncaughtExceptionHandler exceptionHandler)

Method Detail

connectToAllAddress

public void connectToAllAddress()

Put connectToAllAddress out size of Constructor.

sendMessage

public void sendMessage(int dstFragId,
                        WritableRequest request)

postSuperStep

public void postSuperStep()

waitAllRequests

public void waitAllRequests()

toString

public String toString()

Overrides:

toString in class Object

close

public void close()