public static RetryStrategyProvider create()

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;
                }
            };
        }
    }