org.apache.giraph.worker

Class MemoryObserver

java.lang.Object

org.apache.giraph.worker.MemoryObserver

public class MemoryObserver
extends Object

Memory observer to help synchronize when full gcs are happening across all the workers

Field Summary

Fields

Modifier and Type	Field and Description
static FloatConfOption	FREE_MEMORY_FRACTION_FOR_GC For which fraction of free memory will we issue manual gc calls
static IntConfOption	MIN_MS_BETWEEN_FULL_GCS Minimum milliseconds between two manual gc calls
static BooleanConfOption	USE_MEMORY_OBSERVER Whether or not to use memory observer

Constructor Summary

Constructors

Constructor and Description
MemoryObserver(ZooKeeperExt zk, String zkPath, GiraphConfiguration conf) Constructor

Method Summary

Modifier and Type	Method and Description
void	callGc() Manually call gc, if enough time from last call has passed

Methods inherited from class java.lang.Object

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

Field Detail

USE_MEMORY_OBSERVER

public static final BooleanConfOption USE_MEMORY_OBSERVER

Whether or not to use memory observer

FREE_MEMORY_FRACTION_FOR_GC

public static final FloatConfOption FREE_MEMORY_FRACTION_FOR_GC

For which fraction of free memory will we issue manual gc calls

MIN_MS_BETWEEN_FULL_GCS

public static final IntConfOption MIN_MS_BETWEEN_FULL_GCS

Minimum milliseconds between two manual gc calls

Constructor Detail

MemoryObserver

public MemoryObserver(ZooKeeperExt zk,
                      String zkPath,
                      GiraphConfiguration conf)

Constructor

Parameters:

zk - Zookeeper

zkPath - Path on zookeeper for memory observer files

conf - Configration

Method Detail

callGc

public void callGc()

Manually call gc, if enough time from last call has passed