org.apache.hadoop.hive.llap.cache

Class CacheContentsTracker

java.lang.Object

org.apache.hadoop.hive.llap.cache.CacheContentsTracker

All Implemented Interfaces:

EvictionListener, LlapOomDebugDump, LowLevelCachePolicy

public class CacheContentsTracker
extends Object
implements LowLevelCachePolicy, EvictionListener

A wrapper around cache eviction policy that tracks cache contents via tags.

Constructor Summary

Constructors

Constructor and Description
CacheContentsTracker(LowLevelCachePolicy realPolicy)

Method Summary

Modifier and Type	Method and Description
void	cache(LlapCacheableBuffer buffer, LowLevelCache.Priority priority)
String	debugDumpForOom()
void	debugDumpShort(StringBuilder sb)
long	evictSomeBlocks(long memoryToReserve)
void	notifyEvicted(LlapCacheableBuffer buffer)
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

CacheContentsTracker

public CacheContentsTracker(LowLevelCachePolicy realPolicy)

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

debugDumpForOom

public String debugDumpForOom()

Specified by:

debugDumpForOom in interface LlapOomDebugDump

debugDumpShort

public void debugDumpShort(StringBuilder sb)

Specified by:

debugDumpShort in interface LlapOomDebugDump

notifyEvicted

public void notifyEvicted(LlapCacheableBuffer buffer)

Specified by:

notifyEvicted in interface EvictionListener