public final class ProcedureSyncWait
extends java.lang.Object
Modifier and Type | Class and Description |
---|---|
static interface |
ProcedureSyncWait.Predicate<T> |
Modifier and Type | Method and Description |
---|---|
protected static MasterQuotaManager |
getMasterQuotaManager(MasterProcedureEnv env) |
static byte[] |
submitAndWaitProcedure(<any> procExec,
<any> proc) |
static java.util.concurrent.Future<byte[]> |
submitProcedure(<any> procExec,
<any> proc) |
static <T> T |
waitFor(MasterProcedureEnv env,
long waitTime,
long waitingTimeForEvents,
java.lang.String purpose,
ProcedureSyncWait.Predicate<T> predicate) |
static <T> T |
waitFor(MasterProcedureEnv env,
java.lang.String purpose,
ProcedureSyncWait.Predicate<T> predicate) |
static byte[] |
waitForProcedureToComplete(<any> procExec,
<any> proc,
long timeout) |
static byte[] |
waitForProcedureToCompleteIOE(<any> procExec,
<any> proc,
long timeout) |
protected static void |
waitMetaRegions(MasterProcedureEnv env) |
protected static void |
waitRegionInTransition(MasterProcedureEnv env,
java.util.List<RegionInfo> regions) |
public static java.util.concurrent.Future<byte[]> submitProcedure(<any> procExec, <any> proc)
public static byte[] submitAndWaitProcedure(<any> procExec, <any> proc) throws java.io.IOException
java.io.IOException
public static byte[] waitForProcedureToCompleteIOE(<any> procExec, <any> proc, long timeout) throws java.io.IOException
java.io.IOException
public static byte[] waitForProcedureToComplete(<any> procExec, <any> proc, long timeout) throws java.io.IOException
java.io.IOException
public static <T> T waitFor(MasterProcedureEnv env, java.lang.String purpose, ProcedureSyncWait.Predicate<T> predicate) throws java.io.IOException
java.io.IOException
public static <T> T waitFor(MasterProcedureEnv env, long waitTime, long waitingTimeForEvents, java.lang.String purpose, ProcedureSyncWait.Predicate<T> predicate) throws java.io.IOException
java.io.IOException
protected static void waitMetaRegions(MasterProcedureEnv env) throws java.io.IOException
java.io.IOException
protected static void waitRegionInTransition(MasterProcedureEnv env, java.util.List<RegionInfo> regions) throws java.io.IOException
java.io.IOException
protected static MasterQuotaManager getMasterQuotaManager(MasterProcedureEnv env) throws java.io.IOException
java.io.IOException