org.apache.hadoop.hive.llap.cache

Class LowLevelLrfuCachePolicy

java.lang.Object

org.apache.hadoop.hive.llap.cache.LowLevelLrfuCachePolicy

All Implemented Interfaces:

LlapOomDebugDump, LowLevelCachePolicy

public class LowLevelLrfuCachePolicy
extends Object
implements LowLevelCachePolicy

Implementation of the algorithm from "On the Existence of a Spectrum of Policies that Subsumes the Least Recently Used (LRU) and Least Frequently Used (LFU) Policies". Additionally, buffer locking has to be handled (locked buffer cannot be evicted).

Constructor Summary

Constructors

Constructor and Description
LowLevelLrfuCachePolicy(int minBufferSize, long maxSize, org.apache.hadoop.conf.Configuration conf)

Method Summary

Modifier and Type	Method and Description
void	cache(LlapCacheableBuffer buffer, LowLevelCache.Priority priority)
String	debugDumpForOom()
String	debugDumpHeap()
void	debugDumpShort(StringBuilder sb)
long	evictSomeBlocks(long memoryToReserve)
void	notifyLock(LlapCacheableBuffer buffer)
void	notifyUnlock(LlapCacheableBuffer buffer)
long	purge()
void	setEvictionListener(EvictionListener listener)
void	setParentDebugDumper(LlapOomDebugDump dumper)

Methods inherited from class java.lang.Object

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

Constructor Detail

LowLevelLrfuCachePolicy

public LowLevelLrfuCachePolicy(int minBufferSize,
                               long maxSize,
                               org.apache.hadoop.conf.Configuration conf)

Method Detail

cache

public void cache(LlapCacheableBuffer buffer,
                  LowLevelCache.Priority priority)

Specified by:

cache in interface LowLevelCachePolicy

notifyLock

public void notifyLock(LlapCacheableBuffer buffer)

Specified by:

notifyLock in interface LowLevelCachePolicy

notifyUnlock

public void notifyUnlock(LlapCacheableBuffer buffer)

Specified by:

notifyUnlock in interface LowLevelCachePolicy

setEvictionListener

public void setEvictionListener(EvictionListener listener)

Specified by:

setEvictionListener in interface LowLevelCachePolicy

setParentDebugDumper

public void setParentDebugDumper(LlapOomDebugDump dumper)

Specified by:

setParentDebugDumper in interface LowLevelCachePolicy

purge

public long purge()

Specified by:

purge in interface LowLevelCachePolicy

evictSomeBlocks

public long evictSomeBlocks(long memoryToReserve)

Specified by:

evictSomeBlocks in interface LowLevelCachePolicy

debugDumpHeap

public String debugDumpHeap()

debugDumpForOom

public String debugDumpForOom()

Specified by:

debugDumpForOom in interface LlapOomDebugDump

debugDumpShort

public void debugDumpShort(StringBuilder sb)

Specified by:

debugDumpShort in interface LlapOomDebugDump