com.pervasive.datarush.cal

Class ExecutionOptions

java.lang.Object

com.pervasive.datarush.cal.ExecutionOptions

public final class ExecutionOptions
extends Object

Miscellaneous execution options.

Field Summary

Fields

Modifier and Type	Field and Description
static ExecutionOptions	MASTER Execution options to run in the master.
static ExecutionOptions	WORKER Default execution options: parallel/distributed, retry disabled

Method Summary

Methods

Modifier and Type	Method and Description
boolean	isFaultTolerant() Returns true if the number of retries is greater than zero.
int	maxParallelism() Returns the max parallelism.
ExecutionOptions	maxParallelism(int maxParallelism) Creates a new ExecutionOptions, with the maximum parallelism set to the specified value
int	maxRetries() Returns the maximum number of times a part of a job can fail before we give up.
ExecutionOptions	maxRetries(int maxRetries) Creates a new ExecutionOptions, with the maximum retries set to the specified value
boolean	worker() Returns whether this is for a worker.

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

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