Uses of Class
org.apache.storm.hdfs.common.HdfsUtils.Pair

Packages that use HdfsUtils.Pair

Package	Description
org.apache.storm.hdfs.common
org.apache.storm.hdfs.spout

Uses of HdfsUtils.Pair in org.apache.storm.hdfs.common

Methods in org.apache.storm.hdfs.common that return HdfsUtils.Pair

Modifier and Type	Method and Description
static <K,V> HdfsUtils.Pair	HdfsUtils.Pair.of(K key, V value)

Uses of HdfsUtils.Pair in org.apache.storm.hdfs.spout

Methods in org.apache.storm.hdfs.spout that return HdfsUtils.Pair

Modifier and Type	Method and Description
static HdfsUtils.Pair<org.apache.hadoop.fs.Path,FileLock.LogEntry>	FileLock.locateOldestExpiredLock(org.apache.hadoop.fs.FileSystem fs, org.apache.hadoop.fs.Path lockFilesDir, int locktimeoutSec) Finds oldest expired lock file (using modification timestamp), then takes ownership of the lock file Impt: Assumes access to lockFilesDir has been externally synchronized such that only one thread accessing the same thread