public class MetadataCache extends Object implements LlapOomDebugDump, org.apache.hadoop.hive.common.io.FileMetadataCache
Modifier and Type | Class and Description |
---|---|
static interface |
MetadataCache.LlapBufferOrBuffers |
static class |
MetadataCache.LlapMetadataBuffer<T> |
static class |
MetadataCache.LlapMetadataBuffers<T> |
Constructor and Description |
---|
MetadataCache(EvictionAwareAllocator allocator,
MemoryManager memoryManager,
LowLevelCachePolicy policy,
boolean useEstimateCache,
LlapDaemonCacheMetrics metrics) |
public MetadataCache(EvictionAwareAllocator allocator, MemoryManager memoryManager, LowLevelCachePolicy policy, boolean useEstimateCache, LlapDaemonCacheMetrics metrics)
public void putIncompleteCbs(Object fileKey, org.apache.hadoop.hive.common.io.DiskRange[] ranges, long baseOffset)
public org.apache.hadoop.hive.common.io.DiskRangeList getIncompleteCbs(Object fileKey, org.apache.hadoop.hive.common.io.DiskRangeList ranges, long baseOffset, org.apache.hadoop.hive.common.io.DataCache.BooleanRef gotAllData)
public void notifyEvicted(MetadataCache.LlapMetadataBuffer<?> buffer)
public void notifyEvicted(OrcFileEstimateErrors buffer)
public String debugDumpForOom()
debugDumpForOom
in interface LlapOomDebugDump
public void debugDumpShort(StringBuilder sb)
debugDumpShort
in interface LlapOomDebugDump
public MetadataCache.LlapBufferOrBuffers getFileMetadata(Object fileKey)
getFileMetadata
in interface org.apache.hadoop.hive.common.io.FileMetadataCache
public MetadataCache.LlapBufferOrBuffers getStripeTail(OrcBatchKey stripeKey)
public MetadataCache.LlapBufferOrBuffers putFileMetadata(Object fileKey, ByteBuffer tailBuffer)
putFileMetadata
in interface org.apache.hadoop.hive.common.io.FileMetadataCache
public MetadataCache.LlapBufferOrBuffers putFileMetadata(Object fileKey, ByteBuffer tailBuffer, String tag)
putFileMetadata
in interface org.apache.hadoop.hive.common.io.FileMetadataCache
public MetadataCache.LlapBufferOrBuffers putStripeTail(OrcBatchKey stripeKey, ByteBuffer tailBuffer, String tag)
public MetadataCache.LlapBufferOrBuffers putFileMetadata(Object fileKey, int length, InputStream is) throws IOException
putFileMetadata
in interface org.apache.hadoop.hive.common.io.FileMetadataCache
IOException
public MetadataCache.LlapBufferOrBuffers putFileMetadata(Object fileKey, int length, InputStream is, String tag) throws IOException
putFileMetadata
in interface org.apache.hadoop.hive.common.io.FileMetadataCache
IOException
public void decRefBuffer(org.apache.hadoop.hive.common.io.encoded.MemoryBufferOrBuffers buffer)
decRefBuffer
in interface org.apache.hadoop.hive.common.io.FileMetadataCache
public int determineAllocCount(ByteBuffer tailBuffer)
public boolean lockOneBuffer(LlapAllocatorBuffer buffer, boolean doNotifyPolicy)
Copyright © 2022 The Apache Software Foundation. All rights reserved.