org.mapdb

Class StoreWAL

StoreDirectAbstract

org.mapdb.StoreWAL

All Implemented Interfaces:

ConcurrencyAware, Store, StoreImmutable, StoreTx, Verifiable

public class StoreWAL
extends StoreDirectAbstract
implements StoreTx

StoreDirect with write ahead log

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
static class	StoreWAL.Companion

Nested classes/interfaces inherited from interface org.mapdb.ConcurrencyAware

ConcurrencyAware.DefaultImpls

Field Summary

Fields

Modifier and Type	Field and Description
static StoreWAL.Companion	Companion

Constructor Summary

Constructors

Constructor and Description
StoreWAL(java.lang.String file, VolumeFactory volumeFactory, long fileLockWait, boolean isThreadSafe, int concShift, long allocateIncrement, long allocateStartSize, boolean fileDeleteAfterClose, boolean fileDeleteAfterOpen, boolean checksum, boolean checksumHeader, boolean checksumHeaderBypass) StoreDirect with write ahead log

Method Summary

Modifier and Type	Method and Description
long	allocateNewIndexPage()
long	allocateNewPage()
void	close()
void	commit()
void	compact()
<R> boolean	compareAndSwap(long recid, R expectedOldRecord, R newRecord, Serializer<R> serializer)
<R> void	delete(long recid, Serializer<R> serializer)
boolean	fileLoad()
void	freeSizeIncrement(long increment)
<R> R	get(long recid, Serializer<R> serializer)
java.lang.Iterable<java.lang.String>	getAllFiles()
LongIterator	getAllRecids()
NonExistentClass	getAllocatedPages()
NonExistentClass	getCacheIndexLinks()
NonExistentClass	getCacheIndexVals() modified indexVals, key is offset, value is indexValue
NonExistentClass	getCacheRecords() modified records, key is offset, value is WAL ID
NonExistentClass	getCacheStacks() stack pages, key is offset, value is content
byte[]	getHeadBytes() header is stored in-memory, so it can be rolled back
SingleByteArrayVol	getHeadVol()
long[]	getIndexPagesBackup() backup for indexPages, restored on rollback
long	getIndexVal(long recid)
Volume	getRealVolume()
Volume	getVolume()
WriteAheadLog	getWal()
boolean	isReadOnly()
void	linkedRecordDelete(long indexValue, long recid)
byte[]	linkedRecordGet(long indexValue, long recid)
long	linkedRecordPut(byte[] output, int size, long recid)
long	longStackFindEnd(long pageOffset, long pos)
void	longStackNewChunk(long masterLinkOffset, long prevPageOffset, long value, long valueSize, boolean recursive)
void	longStackPut(long masterLinkOffset, long value, boolean recursive)
long	longStackTake(long masterLinkOffset, boolean recursive)
long	preallocate()
<R> long	put(R record, Serializer<R> serializer)
void	rollback()
void	setIndexPagesBackup(long[] p) backup for indexPages, restored on rollback
void	setIndexVal(long recid, long value)
<R> void	update(long recid, R record, Serializer<R> serializer)
void	verify()

Methods inherited from class org.mapdb.StoreDirectAbstract

allocateData, allocateNewIndexPage, allocateNewPage, allocateRecid, assertNotClosed, calculateChecksum, calculateHeaderChecksum, checkThreadSafe, deserialize, fileHeaderCheck, fileHeaderCompose, freeSizeIncrement, getChecksum, getChecksumHeader, getChecksumHeaderBypass, getClosed, getConcShift, getDataTail, getFile, getFileDeleteAfterClose, getFileTail$module, getHeadVol, getIndexPages, getIndexVal, getLocks, getMaxRecid, getSegmentCount, getSegmentMask, getStructuralLock, getVolume, getVolumeExistsAtStart, getVolumeFactory, indexValCompose, indexValFlagArchive, indexValFlagLinked, indexValFlagUnused, isClosed, isThreadSafe, loadIndexPages, longStackMasterLinkOffset, longStackPut, longStackTake, recidToOffset, recidToSegment, releaseData, releaseRecid, serialize, setDataTail, setFileTail$module, setIndexVal, setMaxRecid, storeHeaderCompose

