public class StoreTrivial implements Store
Store which serializes its content into primitive Map
.
It optionally persist its content into file, in this case it supports rollback and durability.
Modifier and Type | Class and Description |
---|---|
static class |
StoreTrivial.Companion |
ConcurrencyAware.DefaultImpls
Modifier and Type | Field and Description |
---|---|
static StoreTrivial.Companion |
Companion |
Constructor and Description |
---|
StoreTrivial(boolean isThreadSafe)
Store which serializes its content into primitive
Map .
It optionally persist its content into file, in this case it supports rollback and durability. |
StoreTrivial()
Store which serializes its content into primitive
Map .
It optionally persist its content into file, in this case it supports rollback and durability. |
Modifier and Type | Method and Description |
---|---|
void |
checkThreadSafe()
checks all subcomponents, if this component is really thread safe, and throws an exception if not thread safe
|
void |
clear() |
void |
clearInternal$module() |
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 |
equals(java.lang.Object other) |
void |
fileHeaderCheck(long header) |
long |
fileHeaderCompose() |
boolean |
fileLoad() |
<R> R |
get(long recid,
Serializer<R> serializer) |
java.lang.Iterable<java.lang.String> |
getAllFiles() |
LongIterator |
getAllRecids() |
java.util.concurrent.locks.ReadWriteLock |
getLock() |
boolean |
isClosed() |
boolean |
isReadOnly() |
boolean |
isThreadSafe()
returns true if this is configured to be thread safe
|
void |
loadFrom(java.io.InputStream inStream) |
void |
loadFromInternal(java.io.InputStream inStream) |
long |
preallocate() |
<R> long |
put(R record,
Serializer<R> serializer) |
void |
saveTo(java.io.OutputStream outStream) |
<R> void |
update(long recid,
R record,
Serializer<R> serializer) |
void |
verify() |
close, commit, compact, compareAndSwap, delete, fileLoad, isClosed, isReadOnly, preallocate, put, update, verify
get, getAllFiles, getAllRecids
verify
checkThreadSafe, isThreadSafe
public static StoreTrivial.Companion Companion
public StoreTrivial(boolean isThreadSafe)
Store which serializes its content into primitive Map
.
It optionally persist its content into file, in this case it supports rollback and durability.
isThreadSafe
- returns true if this is configured to be thread safepublic StoreTrivial()
Store which serializes its content into primitive Map
.
It optionally persist its content into file, in this case it supports rollback and durability.
public java.util.concurrent.locks.ReadWriteLock getLock()
public void loadFrom(java.io.InputStream inStream)
public void loadFromInternal(java.io.InputStream inStream)
public void fileHeaderCheck(long header)
public long fileHeaderCompose()
public void saveTo(java.io.OutputStream outStream)
public long preallocate()
public <R> long put(R record, Serializer<R> serializer)
public <R> void update(long recid, R record, Serializer<R> serializer)
public <R> boolean compareAndSwap(long recid, R expectedOldRecord, R newRecord, Serializer<R> serializer)
public <R> void delete(long recid, Serializer<R> serializer)
public void commit()
public void compact()
public void close()
public boolean isClosed()
public <R> R get(long recid, Serializer<R> serializer)
public void clear()
public void clearInternal$module()
public boolean equals(java.lang.Object other)
public LongIterator getAllRecids()
public void verify()
public boolean isReadOnly()
public boolean fileLoad()
public java.lang.Iterable<java.lang.String> getAllFiles()
public boolean isThreadSafe()
returns true if this is configured to be thread safe
public void checkThreadSafe()
checks all subcomponents, if this component is really thread safe, and throws an exception if not thread safe