Package org.apache.flink.changelog.fs
Class RetryPolicy.FixedRetryPolicy
- java.lang.Object
-
- org.apache.flink.changelog.fs.RetryPolicy.FixedRetryPolicy
-
- All Implemented Interfaces:
RetryPolicy
- Enclosing interface:
- RetryPolicy
public static class RetryPolicy.FixedRetryPolicy extends Object implements RetryPolicy
RetryPolicywith fixed timeout, delay and max attempts.
-
-
Nested Class Summary
-
Nested classes/interfaces inherited from interface org.apache.flink.changelog.fs.RetryPolicy
RetryPolicy.FixedRetryPolicy
-
-
Field Summary
-
Fields inherited from interface org.apache.flink.changelog.fs.RetryPolicy
NONE
-
-
Method Summary
All Methods Instance Methods Concrete Methods Modifier and Type Method Description longretryAfter(int attempt, Exception exception)longtimeoutFor(int attempt)StringtoString()
-
-
-
Method Detail
-
timeoutFor
public long timeoutFor(int attempt)
- Specified by:
timeoutForin interfaceRetryPolicy- Returns:
- timeout in millis. Zero or negative means no timeout.
-
retryAfter
public long retryAfter(int attempt, Exception exception)- Specified by:
retryAfterin interfaceRetryPolicy- Returns:
- delay in millis before the next attempt. Negative means no retry, zero means no delay.
-
-