org.apache.giraph.comm.netty.handler

Class TaskRequestIdGenerator

java.lang.Object

org.apache.giraph.comm.netty.handler.TaskRequestIdGenerator

public class TaskRequestIdGenerator
extends Object

Generate different request ids based on the task id. Thread-safe.

Constructor Summary

Constructors

Constructor and Description
TaskRequestIdGenerator()

Method Summary

Modifier and Type	Method and Description
Long	getNextRequestId(Integer taskId) Get the next request id for a given destination.

Methods inherited from class java.lang.Object

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

Constructor Detail

TaskRequestIdGenerator

public TaskRequestIdGenerator()

Method Detail

getNextRequestId

public Long getNextRequestId(Integer taskId)

Get the next request id for a given destination. Thread-safe.

Parameters:

taskId - id of the task(consistent during a superstep)

Returns:

Valid request id