Uses of Class
org.apache.storm.hdfs.spout.FileLock
-
Uses of FileLock in org.apache.storm.hdfs.spout
Modifier and TypeMethodDescriptionstatic 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.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. throws if unexpected problem