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 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.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.
-