Package | Description |
---|---|
com.bigdata.ha.halog | |
com.bigdata.io | |
com.bigdata.io.writecache |
Low-level write cache service.
|
com.bigdata.journal |
The journal is an append-only persistence capable data structure
supporting atomic commit, named indices, and transactions.
|
com.bigdata.rwstore |
Modifier and Type | Method and Description |
---|---|
static IHAWriteMessage |
HALogReader.processNextBuffer(RandomAccessFile raf,
IReopenChannel<FileChannel> reopener,
StoreTypeEnum storeType,
ByteBuffer clientBuffer) |
Modifier and Type | Class and Description |
---|---|
class |
NOPReopener
Implementation that will not re-open the
FileChannel once it has been
closed. |
Modifier and Type | Method and Description |
---|---|
static int |
FileChannelUtility.readAll(IReopenChannel<FileChannel> opener,
ByteBuffer src,
long pos)
Reads
Buffer.remaining() bytes into the caller's
ByteBuffer from the channel starting at offset pos. |
static int |
FileChannelUtility.writeAll(IReopenChannel<FileChannel> opener,
ByteBuffer data,
long pos)
Write bytes in data from the position to the limit on the channel
starting at pos.
|
Constructor and Description |
---|
FileChannelUtility.ReopenerInputStream(IReopenChannel<FileChannel> opener) |
Modifier and Type | Field and Description |
---|---|
IReopenChannel<FileChannel> |
WriteCache.FileChannelWriteCache.opener
Used to re-open the
FileChannel in this class. |
Modifier and Type | Method and Description |
---|---|
int |
BufferedWrite.flush(IReopenChannel<FileChannel> opener)
Flush buffered data to the backing channel.
|
abstract WriteCache |
WriteCacheService.newWriteCache(IBufferAccess buf,
boolean useChecksum,
boolean bufferHasData,
IReopenChannel<? extends Channel> opener,
long fileExtent)
Factory for
WriteCache implementations. |
int |
BufferedWrite.write(long offset,
ByteBuffer data,
IReopenChannel<FileChannel> opener)
Buffer a write.
|
Constructor and Description |
---|
WriteCache.FileChannelScatteredWriteCache(IBufferAccess buf,
boolean useChecksum,
boolean isHighlyAvailable,
boolean bufferHasData,
IReopenChannel<FileChannel> opener,
long fileExtent,
BufferedWrite bufferedWrite) |
WriteCache.FileChannelWriteCache(long baseOffset,
IBufferAccess buf,
boolean useChecksum,
boolean isHighlyAvailable,
boolean bufferHasData,
IReopenChannel<FileChannel> opener,
long fileExtent) |
WriteCacheService(int nwriteBuffers,
int minCleanListSize,
int nreadBuffers,
boolean prefixWrites,
int compactionThreshold,
int hotCacheSize,
int hotCacheThreshold,
boolean useChecksum,
long fileExtent,
IReopenChannel<? extends Channel> opener,
Quorum quorum,
IBackingReader reader)
Allocates N buffers from the
DirectBufferPool . |
Modifier and Type | Field and Description |
---|---|
protected IReopenChannel<FileChannel> |
DiskBackedBufferStrategy.opener
Used to re-open the
FileChannel in this class. |
Constructor and Description |
---|
RootBlockUtility(IReopenChannel<FileChannel> opener,
File file,
boolean validateChecksum,
boolean alternateRootBlock,
boolean ignoreBadRootBlock) |
Modifier and Type | Method and Description |
---|---|
WriteCache |
RWWriteCacheService.newWriteCache(IBufferAccess buf,
boolean useChecksum,
boolean bufferHasData,
IReopenChannel<? extends Channel> opener,
long fileExtent)
Provide default
WriteCache.FileChannelScatteredWriteCache . |
Constructor and Description |
---|
RWWriteCacheService(int nbuffers,
int minCleanListSize,
int readBuffers,
boolean prefixWrites,
int compactionThreshold,
int hotCacheSize,
int hotCacheThreshold,
long fileExtent,
IReopenChannel<? extends Channel> opener,
Quorum quorum,
IBackingReader reader) |
Copyright © 2006–2019 SYSTAP, LLC DBA Blazegraph. All rights reserved.