Package | Description |
---|---|
org.apache.hadoop.hive.metastore | |
org.apache.hadoop.hive.metastore.api | |
org.apache.hadoop.hive.metastore.txn |
Modifier and Type | Method and Description |
---|---|
LockResponse |
HiveMetaStore.HMSHandler.check_lock(CheckLockRequest rqst) |
LockResponse |
IMetaStoreClient.checkLock(long lockid)
Check the status of a set of locks requested via a
IMetaStoreClient.lock(org.apache.hadoop.hive.metastore.api.LockRequest) call. |
LockResponse |
HiveMetaStoreClient.checkLock(long lockid) |
void |
HiveMetaStore.HMSHandler.heartbeat(HeartbeatRequest ids) |
void |
IMetaStoreClient.heartbeat(long txnid,
long lockid)
Send a heartbeat to indicate that the client holding these locks (if
any) and that opened this transaction (if one exists) is still alive.
|
void |
HiveMetaStoreClient.heartbeat(long txnid,
long lockid) |
void |
IMetaStoreClient.unlock(long lockid)
Unlock a set of locks.
|
void |
HiveMetaStoreClient.unlock(long lockid) |
void |
HiveMetaStore.HMSHandler.unlock(UnlockRequest rqst) |
Modifier and Type | Method and Description |
---|---|
NoSuchLockException |
NoSuchLockException.deepCopy() |
NoSuchLockException |
ThriftHiveMetastore.unlock_result.getO1() |
NoSuchLockException |
ThriftHiveMetastore.heartbeat_result.getO1() |
NoSuchLockException |
ThriftHiveMetastore.check_lock_result.getO3() |
Modifier and Type | Method and Description |
---|---|
int |
NoSuchLockException.compareTo(NoSuchLockException other) |
boolean |
NoSuchLockException.equals(NoSuchLockException that) |
void |
ThriftHiveMetastore.unlock_result.setO1(NoSuchLockException o1) |
void |
ThriftHiveMetastore.heartbeat_result.setO1(NoSuchLockException o1) |
void |
ThriftHiveMetastore.check_lock_result.setO3(NoSuchLockException o3) |
Modifier and Type | Method and Description |
---|---|
LockResponse |
ThriftHiveMetastore.Iface.check_lock(CheckLockRequest rqst) |
LockResponse |
ThriftHiveMetastore.Client.check_lock(CheckLockRequest rqst) |
LockResponse |
ThriftHiveMetastore.AsyncClient.check_lock_call.getResult() |
void |
ThriftHiveMetastore.AsyncClient.unlock_call.getResult() |
void |
ThriftHiveMetastore.AsyncClient.heartbeat_call.getResult() |
void |
ThriftHiveMetastore.Iface.heartbeat(HeartbeatRequest ids) |
void |
ThriftHiveMetastore.Client.heartbeat(HeartbeatRequest ids) |
LockResponse |
ThriftHiveMetastore.Client.recv_check_lock() |
void |
ThriftHiveMetastore.Client.recv_heartbeat() |
void |
ThriftHiveMetastore.Client.recv_unlock() |
void |
ThriftHiveMetastore.Iface.unlock(UnlockRequest rqst) |
void |
ThriftHiveMetastore.Client.unlock(UnlockRequest rqst) |
Constructor and Description |
---|
check_lock_result(LockResponse success,
NoSuchTxnException o1,
TxnAbortedException o2,
NoSuchLockException o3) |
heartbeat_result(NoSuchLockException o1,
NoSuchTxnException o2,
TxnAbortedException o3) |
NoSuchLockException(NoSuchLockException other)
Performs a deep copy on other.
|
unlock_result(NoSuchLockException o1,
TxnOpenException o2) |
Modifier and Type | Method and Description |
---|---|
LockResponse |
TxnStore.checkLock(CheckLockRequest rqst)
Check whether a lock has been obtained.
|
void |
TxnStore.heartbeat(HeartbeatRequest ids)
Send a heartbeat for a lock or a transaction
|
void |
TxnStore.unlock(UnlockRequest rqst)
Unlock a lock.
|
Copyright © 2021 The Apache Software Foundation. All rights reserved.