Uses of Class
org.apache.storm.hdfs.spout.FileLock

Packages that use FileLock

Package	Description
org.apache.storm.hdfs.spout

Uses of FileLock in org.apache.storm.hdfs.spout

Methods in org.apache.storm.hdfs.spout that return FileLock

Modifier and Type	Method and Description
static FileLock	FileLock.acquireOldestExpiredLock(org.apache.hadoop.fs.FileSystem fs, org.apache.hadoop.fs.Path lockFilesDir, int locktimeoutSec, String spoutId) Finds a oldest expired lock file (using modification timestamp), then takes ownership of the lock file Impt: Assumes access to lockFilesDir has been externally synchronized such that only one thread accessing the same thread
static FileLock	FileLock.takeOwnership(org.apache.hadoop.fs.FileSystem fs, org.apache.hadoop.fs.Path lockFile, FileLock.LogEntry lastEntry, String spoutId) Takes ownership of the lock file if possible.
static FileLock	FileLock.tryLock(org.apache.hadoop.fs.FileSystem fs, org.apache.hadoop.fs.Path fileToLock, org.apache.hadoop.fs.Path lockDirPath, String spoutId) returns lock on file or null if file is already locked.