org.apache.giraph.comm.aggregators

Class CountingCache

java.lang.Object

org.apache.giraph.comm.aggregators.CountingCache

Direct Known Subclasses:

SendGlobalCommCache

public abstract class CountingCache
extends Object

Cache which counts the number of flushes per task id (destination worker id), so we know how many requests were sent to the worker

Constructor Summary

Constructors

Constructor and Description
CountingCache()

Method Summary

Modifier and Type	Method and Description
protected long	getCount(Integer taskId) Get number of flushes for worker with desired task id
protected void	incrementCounter(Integer taskId) Increase count of flushes for worker with desired task id.
void	reset() Reset the counts

Methods inherited from class java.lang.Object

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

Constructor Detail

CountingCache

public CountingCache()

Method Detail

incrementCounter

protected void incrementCounter(Integer taskId)

Increase count of flushes for worker with desired task id. Subclasses should call this method whenever flush is called.

Parameters:

taskId - Task id of worker

getCount

protected long getCount(Integer taskId)

Get number of flushes for worker with desired task id

Parameters:

taskId - Task id of worker

Returns:

Number of objects for the worker

reset

public void reset()

Reset the counts