Methods inherited from interface org.mapdb.StoreTx

rollback

Methods inherited from interface org.mapdb.Store

close, commit, compact, compareAndSwap, delete, fileLoad, isClosed, isReadOnly, preallocate, put, update, verify

Methods inherited from interface org.mapdb.StoreImmutable

get, getAllFiles, getAllRecids

Methods inherited from interface org.mapdb.Verifiable

verify

Methods inherited from interface org.mapdb.ConcurrencyAware

checkThreadSafe, isThreadSafe

Field Detail

Companion

public static StoreWAL.Companion Companion

Constructor Detail

StoreWAL

public StoreWAL(java.lang.String file,
                VolumeFactory volumeFactory,
                long fileLockWait,
                boolean isThreadSafe,
                int concShift,
                long allocateIncrement,
                long allocateStartSize,
                boolean fileDeleteAfterClose,
                boolean fileDeleteAfterOpen,
                boolean checksum,
                boolean checksumHeader,
                boolean checksumHeaderBypass)

StoreDirect with write ahead log

Method Detail

getRealVolume

public Volume getRealVolume()

getVolume

public Volume getVolume()

getHeadBytes

public byte[] getHeadBytes()

header is stored in-memory, so it can be rolled back

getHeadVol

public SingleByteArrayVol getHeadVol()

getCacheStacks

public NonExistentClass getCacheStacks()

stack pages, key is offset, value is content

getCacheIndexVals

public NonExistentClass getCacheIndexVals()

modified indexVals, key is offset, value is indexValue

getCacheIndexLinks

public NonExistentClass getCacheIndexLinks()

getCacheRecords

public NonExistentClass getCacheRecords()

modified records, key is offset, value is WAL ID

getWal

public WriteAheadLog getWal()

getIndexPagesBackup

public long[] getIndexPagesBackup()

backup for indexPages, restored on rollback

setIndexPagesBackup

public void setIndexPagesBackup(long[] p)

backup for indexPages, restored on rollback

getAllocatedPages

public NonExistentClass getAllocatedPages()

isReadOnly

public boolean isReadOnly()

getIndexVal

public long getIndexVal(long recid)

setIndexVal

public void setIndexVal(long recid,
                        long value)

compareAndSwap

public <R> boolean compareAndSwap(long recid,
                                  R expectedOldRecord,
                                  R newRecord,
                                  Serializer<R> serializer)

delete

public <R> void delete(long recid,
                       Serializer<R> serializer)

preallocate

public long preallocate()

linkedRecordGet

public byte[] linkedRecordGet(long indexValue,
                              long recid)

linkedRecordDelete

public void linkedRecordDelete(long indexValue,
                               long recid)

linkedRecordPut

public long linkedRecordPut(byte[] output,
                            int size,
                            long recid)

put

public <R> long put(R record,
                    Serializer<R> serializer)

update

public <R> void update(long recid,
                       R record,
                       Serializer<R> serializer)

get

public <R> R get(long recid,
                 Serializer<R> serializer)

getAllRecids

public LongIterator getAllRecids()

verify

public void verify()

close

public void close()

rollback

public void rollback()

commit

public void commit()

compact

public void compact()

allocateNewPage

public long allocateNewPage()

allocateNewIndexPage

public long allocateNewIndexPage()

freeSizeIncrement

public void freeSizeIncrement(long increment)

longStackPut

public void longStackPut(long masterLinkOffset,
                         long value,
                         boolean recursive)

longStackNewChunk

public void longStackNewChunk(long masterLinkOffset,
                              long prevPageOffset,
                              long value,
                              long valueSize,
                              boolean recursive)

longStackTake

public long longStackTake(long masterLinkOffset,
                          boolean recursive)

longStackFindEnd

public long longStackFindEnd(long pageOffset,
                             long pos)

fileLoad

public boolean fileLoad()

getAllFiles

public java.lang.Iterable<java.lang.String> getAllFiles()