public class HdfsLockFactory extends LockFactory
Modifier and Type | Field and Description |
---|---|
static org.slf4j.Logger |
log |
lockPrefix
Constructor and Description |
---|
HdfsLockFactory(org.apache.hadoop.fs.Path lockPath,
org.apache.hadoop.conf.Configuration configuration) |
Modifier and Type | Method and Description |
---|---|
void |
clearLock(String lockName) |
org.apache.hadoop.fs.Path |
getLockPath() |
Lock |
makeLock(String lockName) |
void |
setLockPath(org.apache.hadoop.fs.Path lockPath) |
getLockPrefix, setLockPrefix
public HdfsLockFactory(org.apache.hadoop.fs.Path lockPath, org.apache.hadoop.conf.Configuration configuration)
public Lock makeLock(String lockName)
makeLock
in class LockFactory
public void clearLock(String lockName) throws IOException
clearLock
in class LockFactory
IOException
public org.apache.hadoop.fs.Path getLockPath()
public void setLockPath(org.apache.hadoop.fs.Path lockPath)
Copyright © 2000-2014 Apache Software Foundation. All Rights Reserved.