public class LowLevelCacheImpl extends Object implements LowLevelCache, BufferUsageManager, LlapOomDebugDump
LowLevelCache.Priority
Constructor and Description |
---|
LowLevelCacheImpl(LlapDaemonCacheMetrics metrics,
LowLevelCachePolicy cachePolicy,
org.apache.hadoop.hive.common.io.Allocator allocator,
boolean doAssumeGranularBlocks) |
Modifier and Type | Method and Description |
---|---|
static LlapDataBuffer |
allocateFake() |
String |
debugDumpForOom() |
void |
debugDumpShort(StringBuilder sb) |
void |
decRefBuffer(org.apache.hadoop.hive.common.io.encoded.MemoryBuffer buffer) |
void |
decRefBuffers(List<org.apache.hadoop.hive.common.io.encoded.MemoryBuffer> cacheBuffers) |
org.apache.hadoop.hive.common.io.Allocator |
getAllocator() |
org.apache.hadoop.hive.common.io.DiskRangeList |
getFileData(Object fileKey,
org.apache.hadoop.hive.common.io.DiskRangeList ranges,
long baseOffset,
org.apache.hadoop.hive.common.io.DataCache.DiskRangeListFactory factory,
LowLevelCacheCounters qfCounters,
org.apache.hadoop.hive.common.io.DataCache.BooleanRef gotAllData)
Gets file data for particular offsets.
|
boolean |
incRefBuffer(org.apache.hadoop.hive.common.io.encoded.MemoryBuffer buffer) |
void |
notifyEvicted(org.apache.hadoop.hive.common.io.encoded.MemoryBuffer buffer)
Notifies the cache that a particular buffer should be removed due to eviction.
|
long[] |
putFileData(Object fileKey,
org.apache.hadoop.hive.common.io.DiskRange[] ranges,
org.apache.hadoop.hive.common.io.encoded.MemoryBuffer[] buffers,
long baseOffset,
LowLevelCache.Priority priority,
LowLevelCacheCounters qfCounters,
String tag)
Puts file data into cache.
|
void |
startThreads() |
public LowLevelCacheImpl(LlapDaemonCacheMetrics metrics, LowLevelCachePolicy cachePolicy, org.apache.hadoop.hive.common.io.Allocator allocator, boolean doAssumeGranularBlocks)
public void startThreads()
public org.apache.hadoop.hive.common.io.DiskRangeList getFileData(Object fileKey, org.apache.hadoop.hive.common.io.DiskRangeList ranges, long baseOffset, org.apache.hadoop.hive.common.io.DataCache.DiskRangeListFactory factory, LowLevelCacheCounters qfCounters, org.apache.hadoop.hive.common.io.DataCache.BooleanRef gotAllData)
LowLevelCache
getFileData
in interface LowLevelCache
public long[] putFileData(Object fileKey, org.apache.hadoop.hive.common.io.DiskRange[] ranges, org.apache.hadoop.hive.common.io.encoded.MemoryBuffer[] buffers, long baseOffset, LowLevelCache.Priority priority, LowLevelCacheCounters qfCounters, String tag)
LowLevelCache
putFileData
in interface LowLevelCache
public void decRefBuffer(org.apache.hadoop.hive.common.io.encoded.MemoryBuffer buffer)
decRefBuffer
in interface BufferUsageManager
public void decRefBuffers(List<org.apache.hadoop.hive.common.io.encoded.MemoryBuffer> cacheBuffers)
decRefBuffers
in interface BufferUsageManager
public static LlapDataBuffer allocateFake()
public final void notifyEvicted(org.apache.hadoop.hive.common.io.encoded.MemoryBuffer buffer)
LowLevelCache
notifyEvicted
in interface LowLevelCache
public boolean incRefBuffer(org.apache.hadoop.hive.common.io.encoded.MemoryBuffer buffer)
incRefBuffer
in interface BufferUsageManager
public org.apache.hadoop.hive.common.io.Allocator getAllocator()
getAllocator
in interface BufferUsageManager
public String debugDumpForOom()
debugDumpForOom
in interface LlapOomDebugDump
public void debugDumpShort(StringBuilder sb)
debugDumpShort
in interface LlapOomDebugDump
Copyright © 2022 The Apache Software Foundation. All rights reserved.