Package | Description |
---|---|
org.apache.hadoop.hive.metastore.txn |
Modifier and Type | Method and Description |
---|---|
void |
TxnStore.addDynamicPartitions(AddDynamicPartitions rqst)
Add information on a set of dynamic partitions that participated in a transaction.
|
LockResponse |
TxnStore.checkLock(CheckLockRequest rqst)
Check whether a lock has been obtained.
|
void |
TxnStore.cleanEmptyAbortedTxns()
Clean up aborted transactions from txns that have no components in txn_components.
|
void |
TxnStore.cleanTxnToWriteIdTable()
Clean up entries from TXN_TO_WRITE_ID table less than min_uncommited_txnid as found by
min(NEXT_TXN_ID.ntxn_next, min(MIN_HISTORY_LEVEL.mhl_min_open_txnid), min(Aborted TXNS.txn_id)).
|
void |
TxnStore.heartbeat(HeartbeatRequest ids)
Send a heartbeat for a lock or a transaction
|
HeartbeatTxnRangeResponse |
TxnStore.heartbeatTxnRange(HeartbeatTxnRangeRequest rqst)
Heartbeat a group of transactions together
|
void |
TxnStore.markCompacted(CompactionInfo info)
This will mark an entry in the queue as compacted
and put it in the ready to clean state.
|
void |
TxnStore.performWriteSetGC()
WriteSet tracking is used to ensure proper transaction isolation.
|
void |
TxnStore.purgeCompactionHistory()
For any given compactable entity (partition, table if not partitioned) the history of compactions
may look like "sssfffaaasffss", for example.
|
Copyright © 2022 The Apache Software Foundation. All rights reserved.