org.apache.hadoop.hive.llap.cache

Class LowLevelCacheMemoryManager

java.lang.Object

org.apache.hadoop.hive.llap.cache.LowLevelCacheMemoryManager

All Implemented Interfaces:

LlapOomDebugDump, MemoryManager

public class LowLevelCacheMemoryManager
extends Object
implements MemoryManager

Implementation of memory manager for low level cache. Note that memory is released during reserve most of the time, by calling the evictor to evict some memory. releaseMemory is called rarely.

Constructor Summary

Constructors

Constructor and Description
LowLevelCacheMemoryManager(long maxSize, LowLevelCachePolicy evictor, LlapDaemonCacheMetrics metrics)

Method Summary

Modifier and Type	Method and Description
String	debugDumpForOom()
void	debugDumpShort(StringBuilder sb)
long	purge()
void	releaseMemory(long memoryToRelease)
void	reserveMemory(long memoryToReserve)
boolean	reserveMemory(long memoryToReserve, boolean waitForEviction)
void	updateMaxSize(long maxSize)

Methods inherited from class java.lang.Object

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

Constructor Detail

LowLevelCacheMemoryManager

public LowLevelCacheMemoryManager(long maxSize,
                                  LowLevelCachePolicy evictor,
                                  LlapDaemonCacheMetrics metrics)

Method Detail

reserveMemory

public void reserveMemory(long memoryToReserve)

Specified by:

reserveMemory in interface MemoryManager

reserveMemory

public boolean reserveMemory(long memoryToReserve,
                             boolean waitForEviction)

releaseMemory

public void releaseMemory(long memoryToRelease)

Specified by:

releaseMemory in interface MemoryManager

debugDumpForOom

public String debugDumpForOom()

Specified by:

debugDumpForOom in interface LlapOomDebugDump

debugDumpShort

public void debugDumpShort(StringBuilder sb)

Specified by:

debugDumpShort in interface LlapOomDebugDump

updateMaxSize

public void updateMaxSize(long maxSize)

Specified by:

updateMaxSize in interface MemoryManager

purge

public long purge()