org.apache.hadoop.hbase.util

Class HBaseFsck.FileLockCallable

java.lang.Object

org.apache.hadoop.hbase.util.HBaseFsck.FileLockCallable

All Implemented Interfaces:

Callable<org.apache.hadoop.fs.FSDataOutputStream>

Enclosing class:

HBaseFsck

private static class HBaseFsck.FileLockCallable
extends Object
implements Callable<org.apache.hadoop.fs.FSDataOutputStream>

Field Summary

Fields

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 Summary

Constructors

Constructor and Description
FileLockCallable(org.apache.hadoop.conf.Configuration conf, RetryCounter retryCounter)

Method Summary

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()

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Field Detail

retryCounter

RetryCounter retryCounter

conf

private final org.apache.hadoop.conf.Configuration conf

hbckLockPath

private org.apache.hadoop.fs.Path hbckLockPath

Constructor Detail

FileLockCallable

public FileLockCallable(org.apache.hadoop.conf.Configuration conf,
                        RetryCounter retryCounter)

Method Detail

getHbckLockPath

org.apache.hadoop.fs.Path getHbckLockPath()

Returns:

Will be null unless you call call()

call

public org.apache.hadoop.fs.FSDataOutputStream call()
                                             throws IOException

Specified by:

call in interface Callable<org.apache.hadoop.fs.FSDataOutputStream>

Throws:

IOException

createFileWithRetries

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

Throws:

IOException