#include <transaction.h>
|
| Transaction (main::ClientContext &clientContext, TransactionType transactionType, common::transaction_t transactionID, common::transaction_t startTS) |
|
| Transaction (TransactionType transactionType) noexcept |
|
| Transaction (TransactionType transactionType, common::transaction_t ID, common::transaction_t startTS) noexcept |
|
TransactionType | getType () const |
|
bool | isReadOnly () const |
|
bool | isWriteTransaction () const |
|
bool | isDummy () const |
|
bool | isRecovery () const |
|
common::transaction_t | getID () const |
|
common::transaction_t | getStartTS () const |
|
common::transaction_t | getCommitTS () const |
|
int64_t | getCurrentTS () const |
|
main::ClientContext * | getClientContext () const |
|
void | checkForceCheckpoint (common::StatementType statementType) |
|
bool | shouldAppendToUndoBuffer () const |
|
bool | shouldLogToWAL () const |
|
bool | shouldForceCheckpoint () const |
|
void | commit (storage::WAL *wal) const |
|
void | rollback (storage::WAL *wal) const |
|
uint64_t | getEstimatedMemUsage () const |
|
storage::LocalStorage * | getLocalStorage () const |
|
bool | hasNewlyInsertedNodes (common::table_id_t tableID) const |
|
void | setMaxCommittedNodeOffset (common::table_id_t tableID, common::offset_t offset) |
|
common::offset_t | getMaxNodeOffsetBeforeCommit (common::table_id_t tableID) const |
|
void | pushCatalogEntry (catalog::CatalogSet &catalogSet, catalog::CatalogEntry &catalogEntry, bool skipLoggingToWAL=false) const |
|
void | pushSequenceChange (catalog::SequenceCatalogEntry *sequenceEntry, int64_t kCount, const catalog::SequenceRollbackData &data) const |
|
void | pushVectorInsertInfo (storage::VersionInfo &versionInfo, common::idx_t vectorIdx, common::row_idx_t startRowInVector, common::row_idx_t numRows) const |
|
void | pushVectorDeleteInfo (storage::VersionInfo &versionInfo, common::idx_t vectorIdx, common::row_idx_t startRowInVector, common::row_idx_t numRows) const |
|
void | pushVectorUpdateInfo (storage::UpdateInfo &updateInfo, common::idx_t vectorIdx, storage::VectorUpdateInfo &vectorUpdateInfo) const |
|
◆ Transaction() [1/3]
◆ Transaction() [2/3]
kuzu::transaction::Transaction::Transaction |
( |
TransactionType | transactionType | ) |
|
|
inlineexplicitnoexcept |
◆ Transaction() [3/3]
◆ checkForceCheckpoint()
◆ commit()
void kuzu::transaction::Transaction::commit |
( |
storage::WAL * | wal | ) |
const |
◆ getClientContext()
◆ getCommitTS()
◆ getCurrentTS()
int64_t kuzu::transaction::Transaction::getCurrentTS |
( |
| ) |
const |
|
inline |
◆ getEstimatedMemUsage()
uint64_t kuzu::transaction::Transaction::getEstimatedMemUsage |
( |
| ) |
const |
◆ getID()
◆ getLocalStorage()
◆ getMaxNodeOffsetBeforeCommit()
◆ getStartTS()
◆ getType()
◆ hasNewlyInsertedNodes()
bool kuzu::transaction::Transaction::hasNewlyInsertedNodes |
( |
common::table_id_t | tableID | ) |
const |
|
inline |
◆ isDummy()
bool kuzu::transaction::Transaction::isDummy |
( |
| ) |
const |
|
inline |
◆ isReadOnly()
bool kuzu::transaction::Transaction::isReadOnly |
( |
| ) |
const |
|
inline |
◆ isRecovery()
bool kuzu::transaction::Transaction::isRecovery |
( |
| ) |
const |
|
inline |
◆ isWriteTransaction()
bool kuzu::transaction::Transaction::isWriteTransaction |
( |
| ) |
const |
|
inline |
◆ pushCatalogEntry()
◆ pushSequenceChange()
void kuzu::transaction::Transaction::pushSequenceChange |
( |
catalog::SequenceCatalogEntry * | sequenceEntry, |
|
|
int64_t | kCount, |
|
|
const catalog::SequenceRollbackData & | data ) const |
◆ pushVectorDeleteInfo()
◆ pushVectorInsertInfo()
◆ pushVectorUpdateInfo()
◆ rollback()
void kuzu::transaction::Transaction::rollback |
( |
storage::WAL * | wal | ) |
const |
◆ setMaxCommittedNodeOffset()
◆ shouldAppendToUndoBuffer()
bool kuzu::transaction::Transaction::shouldAppendToUndoBuffer |
( |
| ) |
const |
|
inline |
◆ shouldForceCheckpoint()
bool kuzu::transaction::Transaction::shouldForceCheckpoint |
( |
| ) |
const |
◆ shouldLogToWAL()
bool kuzu::transaction::Transaction::shouldLogToWAL |
( |
| ) |
const |
◆ TransactionManager
friend class TransactionManager |
|
friend |
◆ DUMMY_START_TIMESTAMP
◆ DUMMY_TRANSACTION_ID
◆ START_TRANSACTION_ID
Initial value:=
uint64_t transaction_t
Definition types.h:57
The documentation for this class was generated from the following file: