public class EmbeddedLockManager extends java.lang.Object implements HiveLockManager
Constructor and Description |
---|
EmbeddedLockManager() |
Modifier and Type | Method and Description |
---|---|
void |
close() |
java.util.List<HiveLock> |
getLocks(boolean verifyTablePartitions,
boolean fetchData) |
java.util.List<HiveLock> |
getLocks(boolean verifyTablePartitions,
boolean fetchData,
HiveConf conf) |
java.util.List<HiveLock> |
getLocks(HiveLockObject key,
boolean verifyTablePartitions,
boolean fetchData) |
java.util.List<HiveLock> |
getLocks(HiveLockObject key,
boolean verifyTablePartitions,
boolean fetchData,
HiveConf conf) |
HiveLock |
lock(HiveLockObject key,
HiveLockMode mode,
boolean keepAlive) |
HiveLock |
lock(HiveLockObject key,
HiveLockMode mode,
int numRetriesForLock,
int sleepTime) |
java.util.List<HiveLock> |
lock(java.util.List<HiveLockObj> objs,
boolean keepAlive) |
java.util.List<HiveLock> |
lock(java.util.List<HiveLockObj> objs,
int numRetriesForLock,
int sleepTime) |
void |
prepareRetry() |
void |
refresh()
refresh to enable new configurations.
|
void |
releaseLocks(java.util.List<HiveLock> hiveLocks) |
void |
releaseLocks(java.util.List<HiveLock> hiveLocks,
int numRetriesForUnLock,
int sleepTime) |
void |
setContext(HiveLockManagerCtx ctx) |
void |
unlock(HiveLock hiveLock) |
void |
unlock(HiveLock hiveLock,
int numRetriesForUnLock,
int sleepTime) |
public void setContext(HiveLockManagerCtx ctx) throws LockException
setContext
in interface HiveLockManager
LockException
public HiveLock lock(HiveLockObject key, HiveLockMode mode, boolean keepAlive) throws LockException
lock
in interface HiveLockManager
key
- object to be lockedmode
- mode of the lock (SHARED/EXCLUSIVE)keepAlive
- if the lock needs to be persisted after the statementLockException
public java.util.List<HiveLock> lock(java.util.List<HiveLockObj> objs, boolean keepAlive) throws LockException
lock
in interface HiveLockManager
LockException
public void unlock(HiveLock hiveLock) throws LockException
unlock
in interface HiveLockManager
LockException
public void releaseLocks(java.util.List<HiveLock> hiveLocks)
releaseLocks
in interface HiveLockManager
public java.util.List<HiveLock> getLocks(boolean verifyTablePartitions, boolean fetchData) throws LockException
getLocks
in interface HiveLockManager
LockException
public java.util.List<HiveLock> getLocks(HiveLockObject key, boolean verifyTablePartitions, boolean fetchData) throws LockException
getLocks
in interface HiveLockManager
LockException
public void prepareRetry()
prepareRetry
in interface HiveLockManager
public void refresh()
HiveLockManager
refresh
in interface HiveLockManager
public HiveLock lock(HiveLockObject key, HiveLockMode mode, int numRetriesForLock, int sleepTime) throws LockException
LockException
public java.util.List<HiveLock> lock(java.util.List<HiveLockObj> objs, int numRetriesForLock, int sleepTime) throws LockException
LockException
public void unlock(HiveLock hiveLock, int numRetriesForUnLock, int sleepTime) throws LockException
LockException
public void releaseLocks(java.util.List<HiveLock> hiveLocks, int numRetriesForUnLock, int sleepTime)
public java.util.List<HiveLock> getLocks(boolean verifyTablePartitions, boolean fetchData, HiveConf conf) throws LockException
LockException
public java.util.List<HiveLock> getLocks(HiveLockObject key, boolean verifyTablePartitions, boolean fetchData, HiveConf conf) throws LockException
LockException
public void close()
close
in interface HiveLockManager
Copyright © 2012 The Apache Software Foundation