@ThreadSafe public class LocalCacheManager extends Object implements CacheManager
CacheManager.Factory
Modifier and Type | Method and Description |
---|---|
void |
close() |
static LocalCacheManager |
create(AlluxioConfiguration conf) |
boolean |
delete(PageId pageId)
Deletes a page from the cache.
|
int |
get(PageId pageId,
int pageOffset,
int bytesToRead,
byte[] buffer,
int offsetInBuffer)
Reads a part of a page if the queried page is found in the cache, stores the result in
buffer.
|
boolean |
put(PageId pageId,
byte[] page)
Puts a page into the cache manager.
|
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
get
public static LocalCacheManager create(AlluxioConfiguration conf) throws IOException
conf
- the Alluxio configurationLocalCacheManager
IOException
public boolean put(PageId pageId, byte[] page)
CacheManager
put
in interface CacheManager
pageId
- page identifierpage
- page datapublic int get(PageId pageId, int pageOffset, int bytesToRead, byte[] buffer, int offsetInBuffer)
CacheManager
get
in interface CacheManager
pageId
- page identifierpageOffset
- offset into the pagebytesToRead
- number of bytes to read in this pagebuffer
- destination buffer to writeoffsetInBuffer
- offset in the destination buffer to writepublic boolean delete(PageId pageId)
CacheManager
delete
in interface CacheManager
pageId
- page identifierpublic void close() throws Exception
close
in interface AutoCloseable
Exception
Copyright © 2023. All Rights Reserved.