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() |
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 |
HiveTxnManager.acquireLocks(QueryPlan plan,
Context ctx,
String username)
Acquire all of the locks needed by a query.
|
void |
DbTxnManager.acquireLocks(QueryPlan plan,
Context ctx,
String username) |
void |
HiveLockManager.close() |
void |
DbLockManager.close() |
void |
HiveTxnManager.commitTxn()
Commit the current transaction.
|
void |
DbTxnManager.commitTxn() |
HiveLockManager |
HiveTxnManager.getLockManager()
Get the lock manager.
|
HiveLockManager |
DbTxnManager.getLockManager() |
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) |
HiveTxnManager |
TxnManagerFactory.getTxnManager(HiveConf conf)
Create a new transaction manager.
|
ValidTxnList |
HiveTxnManager.getValidTxns()
Get the transactions that are currently valid.
|
ValidTxnList |
DbTxnManager.getValidTxns() |
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.
|
void |
DbTxnManager.heartbeat() |
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) |
List<HiveLock> |
EmbeddedLockManager.lock(List<HiveLockObj> objs,
boolean keepAlive) |
List<HiveLock> |
DbLockManager.lock(List<HiveLockObj> objs,
boolean keepAlive) |
List<HiveLock> |
EmbeddedLockManager.lock(List<HiveLockObj> objs,
int numRetriesForLock,
long sleepTime) |
long |
HiveTxnManager.openTxn(String user)
Open a new transaction.
|
long |
DbTxnManager.openTxn(String user) |
void |
HiveLockManager.prepareRetry() |
void |
DbLockManager.prepareRetry() |
void |
HiveTxnManager.releaseLocks(List<HiveLock> hiveLocks)
Release specified locks.
|
void |
DbTxnManager.releaseLocks(List<HiveLock> hiveLocks) |
void |
HiveTxnManager.rollbackTxn()
Abort the current transaction.
|
void |
DbTxnManager.rollbackTxn() |
void |
HiveTxnManager.setAutoCommit(boolean autoCommit)
This behaves exactly as
https://docs.oracle.com/javase/6/docs/api/java/sql/Connection.html#setAutoCommit(boolean)
|
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) |
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 © 2016 The Apache Software Foundation. All rights reserved.