public class RetryHelper extends Object
Constructor and Description |
---|
RetryHelper() |
Modifier and Type | Method and Description |
---|---|
static void |
addAffectedCluster(Cluster cluster) |
static void |
clearAffectedClusters() |
static <T> T |
executeWithRetry(Callable<T> command) |
static Set<Cluster> |
getAffectedClusters() |
static int |
getOperationsRetryAttempts() |
static void |
init(Clusters clusters,
int operationsRetryAttempts) |
static void |
invalidateAffectedClusters() |
static boolean |
isDatabaseException(Throwable ex) |
public static void init(Clusters clusters, int operationsRetryAttempts)
public static void addAffectedCluster(Cluster cluster)
public static void clearAffectedClusters()
public static int getOperationsRetryAttempts()
public static boolean isDatabaseException(Throwable ex)
public static void invalidateAffectedClusters()
public static <T> T executeWithRetry(Callable<T> command) throws org.apache.ambari.server.AmbariException
org.apache.ambari.server.AmbariException
Copyright © 2022 Apache Software Foundation. All rights reserved.