Package com.alibaba.graphscope.parallel.netty

Class NettyServer<OID_T extends org.apache.hadoop.io.WritableComparable,GS_VID_T>

java.lang.Object

com.alibaba.graphscope.parallel.netty.NettyServer<OID_T,GS_VID_T>

public class NettyServer<OID_T extends org.apache.hadoop.io.WritableComparable,GS_VID_T>
extends Object

Constructor Summary

Constructors

Constructor	Description
NettyServer(ImmutableClassesGiraphConfiguration conf, IFragment fragment, NetworkMap networkMap, MessageStore<OID_T,org.apache.hadoop.io.Writable,GS_VID_T> nextIncomingMessages, Thread.UncaughtExceptionHandler exceptionHandler)

Method Summary

Modifier and Type	Method	Description
void	close()
long	getNumberOfByteReceived()
void	preSuperStep(MessageStore<OID_T,org.apache.hadoop.io.Writable,GS_VID_T> nextIncomingMessages)
void	resetBytesCounter()
void	startServer()

Methods inherited from class java.lang.Object

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

Constructor Detail

NettyServer

public NettyServer(ImmutableClassesGiraphConfiguration conf,
                   IFragment fragment,
                   NetworkMap networkMap,
                   MessageStore<OID_T,org.apache.hadoop.io.Writable,GS_VID_T> nextIncomingMessages,
                   Thread.UncaughtExceptionHandler exceptionHandler)

Method Detail

startServer

public void startServer()

preSuperStep

public void preSuperStep(MessageStore<OID_T,org.apache.hadoop.io.Writable,GS_VID_T> nextIncomingMessages)

getNumberOfByteReceived

public long getNumberOfByteReceived()

resetBytesCounter

public void resetBytesCounter()

close

public void close()