Class FlinkOperatorConfiguration.FlinkOperatorRetryConfiguration

  • All Implemented Interfaces:
    io.javaoperatorsdk.operator.api.config.RetryConfiguration
    Enclosing class:
    FlinkOperatorConfiguration

    protected static class FlinkOperatorConfiguration.FlinkOperatorRetryConfiguration
    extends java.lang.Object
    implements io.javaoperatorsdk.operator.api.config.RetryConfiguration
    Enables configurable retry mechanism for reconciliation errors.
    • Field Summary

      • Fields inherited from interface io.javaoperatorsdk.operator.api.config.RetryConfiguration

        DEFAULT, DEFAULT_INITIAL_INTERVAL, DEFAULT_MAX_ATTEMPTS, DEFAULT_MULTIPLIER
    • Constructor Summary

      Constructors 
      Constructor Description
      FlinkOperatorRetryConfiguration​(org.apache.flink.configuration.Configuration operatorConfig)  
    • Constructor Detail

      • FlinkOperatorRetryConfiguration

        public FlinkOperatorRetryConfiguration​(org.apache.flink.configuration.Configuration operatorConfig)
    • Method Detail

      • getMaxAttempts

        public int getMaxAttempts()
        Specified by:
        getMaxAttempts in interface io.javaoperatorsdk.operator.api.config.RetryConfiguration
      • getInitialInterval

        public long getInitialInterval()
        Specified by:
        getInitialInterval in interface io.javaoperatorsdk.operator.api.config.RetryConfiguration
      • getIntervalMultiplier

        public double getIntervalMultiplier()
        Specified by:
        getIntervalMultiplier in interface io.javaoperatorsdk.operator.api.config.RetryConfiguration
      • getMaxInterval

        public long getMaxInterval()
        Specified by:
        getMaxInterval in interface io.javaoperatorsdk.operator.api.config.RetryConfiguration