org.apache.hadoop.hbase.master.procedure

Class ProcedureSyncWait

java.lang.Object

org.apache.hadoop.hbase.master.procedure.ProcedureSyncWait

@InterfaceAudience.Private
 @InterfaceStability.Evolving
public final class ProcedureSyncWait
extends Object

Helper to synchronously wait on conditions. This will be removed in the future (mainly when the AssignmentManager will be replaced with a Procedure version) by using ProcedureYieldException, and the queue will handle waiting and scheduling based on events.

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
static interface	ProcedureSyncWait.Predicate<T>

Method Summary

Modifier and Type	Method and Description
protected static MasterQuotaManager	getMasterQuotaManager(MasterProcedureEnv env)
protected static List<HRegionInfo>	getRegionsFromMeta(MasterProcedureEnv env, TableName tableName)
static byte[]	submitAndWaitProcedure(ProcedureExecutor<MasterProcedureEnv> procExec, Procedure proc)
static <T> T	waitFor(MasterProcedureEnv env, long waitTime, long waitingTimeForEvents, String purpose, ProcedureSyncWait.Predicate<T> predicate)
static <T> T	waitFor(MasterProcedureEnv env, String purpose, ProcedureSyncWait.Predicate<T> predicate)
static byte[]	waitForProcedureToComplete(ProcedureExecutor<MasterProcedureEnv> procExec, long procId)
protected static void	waitMetaRegions(MasterProcedureEnv env)
protected static void	waitRegionInTransition(MasterProcedureEnv env, List<HRegionInfo> regions)
protected static void	waitRegionServers(MasterProcedureEnv env)

Methods inherited from class java.lang.Object

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

Method Detail

submitAndWaitProcedure

public static byte[] submitAndWaitProcedure(ProcedureExecutor<MasterProcedureEnv> procExec,
                                            Procedure proc)
                                     throws IOException

Throws:

IOException

waitForProcedureToComplete

public static byte[] waitForProcedureToComplete(ProcedureExecutor<MasterProcedureEnv> procExec,
                                                long procId)
                                         throws IOException

Throws:

IOException

waitFor

public static <T> T waitFor(MasterProcedureEnv env,
                            String purpose,
                            ProcedureSyncWait.Predicate<T> predicate)
                     throws IOException

Throws:

IOException

waitFor

public static <T> T waitFor(MasterProcedureEnv env,
                            long waitTime,
                            long waitingTimeForEvents,
                            String purpose,
                            ProcedureSyncWait.Predicate<T> predicate)
                     throws IOException

Throws:

IOException

waitMetaRegions

protected static void waitMetaRegions(MasterProcedureEnv env)
                               throws IOException

Throws:

IOException

waitRegionServers

protected static void waitRegionServers(MasterProcedureEnv env)
                                 throws IOException

Throws:

IOException

getRegionsFromMeta

protected static List<HRegionInfo> getRegionsFromMeta(MasterProcedureEnv env,
                                                      TableName tableName)
                                               throws IOException

Throws:

IOException

waitRegionInTransition

protected static void waitRegionInTransition(MasterProcedureEnv env,
                                             List<HRegionInfo> regions)
                                      throws IOException,
                                             CoordinatedStateException

Throws:

IOException

CoordinatedStateException

getMasterQuotaManager

protected static MasterQuotaManager getMasterQuotaManager(MasterProcedureEnv env)
                                                   throws IOException

Throws:

IOException