public class SimpleBufferManager extends Object implements BufferUsageManager, LowLevelCache
LowLevelCache.Priority
Constructor and Description |
---|
SimpleBufferManager(org.apache.hadoop.hive.common.io.Allocator allocator,
LlapDaemonCacheMetrics metrics) |
Modifier and Type | Method and Description |
---|---|
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 range,
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[] chunks,
long baseOffset,
LowLevelCache.Priority priority,
LowLevelCacheCounters qfCounters,
String tag)
Puts file data into cache.
|
public SimpleBufferManager(org.apache.hadoop.hive.common.io.Allocator allocator, LlapDaemonCacheMetrics metrics)
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 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 org.apache.hadoop.hive.common.io.DiskRangeList getFileData(Object fileKey, org.apache.hadoop.hive.common.io.DiskRangeList range, 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[] chunks, long baseOffset, LowLevelCache.Priority priority, LowLevelCacheCounters qfCounters, String tag)
LowLevelCache
putFileData
in interface LowLevelCache
public void notifyEvicted(org.apache.hadoop.hive.common.io.encoded.MemoryBuffer buffer)
LowLevelCache
notifyEvicted
in interface LowLevelCache
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.