Package | Description |
---|---|
org.apache.hadoop.hive.metastore.txn |
Modifier and Type | Method and Description |
---|---|
void |
TxnStore.abortTxn(AbortTxnRequest rqst)
Abort (rollback) a transaction.
|
void |
TxnStore.abortTxns(AbortTxnsRequest rqst)
Abort (rollback) a list of transactions in one request.
|
void |
TxnStore.cleanupRecords(HiveObjectType type,
Database db,
Table table,
Iterator<Partition> partitionIterator)
Clean up corresponding records in metastore tables.
|
void |
TxnStore.commitTxn(CommitTxnRequest rqst)
Commit a transaction
|
CompactionResponse |
TxnStore.compact(CompactionRequest rqst)
Submit a compaction request into the queue.
|
Materialization |
TxnStore.getMaterializationInvalidationInfo(CreationMetadata cm,
String validTxnList)
Get invalidation info for the materialization.
|
TxnStore.MutexAPI |
TxnStore.getMutexAPI() |
void |
TxnStore.onRename(String oldCatName,
String oldDbName,
String oldTabName,
String oldPartName,
String newCatName,
String newDbName,
String newTabName,
String newPartName) |
OpenTxnsResponse |
TxnStore.openTxns(OpenTxnRequest rqst)
Open a set of transactions
|
void |
TxnStore.performTimeOuts()
Timeout transactions and/or locks.
|
void |
TxnStore.replTableWriteIdState(ReplTblWriteIdStateRequest rqst)
Replicate Table Write Ids state to mark aborted write ids and writeid high water mark.
|
void |
TxnStore.revokeFromLocalWorkers(String hostname)
This will take all entries assigned to workers
on a host return them to INITIATED state.
|
void |
TxnStore.revokeTimedoutWorkers(long timeout)
This call will return all compaction queue
entries assigned to a worker but over the timeout back to the initiated state.
|
void |
TxnStore.setCompactionHighestWriteId(CompactionInfo ci,
long highestWriteId)
Record the highest write id that the
ci compaction job will pay attention to. |
void |
TxnStore.setHadoopJobId(String hadoopJobId,
long id)
Once a
ThreadPoolExecutor Worker submits a job to the cluster,
it calls this to update the metadata. |
void |
TxnStore.setRunAs(long cq_id,
String user)
Sets the user to run as.
|
void |
TxnStore.unlock(UnlockRequest rqst)
Unlock a lock.
|
Copyright © 2022 The Apache Software Foundation. All rights reserved.