Package | Description |
---|---|
org.apache.storm.hdfs.common | |
org.apache.storm.hdfs.spout |
Modifier and Type | Method and Description |
---|---|
static <K,V> HdfsUtils.Pair |
HdfsUtils.Pair.of(K key,
V value) |
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.
|
Copyright © 2022 The Apache Software Foundation. All rights reserved.