private static class HBaseFsck.FileLockCallable extends Object implements Callable<org.apache.hadoop.fs.FSDataOutputStream>
Modifier and Type | Field and Description |
---|---|
private org.apache.hadoop.conf.Configuration |
conf |
private org.apache.hadoop.fs.Path |
hbckLockPath |
(package private) RetryCounter |
retryCounter |
Constructor and Description |
---|
FileLockCallable(org.apache.hadoop.conf.Configuration conf,
RetryCounter retryCounter) |
Modifier and Type | Method and Description |
---|---|
org.apache.hadoop.fs.FSDataOutputStream |
call() |
private org.apache.hadoop.fs.FSDataOutputStream |
createFileWithRetries(org.apache.hadoop.fs.FileSystem fs,
org.apache.hadoop.fs.Path hbckLockFilePath,
org.apache.hadoop.fs.permission.FsPermission defaultPerms) |
(package private) org.apache.hadoop.fs.Path |
getHbckLockPath()
Returns Will be
null unless you call call() |
RetryCounter retryCounter
private final org.apache.hadoop.conf.Configuration conf
private org.apache.hadoop.fs.Path hbckLockPath
public FileLockCallable(org.apache.hadoop.conf.Configuration conf, RetryCounter retryCounter)
org.apache.hadoop.fs.Path getHbckLockPath()
null
unless you call call()
public org.apache.hadoop.fs.FSDataOutputStream call() throws IOException
call
in interface Callable<org.apache.hadoop.fs.FSDataOutputStream>
IOException
private org.apache.hadoop.fs.FSDataOutputStream createFileWithRetries(org.apache.hadoop.fs.FileSystem fs, org.apache.hadoop.fs.Path hbckLockFilePath, org.apache.hadoop.fs.permission.FsPermission defaultPerms) throws IOException
IOException
Copyright © 2007–2020 The Apache Software Foundation. All rights reserved.