Package | Description |
---|---|
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 | Method and Description |
---|---|
Alias |
TransactionSessionAlias.getAlias() |
Modifier and Type | Method and Description |
---|---|
static void |
DatabaseManager.checkpointTransaction(Alias alias,
TransactionId xid) |
static void |
DatabaseManager.commitTransaction(Alias alias,
TransactionId xid) |
static TransactionSession |
SessionManager.ConnectOptimisticTransaction(Alias alias,
java.lang.String dbname,
org.rocksdb.Options options)
Connect to an optimistic transaction database column family for a default ColumnFamily class being stored in that database.
|
static TransactionSession |
SessionManager.ConnectOptimisticTransaction(Alias alias,
java.lang.String dbname,
org.rocksdb.Options options,
java.lang.String derivedClassName)
Connect to an optimistic transaction database column family for a derived class being stored in that database.
|
static TransactionSession |
SessionManager.ConnectTransaction(Alias alias,
java.lang.String dbname,
org.rocksdb.Options options)
Connect to a transaction database column family for a default ColumnFamily class being stored in that database.
|
static TransactionSession |
SessionManager.ConnectTransaction(Alias alias,
java.lang.String dbname,
org.rocksdb.Options options,
long timeout)
Connect to a transaction database column family for a default ColumnFamily class being stored in that database with associated transaction timeout.
|
static TransactionSession |
SessionManager.ConnectTransaction(Alias alias,
java.lang.String dbname,
org.rocksdb.Options options,
java.lang.String derivedClassName)
Connect to a transaction database column family for a derived class being stored in that database.
|
static TransactionSession |
SessionManager.ConnectTransaction(Alias alias,
java.lang.String dbname,
org.rocksdb.Options options,
java.lang.String derivedClassName,
long timeout)
Connect to a transaction database column family for a derived class being stored in that database with associated transaction timeout.
|
static java.lang.String |
DatabaseManager.getAliasToPath(Alias alias)
Get the tablespace path for the given alias
VolumeManager |
static BufferedMap |
DatabaseManager.getMap(Alias alias,
java.lang.Class clazz)
Get a Map via Java Class type.
|
static BufferedMap |
DatabaseManager.getMap(Alias alias,
java.lang.Comparable clazz)
Get a Map via Comparable instance.
|
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 java.util.List<org.rocksdb.Transaction> |
DatabaseManager.getOutstandingTransactionsByAliasAndId(Alias alias,
TransactionId uid) |
static java.lang.String |
DatabaseManager.getTableSpaceDir(Alias alias)
Get the tablespace by given alias
|
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 void |
DatabaseManager.removeAlias(Alias alias)
Remove the given alias.
|
static void |
DatabaseManager.removeMap(Alias alias,
SetInterface tmap)
Remove the given Map from active DB/transaction collection
|
static void |
DatabaseManager.removeTransaction(Alias alias,
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(Alias alias,
TransactionSetInterface tmap)
Remove the given TransactionalMap from active DB/transaction collection
|
static void |
DatabaseManager.rollbackToCheckpoint(Alias alias,
TransactionId xid) |
static void |
DatabaseManager.rollbackTransaction(Alias alias,
TransactionId xid) |
static void |
DatabaseManager.setTableSpaceDir(Alias alias,
java.lang.String path)
Set the tablespace for a given alias
|
Constructor and Description |
---|
OptimisticTransactionSessionAlias(org.rocksdb.OptimisticTransactionDB kvStore,
org.rocksdb.Options options,
java.util.ArrayList<org.rocksdb.ColumnFamilyDescriptor> columnFamilyDescriptor,
java.util.List<org.rocksdb.ColumnFamilyHandle> columnFamilyHandles,
Alias alias) |
TransactionSessionAlias(org.rocksdb.OptimisticTransactionDB kvStore,
org.rocksdb.Options options,
java.util.ArrayList<org.rocksdb.ColumnFamilyDescriptor> columnFamilyDescriptor,
java.util.List<org.rocksdb.ColumnFamilyHandle> columnFamilyHandles,
Alias alias) |
Modifier and Type | Method and Description |
---|---|
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 |
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 |
BatteryKVTransactionAlias.battery18(Alias alias12,
TransactionalMap bmap2)
Get next transaction id,
Insert half the keys, checkpoint, then insert other half, commit, then remove trans.
|
static void |
BatteryKVTransactionAlias.battery1AR10(TransactionId xid,
Alias alias12,
TransactionalMap bmap3,
int j)
test last and lastKey
|
static void |
BatteryKVTransactionAlias.battery1AR101(TransactionId xid,
Alias alias12,
TransactionalMap bmap3,
int j)
test size
|
static void |
BatteryKVTransactionAlias.battery1AR11(TransactionId xid,
Alias alias12,
TransactionalMap bmap3,
int j)
tailMap test
|
static void |
BatteryKVTransactionAlias.battery1AR12(TransactionId xid,
Alias alias12,
TransactionalMap bmap3,
int j)
tailmapKV
|
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 |
BatteryKVTransactionAlias.battery1AR14(TransactionId xid,
Alias alias12,
TransactionalMap bmap3,
int j)
headMapKV
|
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 |
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 |
BatteryKVTransactionAlias.battery1AR6(TransactionId xid,
Alias alias12,
TransactionalMap bmap3,
int j)
Test the higher level functions in the RelatrixKV.
|
static void |
BatteryKVTransactionAlias.battery1AR7(TransactionId xid,
Alias alias12,
TransactionalMap bmap3,
int j)
Testing of Iterator its = RelatrixKV.keySet;
|
static void |
BatteryKVTransactionAlias.battery1AR8(TransactionId xid,
Alias alias12,
TransactionalMap bmap3,
int k)
Testing of contains, forward and back
|
static void |
BatteryKVTransactionAlias.battery1AR9(TransactionId xid,
Alias alias12,
TransactionalMap bmap3,
int j)
Testing of firstKey/first
|