in common/src/main/java/org/apache/cassandra/diff/RetryStrategyProvider.java [50:66]
public static RetryStrategyProvider create(JobConfiguration.RetryOptions retryOptions) {
try {
String implClass = retryOptions.get(IMPLEMENTATION_KEY);
return (RetryStrategyProvider) Class.forName(implClass)
.getConstructor(JobConfiguration.RetryOptions.class)
.newInstance(retryOptions);
} catch (Exception ex) {
logger.warn("Unable to create RetryStrategyProvider. Use the default provider, NoRetry.", ex);
return new RetryStrategyProvider(retryOptions) {
@Override
public RetryStrategy get() {
return RetryStrategy.NoRetry.INSTANCE;
}
};
}
}