Package com.alibaba.graphscope.graph.comm.netty

Class AggregatorNettyClient

java.lang.Object

com.alibaba.graphscope.graph.comm.netty.AggregatorNettyClient

public class AggregatorNettyClient
extends Object

The implementation class which do responsible for all netty-related stuff.

Field Summary

Fields

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

Constructor Summary

Constructors

Constructor	Description
AggregatorNettyClient(ImmutableClassesGiraphConfiguration conf, AggregatorManager aggregatorManager, WorkerInfo workerInfo, Thread.UncaughtExceptionHandler exceptionHandler)

Method Summary

Modifier and Type	Method	Description
void	close()
NettyMessage	getResponse()
boolean	isConnected()
Future<NettyMessage>	sendMessage(NettyMessage request)

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, 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

SIZE

public static final int SIZE

See Also:

Constant Field Values

Constructor Detail

AggregatorNettyClient

public AggregatorNettyClient(ImmutableClassesGiraphConfiguration conf,
                             AggregatorManager aggregatorManager,
                             WorkerInfo workerInfo,
                             Thread.UncaughtExceptionHandler exceptionHandler)

Method Detail

isConnected

public boolean isConnected()

sendMessage

public Future<NettyMessage> sendMessage(NettyMessage request)

getResponse

public NettyMessage getResponse()

close

public void close()