edu.iu.dsc.tws.comms.shuffle

Class ControlledFileReaderFlags

java.lang.Object

edu.iu.dsc.tws.comms.shuffle.ControlledFileReaderFlags

public class ControlledFileReaderFlags
extends java.lang.Object

Memory mappable limit can be increased in linux with following command. sysctl -w vm.max_map_count=files_count

Constructor Summary

Constructors

Constructor and Description
ControlledFileReaderFlags(long softMemoryLimit, java.util.Comparator keyComparator)
ControlledFileReaderFlags(long softMemoryLimit, long memMapLimit, java.util.Comparator keyComparator) This constructor can be used to configure an instance with an arbitrary amount of mem maps.

Method Summary

Modifier and Type	Method and Description
void	decreaseMemoryLoad(int amount)
boolean	hasMemMapLimitReached()
boolean	hasMemoryLimitReached()
void	increaseMemMapLoad(ControlledFileReader reader)
void	increaseMemoryLoad(int amount)
void	reset()

Methods inherited from class java.lang.Object

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

Constructor Detail

ControlledFileReaderFlags

public ControlledFileReaderFlags(long softMemoryLimit,
                                 java.util.Comparator keyComparator)

ControlledFileReaderFlags

public ControlledFileReaderFlags(long softMemoryLimit,
                                 long memMapLimit,
                                 java.util.Comparator keyComparator)

This constructor can be used to configure an instance with an arbitrary amount of mem maps. Currently we are not using this though.

Method Detail

hasMemoryLimitReached

public boolean hasMemoryLimitReached()

increaseMemoryLoad

public void increaseMemoryLoad(int amount)

decreaseMemoryLoad

public void decreaseMemoryLoad(int amount)

increaseMemMapLoad

public void increaseMemMapLoad(ControlledFileReader reader)

hasMemMapLimitReached

public boolean hasMemMapLimitReached()

reset

public void reset()