Uses of Class
org.apache.storm.hdfs.spout.DirLock
-
Uses of DirLock in org.apache.storm.hdfs.spout
Modifier and TypeMethodDescriptionstatic DirLock
DirLock.takeOwnershipIfStale
(org.apache.hadoop.fs.FileSystem fs, org.apache.hadoop.fs.Path dirToLock, int lockTimeoutSec) if the lock on the directory is stale, take ownership.static DirLock
DirLock.tryLock
(org.apache.hadoop.fs.FileSystem fs, org.apache.hadoop.fs.Path dir) Get a lock on file if not already locked.