| Package | Description |
|---|---|
| com.neocoretechs.rocksack |
Contains the lower level database constructs to support the sessions which create the maps.
|
| com.neocoretechs.rocksack.session |
Sessions and Managers facilitating the creation and operation of the various Maps.
|
| com.neocoretechs.rocksack.test |
Test batteries covering the range of operations.
|
| Modifier and Type | Class and Description |
|---|---|
class |
LockingTransactionId
Encapsulates a transaction id guaranteed to be unique across all usage via UUID.
|
| Modifier and Type | Method and Description |
|---|---|
static TransactionId |
TransactionId.generate() |
| Modifier and Type | Method and Description |
|---|---|
static TransactionId |
DatabaseManager.getTransactionId()
Generate a transaction with random UUID
|
static TransactionId |
DatabaseManager.getTransactionId(long timeout)
Generate a transaction with random UUID
|
| Modifier and Type | Method and Description |
|---|---|
static void |
DatabaseManager.associateSession(TransactionId xid,
TransactionalMap tm)
TransactionalMap contains a
Session or its subclasses TransactionSession or TransactionSessionAlias. |
static void |
TransactionManager.checkpoint(TransactionId uid)
Checkpoint all transactions with given transaction Id
|
static void |
DatabaseManager.checkpointTransaction(Alias alias,
TransactionId xid) |
static void |
DatabaseManager.checkpointTransaction(TransactionId xid) |
static void |
DatabaseManager.clearOutstandingTransaction(TransactionId xid) |
static void |
TransactionManager.commit(TransactionId uid)
Commit all transactions with given transaction Id
|
static void |
DatabaseManager.commitTransaction(Alias alias,
TransactionId xid) |
static void |
DatabaseManager.commitTransaction(TransactionId xid) |
boolean |
TransactionSetInterface.contains(TransactionId transactionId,
java.lang.Comparable o)
Contains a value object
|
boolean |
TransactionalMap.contains(TransactionId transactionId,
java.lang.Comparable o) |
boolean |
TransactionalMap.containsKey(TransactionId transactionId,
java.lang.Comparable tkey)
Returns true if the collection contains the given key
|
boolean |
TransactionalMap.containsValue(TransactionId transactionId,
java.lang.Object value)
Returns true if the collection contains the given value object
|
static void |
DatabaseManager.endTransaction(TransactionId xid) |
java.util.Iterator<?> |
TransactionalMap.entrySet(TransactionId transactionId)
Obtain iterator over the entrySet.
|
java.util.stream.Stream<?> |
TransactionalMap.entrySetStream(TransactionId transactionId)
Return the stream over the entry set
|
java.lang.Object |
TransactionSetInterface.first(TransactionId transactionId)
Get the value of the object associated with first key
|
java.lang.Object |
TransactionalMap.first(TransactionId transactionId)
Return the first element
|
java.lang.Comparable |
TransactionalMap.firstKey(TransactionId transactionId) |
java.lang.Object |
TransactionSetInterface.get(TransactionId transactionId,
java.lang.Comparable o)
Cause the b seekKey for the Comparable type.
|
java.lang.Object |
TransactionalMap.get(TransactionId transactionId,
java.lang.Comparable tkey)
Get a value from backing store if not in cache.
|
java.lang.Object |
TransactionSetInterface.getForUpdate(TransactionId transactionId,
java.lang.Comparable o,
boolean exclusive)
Read a key and make the key value a precondition for commit.
|
java.lang.Object |
TransactionalMap.getForUpdate(TransactionId transactionId,
java.lang.Comparable o,
boolean exclusive)
Read a key and make the key value a precondition for commit.
|
static TransactionalMap |
DatabaseManager.getOptimisticTransactionalMap(Alias alias,
java.lang.Class clazz,
TransactionId xid) |
static TransactionalMap |
DatabaseManager.getOptimisticTransactionalMap(Alias alias,
java.lang.Comparable clazz,
TransactionId xid)
Start a new transaction for the given class in the aliased database
|
static TransactionalMap |
DatabaseManager.getOptimisticTransactionalMap(java.lang.Class clazz,
TransactionId xid)
Start a new optimistic transaction for the given class in the current database
|
static TransactionalMap |
DatabaseManager.getOptimisticTransactionalMap(java.lang.Comparable clazz,
TransactionId xid)
Start a new optimistic transaction for the given class in the current database
|
static java.util.List<org.rocksdb.Transaction> |
DatabaseManager.getOutstandingTransactionsByAliasAndId(Alias alias,
TransactionId uid) |
static java.util.List<org.rocksdb.Transaction> |
DatabaseManager.getOutstandingTransactionsByPathAndId(java.lang.String path,
TransactionId uid) |
org.rocksdb.Transaction |
TransactionSessionAlias.getTransaction(TransactionId transactionId,
java.lang.String clazz,
boolean create)
Get the Transaction object formed from id and class.
|
org.rocksdb.Transaction |
TransactionSession.getTransaction(TransactionId transactionId,
java.lang.String clazz,
boolean create)
Get the Transaction object formed from id and class.
|
static TransactionalMap |
DatabaseManager.getTransactionalMap(Alias alias,
java.lang.Class clazz,
TransactionId xid) |
static TransactionalMap |
DatabaseManager.getTransactionalMap(Alias alias,
java.lang.Comparable clazz,
TransactionId xid)
Start a new transaction for the given class in the aliased database
|
static TransactionalMap |
DatabaseManager.getTransactionalMap(java.lang.Class clazz,
TransactionId xid)
Start a new transaction for the given class in the current database
|
static TransactionalMap |
DatabaseManager.getTransactionalMap(java.lang.Comparable clazz,
TransactionId xid)
Start a new transaction for the given class in the current database
|
static java.util.concurrent.ConcurrentHashMap<java.lang.String,com.neocoretechs.rocksack.session.TransactionManager.SessionAndTransaction> |
TransactionManager.getTransactions(TransactionId transactionId)
Get the Transaction objects formed from id.
|
static java.util.List<org.rocksdb.Transaction> |
TransactionManager.getTransactions(TransactionId transactionId,
java.lang.String clazz)
Get the Transaction objects formed from id and class name.
|
java.lang.Object |
TransactionalMap.getValue(TransactionId transactionId,
java.lang.Object tkey)
Get a value from backing store if not in cache.
|
java.lang.Object |
TransactionalMap.getViaBytes(TransactionId transactionId,
byte[] tkey)
Get a value from backing store if not in cache.
|
java.util.Iterator<?> |
TransactionalMap.headMap(TransactionId transactionId,
java.lang.Comparable tkey) |
java.util.Iterator<?> |
TransactionalMap.headMapKV(TransactionId transactionId,
java.lang.Comparable tkey)
Return iterator over headmap
|
java.util.stream.Stream<?> |
TransactionalMap.headMapKVStream(TransactionId transactionId,
java.lang.Comparable tkey) |
java.util.stream.Stream<?> |
TransactionalMap.headMapStream(TransactionId transactionId,
java.lang.Comparable tkey)
Return the stream over the headmap.
|
java.util.Iterator<?> |
TransactionalMap.headSet(TransactionId transactionId,
java.lang.Comparable tkey)
Return iterator over headset
|
java.util.Iterator<?> |
TransactionalMap.headSetKV(TransactionId transactionId,
java.lang.Comparable tkey)
Return Iterator over headset
|
java.util.stream.Stream<?> |
TransactionalMap.headSetKVStream(TransactionId transactionId,
java.lang.Comparable tkey)
Return stream over headset
|
java.util.stream.Stream<?> |
TransactionalMap.headSetStream(TransactionId transactionId,
java.lang.Comparable tkey)
Return stream over headset
|
boolean |
TransactionSetInterface.isEmpty(TransactionId transactionId)
Is the KVStore empty?
|
boolean |
TransactionalMap.isEmpty(TransactionId transactionId)
Return boolean value indicating whether the map is empty
|
static boolean |
DatabaseManager.isSessionAssociated(TransactionId xid,
TransactionalMap tm)
TransactionalMap contains a
Session or its subclasses TransactionSession or TransactionSessionAlias. |
boolean |
TransactionSessionAlias.isTransactionLinked(TransactionId xid,
TransactionalMap tm,
java.util.concurrent.ConcurrentHashMap<java.lang.String,com.neocoretechs.rocksack.session.TransactionManager.SessionAndTransaction> tLink)
Check the mangled name identifier of transaction id, classname, and optionally the alias,
to identify this entry in the mapping of mangled name to SessionAndTransaction
instances from the passed map.
|
boolean |
TransactionSession.isTransactionLinked(TransactionId xid,
TransactionalMap tm,
java.util.concurrent.ConcurrentHashMap<java.lang.String,com.neocoretechs.rocksack.session.TransactionManager.SessionAndTransaction> tLink)
Check the mangled name identifier of transaction id, classname, and optionally the alias,
to identify this entry in the mapping of mangled name to SessionAndTransaction
instances from the passed map.
|
java.util.Iterator<?> |
TransactionSetInterface.iterator(TransactionId transactionId)
Returns iterator
|
java.util.Iterator<?> |
TransactionalMap.iterator(TransactionId transactionId) |
java.util.Iterator<?> |
TransactionalMap.keySet(TransactionId transactionId)
Get a keySet iterator.
|
java.util.stream.Stream<?> |
TransactionalMap.keySetStream(TransactionId transactionId)
Return the stream over the keyset
|
java.lang.Object |
TransactionSetInterface.last(TransactionId transactionId)
Get the last object associated with greatest valued key in the KVStore
|
java.lang.Object |
TransactionalMap.last(TransactionId transactionId)
Return the last value in the set
|
java.lang.Comparable |
TransactionalMap.lastKey(TransactionId transactionId) |
boolean |
TransactionSessionAlias.linkSessionAndTransaction(TransactionId xid,
TransactionalMap tm,
java.util.concurrent.ConcurrentHashMap<java.lang.String,com.neocoretechs.rocksack.session.TransactionManager.SessionAndTransaction> tLink)
Called from associateSession and setTransaction to link a new mangled name to a new SessionAndTransaction instance
to populate the passed tLink map.
|
boolean |
TransactionSession.linkSessionAndTransaction(TransactionId xid,
TransactionalMap tm,
java.util.concurrent.ConcurrentHashMap<java.lang.String,com.neocoretechs.rocksack.session.TransactionManager.SessionAndTransaction> tLink)
Generate a mangled name identifier of transaction id, classname, and optionally the alias,
to identify this entry in the mapping of mangled name to SessionAndTransaction
instances.
|
java.lang.Object |
TransactionalMap.nearest(TransactionId transactionId,
java.lang.Comparable tkey)
Return the element nearest to given key
|
boolean |
TransactionalMap.put(TransactionId transactionId,
java.lang.Comparable tkey,
java.lang.Object tvalue)
Put a key/value pair to backing store.
|
boolean |
TransactionalMap.putViaBytes(TransactionId transactionId,
byte[] tkey,
java.lang.Object tvalue)
Put a key/value pair to main cache and pool.
|
java.lang.Object |
TransactionSetInterface.remove(TransactionId transactionId,
java.lang.Comparable o)
Remove the key and value of the parameter.
|
java.lang.Object |
TransactionalMap.remove(TransactionId transactionId,
java.lang.Comparable tkey)
Remove object from cache and backing store.
|
static void |
DatabaseManager.removeTransaction(Alias alias,
TransactionId xid)
Remove from classToIso then idToTransaction in
VolumeManager |
static void |
DatabaseManager.removeTransaction(TransactionId xid)
Remove from classToIso then idToTransaction in
VolumeManager |
static void |
DatabaseManager.removeTransactionalMap(Alias alias,
TransactionId xid)
Remove the given TransactionalMap from active DB/transaction collection
|
static void |
DatabaseManager.removeTransactionalMap(TransactionId xid,
TransactionSetInterface tmap)
Remove the given TransactionalMap from active DB/transaction collection
|
static void |
TransactionManager.rollback(TransactionId uid)
Rollback all transactions with given transaction Id
|
static void |
DatabaseManager.rollbackToCheckpoint(Alias alias,
TransactionId xid) |
static void |
TransactionManager.rollbackToCheckpoint(TransactionId uid)
Rollback to checkpoint all transactions with given transaction Id
|
static void |
DatabaseManager.rollbackToCheckpoint(TransactionId xid) |
static void |
DatabaseManager.rollbackTransaction(Alias alias,
TransactionId xid) |
static void |
DatabaseManager.rollbackTransaction(TransactionId xid) |
long |
TransactionSetInterface.size(TransactionId transactionId)
Get the number of keys total.
|
long |
TransactionalMap.size(TransactionId transactionId)
Return the number of elements in the backing store
|
java.util.Iterator<?> |
TransactionalMap.subMap(TransactionId transactionId,
java.lang.Comparable fkey,
java.lang.Comparable tkey) |
java.util.Iterator<?> |
TransactionalMap.subMapKV(TransactionId transactionId,
java.lang.Comparable fkey,
java.lang.Comparable tkey) |
java.util.stream.Stream<?> |
TransactionalMap.subMapKVStream(TransactionId transactionId,
java.lang.Comparable fkey,
java.lang.Comparable tkey) |
java.util.stream.Stream<?> |
TransactionalMap.subMapStream(TransactionId transactionId,
java.lang.Comparable fkey,
java.lang.Comparable tkey) |
java.util.Iterator<?> |
TransactionalMap.subSet(TransactionId transactionId,
java.lang.Comparable fkey,
java.lang.Comparable tkey) |
java.util.Iterator<?> |
TransactionalMap.subSetKV(TransactionId transactionId,
java.lang.Comparable fkey,
java.lang.Comparable tkey) |
java.util.stream.Stream<?> |
TransactionalMap.subSetKVStream(TransactionId transactionId,
java.lang.Comparable fkey,
java.lang.Comparable tkey) |
java.util.stream.Stream<?> |
TransactionalMap.subSetStream(TransactionId transactionId,
java.lang.Comparable fkey,
java.lang.Comparable tkey) |
java.util.Iterator<?> |
TransactionalMap.tailMap(TransactionId transactionId,
java.lang.Comparable fkey)
Tailmap from starting element to end exclusive
|
java.util.Iterator<?> |
TransactionalMap.tailMapKV(TransactionId transactionId,
java.lang.Comparable fkey) |
java.util.stream.Stream<?> |
TransactionalMap.tailMapKVStream(TransactionId transactionId,
java.lang.Comparable fkey)
Tailmap from starting element to end exclusive
|
java.util.stream.Stream<?> |
TransactionalMap.tailMapStream(TransactionId transactionId,
java.lang.Comparable fkey)
Tailmap from starting element to end exclusive
|
java.util.Iterator<?> |
TransactionalMap.tailSet(TransactionId transactionId,
java.lang.Comparable fkey)
Tailset from starting element to end exclusive
|
java.util.Iterator<?> |
TransactionalMap.tailSetKV(TransactionId transactionId,
java.lang.Comparable fkey)
Tailset from starting element to end exclusive
|
java.util.stream.Stream<?> |
TransactionalMap.tailSetKVStream(TransactionId transactionId,
java.lang.Comparable fkey)
Tailset from starting element to end exclusive
|
java.util.stream.Stream<?> |
TransactionalMap.tailSetStream(TransactionId transactionId,
java.lang.Comparable fkey)
Tailset from starting element to end exclusive
|
void |
TransactionSetInterface.undoGetForUpdate(TransactionId transactionId,
java.lang.Comparable o)
Inform the transaction that it no longer needs to do any conflict checking for this key.
|
void |
TransactionalMap.undoGetForUpdate(TransactionId transactionId,
java.lang.Comparable o)
Tell the transaction that it no longer needs to do any conflict checking for this key.
|
| Modifier and Type | Method and Description |
|---|---|
static void |
BatteryKVTransactionStream.battery1(TransactionId xid)
Loads up on keys, should be 0 to max-1, or min, to max -1
|
static void |
BatteryKVTransaction.battery1(TransactionId xid)
Loads up on keys, should be 0 to max-1, or min, to max -1
transaction is committed
|
static void |
BatteryKVOptimisticTransaction.battery1(TransactionId xid,
java.util.concurrent.atomic.AtomicInteger recs12,
int min22,
int max22)
Loads up on keys, should be 0 to max-1, or min, to max -1
transaction is committed
|
static void |
BatteryKVTransactionAlias.battery1(TransactionId xid,
TransactionId xid0,
Alias alias12,
TransactionalMap bmap3)
Use 2 different interleaved transactions to insert to the same database without conflict.
|
static void |
BatteryKVTransactionStream.battery11(TransactionId xid)
Store another transaction then roll it back.
|
static void |
BatteryKVTransaction.battery11(TransactionId xid)
Store another transaction then roll it back.
|
static void |
BatteryKVTransactionAlias.battery11(TransactionId xid,
Alias alias12,
TransactionalMap bmap3)
Store another transaction with twice the max records, then roll it back and remove transaction.
|
static void |
BatteryKVTransactionStream.battery18(TransactionId xid)
Loads up on keys, should be 0 to max-1, or min, to max -1
|
static void |
BatteryKVTransaction.battery18(TransactionId xid)
Test of transaction checkpoint.
|
static void |
BatteryKVOptimisticTransaction.battery18(TransactionId xid,
int min12,
int max22)
Test of transaction checkpoint.
|
static void |
BatteryKVTransactionStream.battery1AR10(TransactionId xid)
test last and lastKey
|
static void |
BatteryKVTransaction.battery1AR10(TransactionId xid)
test last and lastKey
|
static void |
BatteryKVTransactionAlias.battery1AR10(TransactionId xid,
Alias alias12,
TransactionalMap bmap3,
int j)
test last and lastKey
|
static void |
BatteryKVOptimisticTransaction.battery1AR10(TransactionId xid,
int min12,
int max22)
test last and lastKey
|
static void |
BatteryKVTransactionStream.battery1AR101(TransactionId xid)
test size
|
static void |
BatteryKVTransaction.battery1AR101(TransactionId xid)
test size
|
static void |
BatteryKVTransactionAlias.battery1AR101(TransactionId xid,
Alias alias12,
TransactionalMap bmap3,
int j)
test size
|
static void |
BatteryKVOptimisticTransaction.battery1AR101(TransactionId xid,
int min12,
int max22)
test size
|
static void |
BatteryKVTransactionStream.battery1AR11(TransactionId xid)
findMap test, basically tailmap returning keys
|
static void |
BatteryKVTransaction.battery1AR11(TransactionId xid)
tailMap returning keys
|
static void |
BatteryKVTransactionAlias.battery1AR11(TransactionId xid,
Alias alias12,
TransactionalMap bmap3,
int j)
tailMap test
|
static void |
BatteryKVOptimisticTransaction.battery1AR11(TransactionId xid,
int min12,
int max22)
tailMap returning keys
|
static void |
BatteryKVTransactionStream.battery1AR12(TransactionId xid)
findMapKV tailmapKV
|
static void |
BatteryKVTransaction.battery1AR12(TransactionId xid)
tailMapKV
|
static void |
BatteryKVTransactionAlias.battery1AR12(TransactionId xid,
Alias alias12,
TransactionalMap bmap3,
int j)
tailmapKV
|
static void |
BatteryKVOptimisticTransaction.battery1AR12(TransactionId xid,
int min12,
int max22)
tailMapKV
|
static void |
BatteryKVTransactionStream.battery1AR13(TransactionId xid)
headMapStream - Returns a view of the portion of this map whose keys are strictly less than toKey.
|
static void |
BatteryKVTransaction.battery1AR13(TransactionId xid)
headMap - Returns a view of the portion of this map whose keys are strictly less than toKey.
|
static void |
BatteryKVTransactionAlias.battery1AR13(TransactionId xid,
Alias alias12,
TransactionalMap bmap3,
int j)
findHeadMap - Returns a view of the portion of this map whose keys are strictly less than toKey.
|
static void |
BatteryKVOptimisticTransaction.battery1AR13(TransactionId xid,
int min12,
int max22)
headMap - Returns a view of the portion of this map whose keys are strictly less than toKey.
|
static void |
BatteryKVTransactionStream.battery1AR14(TransactionId xid)
headMapKVStream
|
static void |
BatteryKVTransaction.battery1AR14(TransactionId xid)
headMapKV
|
static void |
BatteryKVTransactionAlias.battery1AR14(TransactionId xid,
Alias alias12,
TransactionalMap bmap3,
int j)
headMapKV
|
static void |
BatteryKVOptimisticTransaction.battery1AR14(TransactionId xid,
int min12,
int max22)
headMapKV
|
static void |
BatteryKVTransactionStream.battery1AR15(TransactionId xid)
subMapStream - Returns a view of the portion of this map whose keys range from fromKey, inclusive, to toKey, exclusive.
|
static void |
BatteryKVTransaction.battery1AR15(TransactionId xid)
subMap - Returns a view of the portion of this map whose keys range from fromKey, inclusive, to toKey, exclusive.
|
static void |
BatteryKVTransactionAlias.battery1AR15(TransactionId xid,
Alias alias12,
TransactionalMap bmap3,
int k)
subMap - Returns a view of the portion of this map whose keys range from fromKey, inclusive, to toKey, exclusive.
|
static void |
BatteryKVOptimisticTransaction.battery1AR15(TransactionId xid,
int min12,
int max22)
subMap - Returns a view of the portion of this map whose keys range from fromKey, inclusive, to toKey, exclusive.
|
static void |
BatteryKVTransactionStream.battery1AR16(TransactionId xid)
subMapKVStream - Returns a view of the portion of this map whose keys range from fromKey, inclusive, to toKey, exclusive.
|
static void |
BatteryKVTransaction.battery1AR16(TransactionId xid)
subMapKV - Returns a view of the portion of this map whose keys range from fromKey, inclusive, to toKey, exclusive.
|
static void |
BatteryKVTransactionAlias.battery1AR16(TransactionId xid,
Alias alias12,
TransactionalMap bmap3,
int k)
subMapKV - Returns a view of the portion of this map whose keys range from fromKey, inclusive, to toKey, exclusive.
|
static void |
BatteryKVOptimisticTransaction.battery1AR16(TransactionId xid,
int min12,
int max22)
subMapKV - Returns a view of the portion of this map whose keys range from fromKey, inclusive, to toKey, exclusive.
|
static void |
BatteryKVTransactionStream.battery1AR17(TransactionId xid)
remove entries
|
static void |
BatteryKVTransaction.battery1AR17(TransactionId xid)
remove entries
|
static void |
BatteryKVOptimisticTransaction.battery1AR17(TransactionId xid,
int min12,
int max22)
remove entries
|
static void |
BatteryKVTransactionStream.battery1AR6(TransactionId xid)
Test the higher level functions in the map.
|
static void |
BatteryKVTransaction.battery1AR6(TransactionId xid)
Test the higher level functions in the RelatrixKV.
|
static void |
BatteryKVTransactionAlias.battery1AR6(TransactionId xid,
Alias alias12,
TransactionalMap bmap3,
int j)
Test the higher level functions in the RelatrixKV.
|
static void |
BatteryKVOptimisticTransaction.battery1AR6(TransactionId xid,
int min12,
int max22)
Test the higher level functions in the RelatrixKV.
|
static void |
BatteryKVTransactionStream.battery1AR7(TransactionId xid)
Testing of Stream its = keySetStream;
|
static void |
BatteryKVTransaction.battery1AR7(TransactionId xid)
Testing of Iterator its = RelatrixKV.keySet;
|
static void |
BatteryKVTransactionAlias.battery1AR7(TransactionId xid,
Alias alias12,
TransactionalMap bmap3,
int j)
Testing of Iterator its = RelatrixKV.keySet;
|
static void |
BatteryKVOptimisticTransaction.battery1AR7(TransactionId xid,
int min12,
int max22)
Testing of Iterator its = RelatrixKV.keySet;
|
static void |
BatteryKVTransactionStream.battery1AR8(TransactionId xid)
Testing of contains
|
static void |
BatteryKVTransaction.battery1AR8(TransactionId xid)
Testing of contains/containsValue
|
static void |
BatteryKVTransactionAlias.battery1AR8(TransactionId xid,
Alias alias12,
TransactionalMap bmap3,
int k)
Testing of contains, forward and back
|
static void |
BatteryKVOptimisticTransaction.battery1AR8(TransactionId xid,
int min12,
int max22)
Testing of contains/containsValue
|
static void |
BatteryKVTransactionStream.battery1AR9(TransactionId xid)
Testing of first(), and firstValue
|
static void |
BatteryKVTransaction.battery1AR9(TransactionId xid)
Testing of firstKey
|
static void |
BatteryKVTransactionAlias.battery1AR9(TransactionId xid,
Alias alias12,
TransactionalMap bmap3,
int j)
Testing of firstKey/first
|
static void |
BatteryKVOptimisticTransaction.battery1AR9(TransactionId xid,
int min12,
int max22)
Testing of firstKey
|