InMemoryTransactionManager(Duration, int, CatalogManager, Executor, Map) |  | 0% |  | 0% | 2 | 2 | 12 | 12 | 1 | 1 |
cleanUpExpiredTransactions() |  | 0% |  | 0% | 3 | 3 | 9 | 9 | 1 | 1 |
registerTransaction(TransactionId, IsolationLevel, boolean, boolean) |  | 0% |  | 0% | 2 | 2 | 4 | 4 | 1 | 1 |
create(TransactionManagerConfig, ScheduledExecutorService, CatalogManager, ExecutorService) |  | 0% | | n/a | 1 | 1 | 6 | 6 | 1 | 1 |
tryRegisterTransaction(TransactionInfo) |  | 0% |  | 0% | 2 | 2 | 5 | 5 | 1 | 1 |
registerFunctionNamespaceManager(String, FunctionNamespaceManager) |  | 0% |  | 0% | 2 | 2 | 3 | 3 | 1 | 1 |
getCatalogMetadataForWrite(TransactionId, String) |  | 0% | | n/a | 1 | 1 | 4 | 4 | 1 | 1 |
removeTransactionMetadataAsFuture(TransactionId) |  | 0% |  | 0% | 2 | 2 | 4 | 4 | 1 | 1 |
getOptionalCatalogMetadata(TransactionId, String) |  | 0% | | n/a | 1 | 1 | 3 | 3 | 1 | 1 |
createTestTransactionManager(CatalogManager) |  | 0% | | n/a | 1 | 1 | 1 | 1 | 1 | 1 |
getTransactionMetadata(TransactionId) |  | 0% |  | 0% | 2 | 2 | 4 | 4 | 1 | 1 |
unknownTransactionError(TransactionId) |  | 0% | | n/a | 1 | 1 | 1 | 1 | 1 | 1 |
lambda$getCatalogMetadataForWrite$2(String) |  | 0% | | n/a | 1 | 1 | 1 | 1 | 1 | 1 |
scheduleIdleChecks(Duration, ScheduledExecutorService) |  | 0% | | n/a | 1 | 1 | 3 | 3 | 1 | 1 |
getCatalogMetadataForWrite(TransactionId, ConnectorId) |  | 0% | | n/a | 1 | 1 | 3 | 3 | 1 | 1 |
getAllTransactionInfos() |  | 0% | | n/a | 1 | 1 | 3 | 3 | 1 | 1 |
beginTransaction(IsolationLevel, boolean, boolean) |  | 0% | | n/a | 1 | 1 | 3 | 3 | 1 | 1 |
checkAndSetActive(TransactionId) |  | 0% | | n/a | 1 | 1 | 4 | 4 | 1 | 1 |
lambda$scheduleIdleChecks$0() |  | 0% | | n/a | 1 | 1 | 5 | 5 | 1 | 1 |
enableRollback(TransactionId) |  | 0% | | n/a | 1 | 1 | 3 | 3 | 1 | 1 |
asyncCommit(TransactionId) |  | 0% | | n/a | 1 | 1 | 1 | 1 | 1 | 1 |
asyncAbort(TransactionId) |  | 0% | | n/a | 1 | 1 | 1 | 1 | 1 | 1 |
getConnectorTransaction(TransactionId, ConnectorId) |  | 0% | | n/a | 1 | 1 | 1 | 1 | 1 | 1 |
getFunctionNamespaceTransaction(TransactionId, String) |  | 0% | | n/a | 1 | 1 | 1 | 1 | 1 | 1 |
getOptionalTransactionInfo(TransactionId) |  | 0% | | n/a | 1 | 1 | 1 | 1 | 1 | 1 |
beginTransaction(boolean) |  | 0% | | n/a | 1 | 1 | 1 | 1 | 1 | 1 |
getCatalogMetadata(TransactionId, ConnectorId) |  | 0% | | n/a | 1 | 1 | 1 | 1 | 1 | 1 |
checkConnectorWrite(TransactionId, ConnectorId) |  | 0% | | n/a | 1 | 1 | 2 | 2 | 1 | 1 |
trySetActive(TransactionId) |  | 0% | | n/a | 1 | 1 | 2 | 2 | 1 | 1 |
trySetInactive(TransactionId) |  | 0% | | n/a | 1 | 1 | 2 | 2 | 1 | 1 |
tryGetTransactionMetadata(TransactionId) |  | 0% | | n/a | 1 | 1 | 1 | 1 | 1 | 1 |
fail(TransactionId) |  | 0% | | n/a | 1 | 1 | 2 | 2 | 1 | 1 |
createTestTransactionManager() |  | 0% | | n/a | 1 | 1 | 1 | 1 | 1 | 1 |
getTransactionInfo(TransactionId) |  | 0% | | n/a | 1 | 1 | 1 | 1 | 1 | 1 |
getCatalogNames(TransactionId) |  | 0% | | n/a | 1 | 1 | 1 | 1 | 1 | 1 |
lambda$getOptionalCatalogMetadata$1(InMemoryTransactionManager.TransactionMetadata, ConnectorId) |  | 0% | | n/a | 1 | 1 | 1 | 1 | 1 | 1 |
static {...} |  | 0% | | n/a | 1 | 1 | 1 | 1 | 1 | 1 |