org.apache.hadoop.hbase.backup.regionserver

Class LogRollBackupSubprocedurePool

java.lang.Object

org.apache.hadoop.hbase.backup.regionserver.LogRollBackupSubprocedurePool

All Implemented Interfaces:

Closeable, AutoCloseable, Abortable

public class LogRollBackupSubprocedurePool
extends Object
implements Closeable, Abortable

Handle running each of the individual tasks for completing a backup procedure on a regionserver.

Constructor Summary

Constructors

Constructor and Description
LogRollBackupSubprocedurePool(String name, Configuration conf)

Method Summary

Modifier and Type	Method and Description
void	abort(String why, Throwable e) Abort the server or client.
void	close() Attempt to cleanly shutdown any running tasks - allows currently running tasks to cleanly finish
boolean	isAborted() Check if the server or client was aborted.
void	submitTask(Callable<Void> task) Submit a task to the pool.
boolean	waitForOutstandingTasks() Wait for all of the currently outstanding tasks submitted via submitTask(Callable)

Methods inherited from class java.lang.Object

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

Constructor Detail

LogRollBackupSubprocedurePool

public LogRollBackupSubprocedurePool(String name,
                                     Configuration conf)

Method Detail

submitTask

public void submitTask(Callable<Void> task)

Submit a task to the pool.

waitForOutstandingTasks

public boolean waitForOutstandingTasks()
                                throws ForeignException

Wait for all of the currently outstanding tasks submitted via submitTask(Callable)

Returns:

true on success, false otherwise

Throws:

ForeignException - exception

close

public void close()

Attempt to cleanly shutdown any running tasks - allows currently running tasks to cleanly finish

Specified by:

close in interface Closeable

Specified by:

close in interface AutoCloseable

abort

public void abort(String why,
                  Throwable e)

Description copied from interface: Abortable

Abort the server or client.

Specified by:

abort in interface Abortable

Parameters:

why - Why we're aborting.

e - Throwable that caused abort. Can be null.

isAborted

public boolean isAborted()

Description copied from interface: Abortable

Check if the server or client was aborted.

Specified by:

isAborted in interface Abortable

Returns:

true if the server or client was aborted, false otherwise