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

Class AggregatorNettyServer

java.lang.Object

com.alibaba.graphscope.graph.comm.netty.AggregatorNettyServer

public class AggregatorNettyServer
extends Object

This server uses Netty and will implement all Giraph communication

Constructor Summary

Constructors

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

Method Summary

Modifier and Type	Method	Description
void	close()
AtomicInteger	getMsgNo()

Methods inherited from class java.lang.Object

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

Constructor Detail

AggregatorNettyServer

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

Method Detail

getMsgNo

public AtomicInteger getMsgNo()

close

public void close()