public final class TransactionManager
extends java.lang.Object
TransactionId
s to
TransactionSession
s. We can access and manipulate this map in order to get us to the eventual
map of mangled transaction names and RocksDb TransactionDb Transaction instances in TransactionSession.Modifier and Type | Method and Description |
---|---|
static void |
checkpoint(java.lang.String uid) |
static void |
commit(java.lang.String uid) |
static TransactionManager |
getInstance() |
static java.util.ArrayList<org.rocksdb.Transaction> |
getTransactions(java.lang.String clazz)
Get the Transaction objects formed from class name.
|
static java.util.concurrent.ConcurrentHashMap<java.lang.String,com.neocoretechs.rocksack.session.TransactionManager.SessionAndTransaction> |
getTransactions(TransactionId transactionId)
Get the Transaction objects formed from id.
|
static java.util.List<org.rocksdb.Transaction> |
getTransactions(TransactionId transactionId,
java.lang.String clazz)
Get the Transaction objects formed from id and class name.
|
static void |
rollback(java.lang.String uid) |
static void |
rollbackToCheckpoint(java.lang.String uid) |
public static TransactionManager getInstance()
public static java.util.concurrent.ConcurrentHashMap<java.lang.String,com.neocoretechs.rocksack.session.TransactionManager.SessionAndTransaction> getTransactions(TransactionId transactionId)
transactionId
- public static java.util.List<org.rocksdb.Transaction> getTransactions(TransactionId transactionId, java.lang.String clazz)
transactionId
- clazz
- public static java.util.ArrayList<org.rocksdb.Transaction> getTransactions(java.lang.String clazz)
clazz
- public static void commit(java.lang.String uid) throws org.rocksdb.RocksDBException
org.rocksdb.RocksDBException
public static void rollback(java.lang.String uid) throws org.rocksdb.RocksDBException
org.rocksdb.RocksDBException
public static void checkpoint(java.lang.String uid) throws org.rocksdb.RocksDBException
org.rocksdb.RocksDBException
public static void rollbackToCheckpoint(java.lang.String uid) throws org.rocksdb.RocksDBException
org.rocksdb.RocksDBException