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

All Methods Instance Methods Concrete Methods
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()
```

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

Constructor Summary

Method Summary

Methods inherited from class java.lang.Object

Constructor Detail

NettyServer

Method Detail

startServer

preSuperStep

getNumberOfByteReceived

resetBytesCounter

close

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