public final class ExecutionOptions extends Object
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
|
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.
|
public static final ExecutionOptions WORKER
public static final ExecutionOptions MASTER
public int maxRetries()
public ExecutionOptions maxRetries(int maxRetries)
maxRetries
- the max retriespublic int maxParallelism()
public ExecutionOptions maxParallelism(int maxParallelism)
maxRetries
- the max retriespublic boolean worker()
public boolean isFaultTolerant()
Copyright © 2016 Actian Corporation. All rights reserved.