public class SerDeLowLevelCacheImpl extends Object implements BufferUsageManager, LlapOomDebugDump
Modifier and Type | Class and Description |
---|---|
static class |
SerDeLowLevelCacheImpl.FileData |
static class |
SerDeLowLevelCacheImpl.LlapSerDeDataBuffer |
static class |
SerDeLowLevelCacheImpl.StripeData |
Constructor and Description |
---|
SerDeLowLevelCacheImpl(LlapDaemonCacheMetrics metrics,
LowLevelCachePolicy cachePolicy,
org.apache.hadoop.hive.common.io.Allocator allocator) |
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() |
SerDeLowLevelCacheImpl.FileData |
getFileData(Object fileKey,
long start,
long end,
boolean[] includes,
org.apache.hadoop.hive.common.io.DataCache.DiskRangeListFactory factory,
LowLevelCacheCounters qfCounters,
org.apache.hadoop.hive.common.io.DataCache.BooleanRef gotAllData) |
boolean |
incRefBuffer(org.apache.hadoop.hive.common.io.encoded.MemoryBuffer buffer) |
void |
notifyEvicted(org.apache.hadoop.hive.common.io.encoded.MemoryBuffer buffer) |
void |
putFileData(SerDeLowLevelCacheImpl.FileData data,
LowLevelCache.Priority priority,
LowLevelCacheCounters qfCounters,
String tag) |
void |
startThreads() |
static String |
toString(SerDeLowLevelCacheImpl.LlapSerDeDataBuffer[][] data) |
static String |
toString(SerDeLowLevelCacheImpl.LlapSerDeDataBuffer[][][] data) |
public SerDeLowLevelCacheImpl(LlapDaemonCacheMetrics metrics, LowLevelCachePolicy cachePolicy, org.apache.hadoop.hive.common.io.Allocator allocator)
public static String toString(SerDeLowLevelCacheImpl.LlapSerDeDataBuffer[][][] data)
public static String toString(SerDeLowLevelCacheImpl.LlapSerDeDataBuffer[][] data)
public void startThreads()
public SerDeLowLevelCacheImpl.FileData getFileData(Object fileKey, long start, long end, boolean[] includes, org.apache.hadoop.hive.common.io.DataCache.DiskRangeListFactory factory, LowLevelCacheCounters qfCounters, org.apache.hadoop.hive.common.io.DataCache.BooleanRef gotAllData) throws IOException
IOException
public void putFileData(SerDeLowLevelCacheImpl.FileData data, LowLevelCache.Priority priority, LowLevelCacheCounters qfCounters, String tag)
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 final void notifyEvicted(org.apache.hadoop.hive.common.io.encoded.MemoryBuffer buffer)
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.