org.apache.hadoop.hbase.master.cleaner

Class CleanerChore.CleanerTask

java.lang.Object

java.util.concurrent.ForkJoinTask<V>

java.util.concurrent.RecursiveTask<Boolean>

org.apache.hadoop.hbase.master.cleaner.CleanerChore.CleanerTask

All Implemented Interfaces:

Serializable, Future<Boolean>

Enclosing class:

CleanerChore<T extends FileCleanerDelegate>

private class CleanerChore.CleanerTask
extends RecursiveTask<Boolean>

Attemps to clean up a directory, its subdirectories, and files. Return value is true if everything was deleted. false on partial / total failures.

Field Summary

Fields

Modifier and Type	Field and Description
private org.apache.hadoop.fs.Path	dir
private boolean	root

Constructor Summary

Constructors

Constructor and Description
CleanerTask(org.apache.hadoop.fs.FileStatus dir, boolean root)
CleanerTask(org.apache.hadoop.fs.Path dir, boolean root)

Method Summary

Modifier and Type	Method and Description
protected Boolean	compute()
private boolean	deleteAction(CleanerChore.Action<Boolean> deletion, String type) Perform a delete on a specified type.
private boolean	getCleanResult(List<CleanerChore.CleanerTask> tasks) Get cleaner results of subdirs.
private List<org.apache.hadoop.fs.FileStatus>	getFilteredStatus(org.apache.hbase.thirdparty.com.google.common.base.Predicate<org.apache.hadoop.fs.FileStatus> function) Get FileStatus with filter.

Methods inherited from class java.util.concurrent.RecursiveTask

exec, getRawResult, setRawResult

Methods inherited from class java.util.concurrent.ForkJoinTask

adapt, adapt, adapt, cancel, compareAndSetForkJoinTaskTag, complete, completeExceptionally, fork, get, get, getException, getForkJoinTaskTag, getPool, getQueuedTaskCount, getSurplusQueuedTaskCount, helpQuiesce, inForkJoinPool, invoke, invokeAll, invokeAll, invokeAll, isCancelled, isCompletedAbnormally, isCompletedNormally, isDone, join, peekNextLocalTask, pollNextLocalTask, pollTask, quietlyComplete, quietlyInvoke, quietlyJoin, reinitialize, setForkJoinTaskTag, tryUnfork

Methods inherited from class java.lang.Object

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

Field Detail

dir

private final org.apache.hadoop.fs.Path dir

root

private final boolean root

Constructor Detail

CleanerTask

CleanerTask(org.apache.hadoop.fs.FileStatus dir,
            boolean root)

CleanerTask

CleanerTask(org.apache.hadoop.fs.Path dir,
            boolean root)

Method Detail

compute

protected Boolean compute()

Specified by:

compute in class RecursiveTask<Boolean>

getFilteredStatus

private List<org.apache.hadoop.fs.FileStatus> getFilteredStatus(org.apache.hbase.thirdparty.com.google.common.base.Predicate<org.apache.hadoop.fs.FileStatus> function)
                                                         throws IOException

Get FileStatus with filter. Pay attention that FSUtils #listStatusWithStatusFilter would return null, even though status is empty but not null.

Parameters:

function - a filter function

Returns:

filtered FileStatus or null if dir doesn't exist

Throws:

IOException - if there's an error other than dir not existing

deleteAction

private boolean deleteAction(CleanerChore.Action<Boolean> deletion,
                             String type)

Perform a delete on a specified type.

Parameters:

deletion - a delete

type - possible values are 'files', 'subdirs', 'dirs'

Returns:

true if it deleted successfully, false otherwise

getCleanResult

private boolean getCleanResult(List<CleanerChore.CleanerTask> tasks)
                        throws IOException

Get cleaner results of subdirs.

Parameters:

tasks - subdirs cleaner tasks

Returns:

true if all subdirs deleted successfully, false for patial/all failures

Throws:

IOException - something happen during computation