| 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 © 2021 The Apache Software Foundation. All rights reserved.