Module datarush.commons
Package com.pervasive.datarush.cal

Class ExecutionOptions

  • public final class ExecutionOptions
extends Object
    Miscellaneous execution options.

    • Field Detail

      • WORKER

        public static final ExecutionOptions WORKER
        Default execution options: parallel/distributed, retry disabled

      • MASTER

        public static final ExecutionOptions MASTER
        Execution options to run in the master. Non parallel and no retries. Runs locally, within the same JVM that submitted.

    • Method Detail

      • maxRetries

        public int maxRetries()
        Returns the maximum number of times a part of a job can fail before we give up.
        Returns:
        the max retries

      • maxRetries

        public ExecutionOptions maxRetries​(int maxRetries)
        Creates a new ExecutionOptions, with the maximum retries set to the specified value
        Parameters:
        maxRetries - the max retries
        Returns:
        a new ExecutionOptions

      • maxParallelism

        public int maxParallelism()
        Returns the max parallelism.
        Returns:
        the max parallelism

      • maxParallelism

        public ExecutionOptions maxParallelism​(int maxParallelism)
        Creates a new ExecutionOptions, with the maximum parallelism set to the specified value
        Parameters:
        maxRetries - the max retries
        Returns:
        a new ExecutionOptions

      • worker

        public boolean worker()
        Returns whether this is for a worker.
        Returns:
        whether this is for a worker

      • isFaultTolerant

        public boolean isFaultTolerant()
        Returns true if the number of retries is greater than zero.
        Returns:
        whether we are fault tolerant