@InterfaceAudience.Private @InterfaceStability.Evolving public final class ProcedureSyncWait extends Object
| Modifier and Type | Class and Description |
|---|---|
static interface |
ProcedureSyncWait.Predicate<T> |
| Modifier and Type | Field and Description |
|---|---|
private static org.apache.commons.logging.Log |
LOG |
| Modifier | Constructor and Description |
|---|---|
private |
ProcedureSyncWait() |
| 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) |
public static byte[] submitAndWaitProcedure(ProcedureExecutor<MasterProcedureEnv> procExec, Procedure proc) throws IOException
IOExceptionpublic static byte[] waitForProcedureToComplete(ProcedureExecutor<MasterProcedureEnv> procExec, long procId) throws IOException
IOExceptionpublic static <T> T waitFor(MasterProcedureEnv env, String purpose, ProcedureSyncWait.Predicate<T> predicate) throws IOException
IOExceptionpublic static <T> T waitFor(MasterProcedureEnv env, long waitTime, long waitingTimeForEvents, String purpose, ProcedureSyncWait.Predicate<T> predicate) throws IOException
IOExceptionprotected static void waitMetaRegions(MasterProcedureEnv env) throws IOException
IOExceptionprotected static void waitRegionServers(MasterProcedureEnv env) throws IOException
IOExceptionprotected static List<HRegionInfo> getRegionsFromMeta(MasterProcedureEnv env, TableName tableName) throws IOException
IOExceptionprotected static void waitRegionInTransition(MasterProcedureEnv env, List<HRegionInfo> regions) throws IOException, CoordinatedStateException
IOExceptionCoordinatedStateExceptionprotected static MasterQuotaManager getMasterQuotaManager(MasterProcedureEnv env) throws IOException
IOExceptionCopyright © 2007–2019 The Apache Software Foundation. All rights reserved.