Class LazyWriteBuffer
- java.lang.Object
- 
- org.apache.sysds.runtime.controlprogram.caching.LazyWriteBuffer
 
- 
 public class LazyWriteBuffer extends Object 
- 
- 
Nested Class SummaryNested Classes Modifier and Type Class Description static classLazyWriteBuffer.RPolicy
 - 
Constructor SummaryConstructors Constructor Description LazyWriteBuffer()
 - 
Method SummaryAll Methods Static Methods Concrete Methods Modifier and Type Method Description static voidcleanup()static voiddeleteBlock(String fname)static voidforceEviction()Evicts all buffer pool entries.static longgetCacheBlockSize(CacheBlock cb)static intgetQueueSize()static ExecutorServicegetUtilThreadPool()static longgetWriteBufferFree()static longgetWriteBufferLimit()static longgetWriteBufferSize()static voidinit()static voidprintStatus(String position)Print current status of buffer pool, including all entries.static CacheBlockreadBlock(String fname, boolean matrix)static voidsetWriteBufferLimit(long limit)static intwriteBlock(String fname, CacheBlock cb)
 
- 
- 
- 
Method Detail- 
writeBlockpublic static int writeBlock(String fname, CacheBlock cb) throws IOException - Throws:
- IOException
 
 - 
deleteBlockpublic static void deleteBlock(String fname) 
 - 
readBlockpublic static CacheBlock readBlock(String fname, boolean matrix) throws IOException - Throws:
- IOException
 
 - 
initpublic static void init() 
 - 
cleanuppublic static void cleanup() 
 - 
getWriteBufferLimitpublic static long getWriteBufferLimit() 
 - 
setWriteBufferLimitpublic static void setWriteBufferLimit(long limit) 
 - 
getWriteBufferSizepublic static long getWriteBufferSize() 
 - 
getWriteBufferFreepublic static long getWriteBufferFree() 
 - 
getQueueSizepublic static int getQueueSize() 
 - 
getCacheBlockSizepublic static long getCacheBlockSize(CacheBlock cb) 
 - 
printStatuspublic static void printStatus(String position) Print current status of buffer pool, including all entries. NOTE: use only for debugging or testing.- Parameters:
- position- the position
 
 - 
forceEvictionpublic static void forceEviction() throws IOExceptionEvicts all buffer pool entries. NOTE: use only for debugging or testing.- Throws:
- IOException- if IOException occurs
 
 - 
getUtilThreadPoolpublic static ExecutorService getUtilThreadPool() 
 
- 
 
-