@InterfaceAudience.Private @InterfaceStability.Evolving public final class ProcedureSyncWait extends Object
Modifier and Type | Class and Description |
---|---|
static interface |
ProcedureSyncWait.Predicate<T> |
public static byte[] submitAndWaitProcedure(ProcedureExecutor<MasterProcedureEnv> procExec, Procedure proc) throws IOException
IOException
public static byte[] waitForProcedureToComplete(ProcedureExecutor<MasterProcedureEnv> procExec, long procId) throws IOException
IOException
public static <T> T waitFor(MasterProcedureEnv env, String purpose, ProcedureSyncWait.Predicate<T> predicate) throws IOException
IOException
public static <T> T waitFor(MasterProcedureEnv env, long waitTime, long waitingTimeForEvents, String purpose, ProcedureSyncWait.Predicate<T> predicate) throws IOException
IOException
protected static void waitMetaRegions(MasterProcedureEnv env) throws IOException
IOException
protected static void waitRegionServers(MasterProcedureEnv env) throws IOException
IOException
protected static List<HRegionInfo> getRegionsFromMeta(MasterProcedureEnv env, TableName tableName) throws IOException
IOException
protected static List<HRegionInfo> getRegionsFromMeta(MasterProcedureEnv env, TableName tableName, boolean excludeOfflinedSplitParents, boolean excludeReplicaRegions) throws IOException
IOException
protected static void waitRegionInTransition(MasterProcedureEnv env, List<HRegionInfo> regions) throws IOException, CoordinatedStateException
IOException
CoordinatedStateException
protected static MasterQuotaManager getMasterQuotaManager(MasterProcedureEnv env) throws IOException
IOException
Copyright © 2007–2019 The Apache Software Foundation. All rights reserved.