public class LazyWriteBuffer extends Object
Modifier and Type | Class and Description |
---|---|
static class |
LazyWriteBuffer.RPolicy |
Constructor and Description |
---|
LazyWriteBuffer() |
Modifier and Type | Method and Description |
---|---|
static void |
cleanup() |
static void |
deleteBlock(String fname) |
static void |
forceEviction()
Evicts all buffer pool entries.
|
static long |
getCacheBlockSize(CacheBlock cb) |
static int |
getQueueSize() |
static ExecutorService |
getUtilThreadPool() |
static long |
getWriteBufferFree() |
static long |
getWriteBufferLimit() |
static long |
getWriteBufferSize() |
static void |
init() |
static void |
printStatus(String position)
Print current status of buffer pool, including all entries.
|
static CacheBlock |
readBlock(String fname,
boolean matrix) |
static int |
writeBlock(String fname,
CacheBlock cb) |
public static int writeBlock(String fname, CacheBlock cb) throws IOException
IOException
public static void deleteBlock(String fname)
public static CacheBlock readBlock(String fname, boolean matrix) throws IOException
IOException
public static void init()
public static void cleanup()
public static long getWriteBufferLimit()
public static long getWriteBufferSize()
public static long getWriteBufferFree()
public static int getQueueSize()
public static long getCacheBlockSize(CacheBlock cb)
public static void printStatus(String position)
position
- the positionpublic static void forceEviction() throws IOException
IOException
- if IOException occurspublic static ExecutorService getUtilThreadPool()
Copyright © 2020 The Apache Software Foundation. All rights reserved.