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. throws if unexpected problem