@Public public enum ExecutionMode extends Enum<ExecutionMode>
Enum Constant and Description |
---|
BATCH
This mode executes all shuffles and broadcasts in a batch fashion, while pipelining data
between operations that exchange data only locally between one producer and one consumer.
|
BATCH_FORCED
This mode executes the program in a strict batch way, including all points where data is
forwarded locally from one producer to one consumer.
|
PIPELINED
Executes the program in a pipelined fashion (including shuffles and broadcasts), except for
data exchanges that are susceptible to deadlocks when pipelining.
|
PIPELINED_FORCED
Executes the program in a pipelined fashion (including shuffles and broadcasts),
including data exchanges that are susceptible to deadlocks when executed via
pipelining.
|
Modifier and Type | Method and Description |
---|---|
static ExecutionMode |
valueOf(String name)
Returns the enum constant of this type with the specified name.
|
static ExecutionMode[] |
values()
Returns an array containing the constants of this enum type, in
the order they are declared.
|
public static final ExecutionMode PIPELINED
An example of situations that are susceptible to deadlocks (when executed in a pipelined manner) are data flows that branch (one data set consumed by multiple operations) and re-join later:
DataSet data = ...;
DataSet mapped1 = data.map(new MyMapper());
DataSet mapped2 = data.map(new AnotherMapper());
mapped1.join(mapped2).where(...).equalTo(...);
public static final ExecutionMode PIPELINED_FORCED
Usually, PIPELINED
is the preferable option, which pipelines most data exchanges
and only uses batch data exchanges in situations that are susceptible to deadlocks.
This option should only be used with care and only in situations where the programmer is sure that the program is safe for full pipelining and that Flink was too conservative when choosing the batch exchange at a certain point.
public static final ExecutionMode BATCH
public static final ExecutionMode BATCH_FORCED
BATCH
mode. It does guarantee that no successive operations are
ever executed concurrently.public static ExecutionMode[] values()
for (ExecutionMode c : ExecutionMode.values()) System.out.println(c);
public static ExecutionMode valueOf(String name)
name
- the name of the enum constant to be returned.IllegalArgumentException
- if this enum type has no constant with the specified nameNullPointerException
- if the argument is nullCopyright © 2014–2024 The Apache Software Foundation. All rights reserved.