Package org.apache.hadoop.hbase.procedure2

Class ProcedureFutureUtil

java.lang.Object

org.apache.hadoop.hbase.procedure2.ProcedureFutureUtil

@Private
public final class ProcedureFutureUtil
extends Object

A helper class for switching procedure out(yielding) while it is doing some time consuming operation, such as updating meta, where we can get a CompletableFuture about the operation.

Field Summary

Fields

Modifier and Type	Field	Description
private static final org.slf4j.Logger	LOG

Constructor Summary

Constructors

Modifier	Constructor	Description
private	ProcedureFutureUtil()

Method Summary

Modifier and Type	Method	Description
static boolean	checkFuture(Procedure<?> proc, Supplier<CompletableFuture<Void>> getFuture, Consumer<CompletableFuture<Void>> setFuture, Runnable actionAfterDone)
static void	suspend(Procedure<?> proc)
static void	suspendIfNecessary(Procedure<?> proc, Consumer<CompletableFuture<Void>> setFuture, CompletableFuture<Void> future, MasterProcedureEnv env, Runnable actionAfterDone)
static void	wakeUp(Procedure<?> proc, MasterProcedureEnv env)

Methods inherited from class java.lang.Object

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

Field Details

LOG

private static final org.slf4j.Logger LOG

Constructor Details

ProcedureFutureUtil

private ProcedureFutureUtil()

Method Details

checkFuture

public static boolean checkFuture(Procedure<?> proc,
 Supplier<CompletableFuture<Void>> getFuture,
 Consumer<CompletableFuture<Void>> setFuture,
 Runnable actionAfterDone)
                           throws IOException

Throws:

IOException

suspendIfNecessary

public static void suspendIfNecessary(Procedure<?> proc,
 Consumer<CompletableFuture<Void>> setFuture,
 CompletableFuture<Void> future,
 MasterProcedureEnv env,
 Runnable actionAfterDone)
                               throws IOException,
ProcedureSuspendedException

Throws:

IOException

ProcedureSuspendedException

suspend

public static void suspend(Procedure<?> proc)
                    throws ProcedureSuspendedException

Throws:

ProcedureSuspendedException

wakeUp

public static void wakeUp(Procedure<?> proc,
 MasterProcedureEnv env)