FixedRetryStrategy (Flink : Core 2.2.0 API)

java.lang.Object
- org.apache.flink.util.concurrent.FixedRetryStrategy

All Implemented Interfaces:

RetryStrategy
```
public class FixedRetryStrategy
extends Object
implements RetryStrategy
```
An implementation of RetryStrategy that retries at a fixed delay.

- Constructor Summary
  
  Constructors
  Constructor Description
  
  FixedRetryStrategy(int remainingRetries, Duration retryDelay)
- Method Summary
  
  All Methods Instance Methods Concrete Methods
  Modifier and Type Method Description
  
  RetryStrategy getNextRetryStrategy()
  
  int getNumRemainingRetries()
  
  Duration getRetryDelay()
  - Methods inherited from class java.lang.Object
    clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

- Constructor Detail
  - FixedRetryStrategy
```
public FixedRetryStrategy(int remainingRetries,
                          Duration retryDelay)
```
    Parameters:
    
    remainingRetries - number of times to retry
    
    retryDelay - delay between retries
- Method Detail
  - getNumRemainingRetries
```
public int getNumRemainingRetries()
```
    Specified by:
    
    getNumRemainingRetries in interface RetryStrategy
    
    Returns:
    
    the number of remaining retries
  - getRetryDelay
```
public Duration getRetryDelay()
```
    Specified by:
    
    getRetryDelay in interface RetryStrategy
    
    Returns:
    
    the current delay if we need to retry
  - getNextRetryStrategy
```
public RetryStrategy getNextRetryStrategy()
```
    Specified by:
    
    getNextRetryStrategy in interface RetryStrategy
    
    Returns:
    
    the next retry strategy to current delay if we need to retry