Modifier and Type | Class and Description |
---|---|
class |
AsyncWriteEngine
Engine wrapper which provides asynchronous serialization and asynchronous write. |
static class |
Caches.HardRef
Cache created objects using hard reference.
|
static class |
Caches.HashTable
Fixed size cache which uses hash table.
|
static class |
Caches.LRU
Least Recently Used cache.
|
static class |
Caches.WeakSoftRef
Instance cache which uses
SoftReference or WeakReference
Items can be removed from cache by Garbage Collector if |
class |
EngineWrapper
EngineWrapper adapter.
|
static class |
EngineWrapper.CloseOnJVMShutdown
Closes Engine on JVM shutdown using shutdown hook:
Runtime.addShutdownHook(Thread)
If engine was closed by user before JVM shutdown, hook is removed to save memory. |
static class |
EngineWrapper.ImmutabilityCheckEngine
check if Record Instances were not modified while in cache.
|
static class |
EngineWrapper.ReadOnlyEngine
Wraps an
Engine and throws
UnsupportedOperationException("Read-only")
on any modification attempt. |
static class |
EngineWrapper.SerializerCheckEngineWrapper
Checks that Serializer used to serialize item is the same as Serializer used to deserialize it
|
static class |
EngineWrapper.SynchronizedEngineWrapper
Engine wrapper with all methods synchronized on global lock, useful to diagnose concurrency issues.
|
class |
Store
Low level record store.
|
class |
StoreDirect
Storage Engine which saves record directly into file.
|
class |
StoreHeap
Store which keeps all instances on heap.
|
class |
StoreWAL
Write-Ahead-Log
|
class |
TxEngine
Naive implementation of Snapshots on top of StorageEngine.
|
class |
TxEngine.Tx |
Modifier and Type | Field and Description |
---|---|
static Engine |
EngineWrapper.CLOSED
throws `IllegalArgumentError("already closed)` on all access
|
protected Engine |
TxMaker.engine
parent engine under which modifications are stored
|
protected Engine |
Queues.SimpleQueue.engine |
protected Engine |
BTreeMap.engine
DB Engine in which entries are persisted
|
protected Engine |
HTreeMap.engine |
protected Engine |
DB.engine
Engine which provides persistence for this DB
|
protected Engine |
Atomic.Integer.engine |
protected Engine |
Atomic.Long.engine |
protected Engine |
Atomic.Boolean.engine |
protected Engine |
Atomic.String.engine |
protected Engine |
Atomic.Var.engine |
Modifier and Type | Method and Description |
---|---|
static Engine |
TxEngine.createSnapshotFor(Engine engine) |
protected Engine |
DBMaker.extendAsyncWriteEngine(Engine engine) |
protected Engine |
DBMaker.extendCacheHardRef(Engine engine) |
protected Engine |
DBMaker.extendCacheHashTable(Engine engine) |
protected Engine |
DBMaker.extendCacheLRU(Engine engine) |
protected Engine |
DBMaker.extendCacheSoftRef(Engine engine) |
protected Engine |
DBMaker.extendCacheWeakRef(Engine engine) |
protected Engine |
DBMaker.extendHeapStore() |
protected Engine |
DBMaker.extendSnapshotEngine(Engine engine) |
protected Engine |
DBMaker.extendStoreAppend() |
protected Engine |
DBMaker.extendStoreDirect(Volume.Factory folFac) |
protected Engine |
DBMaker.extendStoreWAL(Volume.Factory folFac) |
protected Engine |
DBMaker.extendWrapCache(Engine engine) |
protected Engine |
DBMaker.extendWrapSnapshotEngine(Engine engine) |
protected Engine |
DBMaker.extendWrapStore(Engine engine) |
protected Engine |
SerializerPojo.getEngine() |
Engine |
BTreeMap.getEngine() |
Engine |
HTreeMap.getEngine() |
Engine |
DB.getEngine() |
protected Engine |
SerializerBase.getEngine() |
Engine |
EngineWrapper.getWrappedEngine() |
Engine |
TxEngine.Tx.getWrappedEngine() |
Engine |
DBMaker.makeEngine()
constructs Engine using current settings
|
Engine |
Store.snapshot() |
Engine |
EngineWrapper.snapshot() |
Engine |
EngineWrapper.ReadOnlyEngine.snapshot() |
Engine |
EngineWrapper.SynchronizedEngineWrapper.snapshot() |
Engine |
TxEngine.snapshot() |
Engine |
TxEngine.Tx.snapshot() |
Engine |
Engine.snapshot()
Returns read-only snapshot of data in Engine.
|
Modifier and Type | Method and Description |
---|---|
static <E,K,V> long |
Pump.buildTreeMap(Iterator<E> source,
Engine engine,
Fun.Function1<K,E> keyExtractor,
Fun.Function1<V,E> valueExtractor,
boolean ignoreDuplicates,
int nodeSize,
boolean valuesStoredOutsideNodes,
long counterRecid,
BTreeKeySerializer<K> keySerializer,
Serializer<V> valueSerializer,
Comparator comparator)
Build BTreeMap (or TreeSet) from presorted data.
|
protected static long |
BTreeMap.createRootRef(Engine engine,
BTreeKeySerializer keySer,
Serializer valueSer,
Comparator comparator,
int numberOfNodeMetas)
creates empty root node and returns recid of its reference
|
static Engine |
TxEngine.createSnapshotFor(Engine engine) |
protected Engine |
DBMaker.extendAsyncWriteEngine(Engine engine) |
protected Engine |
DBMaker.extendCacheHardRef(Engine engine) |
protected Engine |
DBMaker.extendCacheHashTable(Engine engine) |
protected Engine |
DBMaker.extendCacheLRU(Engine engine) |
protected Engine |
DBMaker.extendCacheSoftRef(Engine engine) |
protected Engine |
DBMaker.extendCacheWeakRef(Engine engine) |
protected Engine |
DBMaker.extendSnapshotEngine(Engine engine) |
protected Engine |
DBMaker.extendWrapCache(Engine engine) |
protected Engine |
DBMaker.extendWrapSnapshotEngine(Engine engine) |
protected Engine |
DBMaker.extendWrapStore(Engine engine) |
static Store |
Store.forEngine(Engine e)
traverses
EngineWrapper s and returns underlying Store |
protected static long[] |
HTreeMap.preallocateSegments(Engine engine) |
void |
SerializerPojo.save(Engine e) |
Constructor and Description |
---|
AsyncWriteEngine(Engine engine) |
AsyncWriteEngine(Engine engine,
int _asyncFlushDelay,
int queueSize,
Executor executor)
Construct new class and starts background threads.
|
Boolean(Engine engine,
long recid) |
BTreeMap(Engine engine,
long rootRecidRef,
int maxNodeSize,
boolean valsOutsideNodes,
long counterRecid,
BTreeKeySerializer<K> keySerializer,
Serializer<V> valueSerializer,
Comparator<K> comparator,
int numberOfNodeMetas,
boolean disableLocks)
Constructor used to create new BTreeMap.
|
CircularQueue(Engine engine,
Serializer<E> serializer,
long headRecid,
long headInsertRecid,
long size) |
CloseOnJVMShutdown(Engine engine) |
DB(Engine engine)
Construct new DB.
|
DB(Engine engine,
boolean strictDBGet,
boolean disableLocks) |
EngineWrapper(Engine engine) |
HardRef(Engine engine,
int initialCapacity,
boolean disableLocks) |
HashTable(Engine engine,
int cacheMaxSize,
boolean disableLocks) |
HTreeMap(Engine engine,
long counterRecid,
int hashSalt,
long[] segmentRecids,
Serializer<K> keySerializer,
Serializer<V> valueSerializer,
long expireTimeStart,
long expire,
long expireAccess,
long expireMaxSize,
long expireStoreSize,
long[] expireHeads,
long[] expireTails,
Fun.Function1<V,K> valueCreator,
Hasher hasher,
boolean disableLocks)
Opens HTreeMap
|
ImmutabilityCheckEngine(Engine engine) |
Integer(Engine engine,
long recid) |
Long(Engine engine,
long recid) |
LRU(Engine engine,
int cacheSize,
boolean disableLocks) |
LRU(Engine engine,
LongMap<Object> cache,
boolean disableLocks) |
Queue(Engine engine,
Serializer<E> serializer,
long headerRecid,
long nextTailRecid,
boolean useLocks) |
ReadOnlyEngine(Engine engine) |
SerializerCheckEngineWrapper(Engine engine) |
SimpleQueue(Engine engine,
Serializer<E> serializer,
long headRecidRef,
boolean useLocks) |
Stack(Engine engine,
Serializer<E> serializer,
long headerRecidRef,
boolean useLocks) |
String(Engine engine,
long recid) |
SynchronizedEngineWrapper(Engine engine) |
TxEngine(Engine engine,
boolean fullTx) |
TxMaker(Engine engine) |
TxMaker(Engine engine,
boolean strictDBGet,
boolean txSnapshotsEnabled) |
Var(Engine engine,
long recid,
Serializer<E> serializer) |
Var(Engine engine,
SerializerBase serializerBase,
DataInput is,
SerializerBase.FastArrayList<Object> objectStack)
used for deserialization
|
WeakSoftRef(Engine engine,
boolean useWeakRef,
boolean disableLocks) |
Copyright © 2015. All rights reserved.