Package | Description |
---|---|
org.apache.storm.hdfs.spout |
Modifier and Type | Method and Description |
---|---|
static 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.
|
Copyright © 2022 The Apache Software Foundation. All rights reserved.