Class BatchExecutionOptions


  • @PublicEvolving
    public class BatchExecutionOptions
    extends Object
    Configuration options for the batch job execution.
    • Field Detail

      • ADAPTIVE_AUTO_PARALLELISM_ENABLED

        public static final ConfigOption<Boolean> ADAPTIVE_AUTO_PARALLELISM_ENABLED
      • ADAPTIVE_AUTO_PARALLELISM_MIN_PARALLELISM

        public static final ConfigOption<Integer> ADAPTIVE_AUTO_PARALLELISM_MIN_PARALLELISM
      • ADAPTIVE_AUTO_PARALLELISM_MAX_PARALLELISM

        public static final ConfigOption<Integer> ADAPTIVE_AUTO_PARALLELISM_MAX_PARALLELISM
      • ADAPTIVE_AUTO_PARALLELISM_AVG_DATA_VOLUME_PER_TASK

        public static final ConfigOption<MemorySize> ADAPTIVE_AUTO_PARALLELISM_AVG_DATA_VOLUME_PER_TASK
      • ADAPTIVE_AUTO_PARALLELISM_DEFAULT_SOURCE_PARALLELISM

        public static final ConfigOption<Integer> ADAPTIVE_AUTO_PARALLELISM_DEFAULT_SOURCE_PARALLELISM
      • SPECULATIVE_MAX_CONCURRENT_EXECUTIONS

        public static final ConfigOption<Integer> SPECULATIVE_MAX_CONCURRENT_EXECUTIONS
      • JOB_RECOVERY_PREVIOUS_WORKER_RECOVERY_TIMEOUT

        public static final ConfigOption<Duration> JOB_RECOVERY_PREVIOUS_WORKER_RECOVERY_TIMEOUT
      • JOB_RECOVERY_SNAPSHOT_MIN_PAUSE

        public static final ConfigOption<Duration> JOB_RECOVERY_SNAPSHOT_MIN_PAUSE