Uses of Class
org.apache.storm.hdfs.spout.FileLock
Packages that use FileLock
-
Uses of FileLock in org.apache.storm.hdfs.spout
Methods in org.apache.storm.hdfs.spout that return FileLockModifier and TypeMethodDescriptionstatic FileLockFileLock.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 FileLockFileLock.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 FileLockFileLock.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.