Package org.apache.hadoop.hbase.backup.regionserver

Class LogRollBackupSubprocedurePool

java.lang.Object

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

All Implemented Interfaces:

Closeable, AutoCloseable, Abortable

@Private
public class LogRollBackupSubprocedurePool
extends Object
implements Closeable, Abortable

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

Field Summary

Fields

Modifier and Type	Field	Description
private boolean	aborted
private static final String	CONCURENT_BACKUP_TASKS_KEY	Maximum number of concurrent snapshot region tasks that can run concurrently
private static final int	DEFAULT_CONCURRENT_BACKUP_TASKS
private final ThreadPoolExecutor	executor
private final List<Future<Void>>	futures
private static final org.slf4j.Logger	LOG
private final String	name
private final ExecutorCompletionService<Void>	taskPool

Constructor Summary

Constructors

Constructor	Description
LogRollBackupSubprocedurePool(String name, org.apache.hadoop.conf.Configuration conf)

Method Summary

Modifier and Type	Method	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

Methods inherited from interface org.apache.hadoop.hbase.Abortable

abort

Field Details

LOG

private static final org.slf4j.Logger LOG

CONCURENT_BACKUP_TASKS_KEY

private static final String CONCURENT_BACKUP_TASKS_KEY

Maximum number of concurrent snapshot region tasks that can run concurrently

See Also:

• Constant Field Values

DEFAULT_CONCURRENT_BACKUP_TASKS

private static final int DEFAULT_CONCURRENT_BACKUP_TASKS

See Also:

• Constant Field Values

taskPool

private final ExecutorCompletionService<Void> taskPool

executor

private final ThreadPoolExecutor executor

aborted

private volatile boolean aborted

futures

private final List<Future<Void>> futures

name

private final String name

Constructor Details

LogRollBackupSubprocedurePool

public LogRollBackupSubprocedurePool(String name,
 org.apache.hadoop.conf.Configuration conf)

Method Details

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 AutoCloseable

Specified by:

close in interface Closeable

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