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()