Package | Description |
---|---|
org.apache.hadoop.hive.ql | |
org.apache.hadoop.hive.ql.exec.mr | |
org.apache.hadoop.hive.ql.lockmgr |
Hive Lock Manager interfaces and some custom implmentations
|
org.apache.hadoop.hive.ql.lockmgr.zookeeper | |
org.apache.hadoop.hive.ql.session |
Modifier and Type | Method and Description |
---|---|
void |
Context.checkHeartbeaterLockException() |
void |
Driver.releaseLocksAndCommitOrRollback(boolean commit) |
void |
Driver.releaseLocksAndCommitOrRollback(boolean commit,
HiveTxnManager txnManager) |
Modifier and Type | Method and Description |
---|---|
int |
HadoopJobExecHelper.progress(org.apache.hadoop.mapred.RunningJob rj,
org.apache.hadoop.mapred.JobClient jc,
Context ctx) |
Modifier and Type | Method and Description |
---|---|
LockException |
DbTxnManager.Heartbeater.getLockException() |
Modifier and Type | Method and Description |
---|---|
void |
DbTxnManager.acquireLocks(QueryPlan plan,
Context ctx,
String username) |
void |
HiveTxnManager.acquireLocks(QueryPlan plan,
Context ctx,
String username)
Acquire all of the locks needed by a query.
|
void |
HiveTxnManager.acquireLocks(QueryPlan plan,
Context ctx,
String username,
Driver.LockedDriverState lDrvState)
Acquire all of the locks needed by a query.
|
LockResponse |
DbTxnManager.acquireMaterializationRebuildLock(String dbName,
String tableName,
long txnId) |
LockResponse |
HiveTxnManager.acquireMaterializationRebuildLock(String dbName,
String tableName,
long txnId)
Acquire the materialization rebuild lock for a given view.
|
void |
HiveLockManager.close() |
void |
DbLockManager.close() |
void |
DbTxnManager.commitTxn() |
void |
HiveTxnManager.commitTxn()
Commit the current transaction.
|
static long |
DbTxnManager.getHeartbeatInterval(org.apache.hadoop.conf.Configuration conf) |
HiveLockManager |
DbTxnManager.getLockManager()
we don't expect multiple threads to call this method concurrently but
DbTxnManager.lockMgr will
be read by a different threads than one writing it, thus it's volatile |
HiveLockManager |
HiveTxnManager.getLockManager()
Get the lock manager.
|
ShowLocksResponse |
DbLockManager.getLocks() |
List<HiveLock> |
HiveLockManager.getLocks(boolean verifyTablePartitions,
boolean fetchData) |
List<HiveLock> |
EmbeddedLockManager.getLocks(boolean verifyTablePartitions,
boolean fetchData) |
List<HiveLock> |
DbLockManager.getLocks(boolean verifyTablePartitions,
boolean fetchData) |
List<HiveLock> |
EmbeddedLockManager.getLocks(boolean verifyTablePartitions,
boolean fetchData,
HiveConf conf) |
List<HiveLock> |
HiveLockManager.getLocks(HiveLockObject key,
boolean verifyTablePartitions,
boolean fetchData) |
List<HiveLock> |
EmbeddedLockManager.getLocks(HiveLockObject key,
boolean verifyTablePartitions,
boolean fetchData) |
List<HiveLock> |
DbLockManager.getLocks(HiveLockObject key,
boolean verifyTablePartitions,
boolean fetchData) |
List<HiveLock> |
EmbeddedLockManager.getLocks(HiveLockObject key,
boolean verifyTablePartitions,
boolean fetchData,
HiveConf conf) |
ShowLocksResponse |
DbLockManager.getLocks(ShowLocksRequest showLocksRequest) |
long |
DbTxnManager.getTableWriteId(String dbName,
String tableName) |
long |
HiveTxnManager.getTableWriteId(String dbName,
String tableName)
if
isTxnOpen() , returns the table write ID associated with current active transaction. |
HiveTxnManager |
TxnManagerFactory.getTxnManager(HiveConf conf)
Create a new transaction manager.
|
org.apache.hadoop.hive.common.ValidTxnList |
DbTxnManager.getValidTxns() |
org.apache.hadoop.hive.common.ValidTxnList |
HiveTxnManager.getValidTxns()
Get the transactions that are currently valid.
|
org.apache.hadoop.hive.common.ValidTxnWriteIdList |
DbTxnManager.getValidWriteIds(List<String> tableList,
String validTxnList) |
org.apache.hadoop.hive.common.ValidTxnWriteIdList |
HiveTxnManager.getValidWriteIds(List<String> tableList,
String validTxnList)
Get the table write Ids that are valid for the current transaction.
|
void |
DbTxnManager.heartbeat() |
void |
HiveTxnManager.heartbeat()
Send a heartbeat to the transaction management storage so other Hive
clients know that the transaction and locks held by this client are
still valid.
|
HiveLock |
HiveLockManager.lock(HiveLockObject key,
HiveLockMode mode,
boolean keepAlive) |
HiveLock |
EmbeddedLockManager.lock(HiveLockObject key,
HiveLockMode mode,
boolean keepAlive) |
HiveLock |
DbLockManager.lock(HiveLockObject key,
HiveLockMode mode,
boolean keepAlive) |
HiveLock |
EmbeddedLockManager.lock(HiveLockObject key,
HiveLockMode mode,
int numRetriesForLock,
long sleepTime) |
List<HiveLock> |
HiveLockManager.lock(List<HiveLockObj> objs,
boolean keepAlive,
Driver.LockedDriverState lDrvState) |
List<HiveLock> |
EmbeddedLockManager.lock(List<HiveLockObj> objs,
boolean keepAlive,
Driver.LockedDriverState lDrvState) |
List<HiveLock> |
DbLockManager.lock(List<HiveLockObj> objs,
boolean keepAlive,
Driver.LockedDriverState lDrvState) |
long |
DbTxnManager.openTxn(Context ctx,
String user) |
long |
HiveTxnManager.openTxn(Context ctx,
String user)
Open a new transaction.
|
void |
HiveLockManager.prepareRetry() |
void |
DbLockManager.prepareRetry() |
void |
DbTxnManager.releaseLocks(List<HiveLock> hiveLocks) |
void |
HiveTxnManager.releaseLocks(List<HiveLock> hiveLocks)
Release specified locks.
|
void |
DbTxnManager.replAllocateTableWriteIdsBatch(String dbName,
String tableName,
String replPolicy,
List<TxnToWriteId> srcTxnToWriteIdList) |
void |
HiveTxnManager.replAllocateTableWriteIdsBatch(String dbName,
String tableName,
String replPolicy,
List<TxnToWriteId> srcTxnToWriteIdList)
Allocates write id for each transaction in the list.
|
void |
DbTxnManager.replCommitTxn(String replPolicy,
long srcTxnId) |
void |
HiveTxnManager.replCommitTxn(String replPolicy,
long srcTxnId)
Commit the transaction in target cluster.
|
List<Long> |
DbTxnManager.replOpenTxn(String replPolicy,
List<Long> srcTxnIds,
String user) |
List<Long> |
HiveTxnManager.replOpenTxn(String replPolicy,
List<Long> srcTxnIds,
String user)
Open a new transaction in target cluster.
|
void |
DbTxnManager.replRollbackTxn(String replPolicy,
long srcTxnId) |
void |
HiveTxnManager.replRollbackTxn(String replPolicy,
long srcTxnId)
Abort the transaction in target cluster.
|
void |
DbTxnManager.replTableWriteIdState(String validWriteIdList,
String dbName,
String tableName,
List<String> partNames) |
void |
HiveTxnManager.replTableWriteIdState(String validWriteIdList,
String dbName,
String tableName,
List<String> partNames)
Replicate Table Write Ids state to mark aborted write ids and writeid high water mark.
|
void |
DbTxnManager.rollbackTxn() |
void |
HiveTxnManager.rollbackTxn()
Abort the current transaction.
|
void |
HiveLockManager.setContext(HiveLockManagerCtx ctx) |
void |
EmbeddedLockManager.setContext(HiveLockManagerCtx ctx) |
void |
DbLockManager.setContext(HiveLockManagerCtx ctx) |
void |
HiveLockManager.unlock(HiveLock hiveLock) |
void |
EmbeddedLockManager.unlock(HiveLock hiveLock) |
void |
DbLockManager.unlock(HiveLock hiveLock) |
void |
EmbeddedLockManager.unlock(HiveLock hiveLock,
int numRetriesForUnLock,
long sleepTime) |
Modifier and Type | Method and Description |
---|---|
void |
ZooKeeperHiveLockManager.close() |
List<HiveLock> |
ZooKeeperHiveLockManager.getLocks(boolean verifyTablePartition,
boolean fetchData) |
List<HiveLock> |
ZooKeeperHiveLockManager.getLocks(HiveLockObject key,
boolean verifyTablePartitions,
boolean fetchData) |
ZooKeeperHiveLock |
ZooKeeperHiveLockManager.lock(HiveLockObject key,
HiveLockMode mode,
boolean keepAlive) |
List<HiveLock> |
ZooKeeperHiveLockManager.lock(List<HiveLockObj> lockObjects,
boolean keepAlive,
Driver.LockedDriverState lDrvState) |
void |
ZooKeeperHiveLockManager.prepareRetry() |
void |
ZooKeeperHiveLockManager.setContext(HiveLockManagerCtx ctx) |
void |
ZooKeeperHiveLockManager.unlock(HiveLock hiveLock) |
Modifier and Type | Method and Description |
---|---|
HiveTxnManager |
SessionState.initTxnMgr(HiveConf conf)
Initialize the transaction manager.
|
Copyright © 2022 The Apache Software Foundation. All rights reserved.