public static enum ExecEdge.DamBehavior extends Enum<ExecEdge.DamBehavior>
TODO: We would like to remove Exchange exec nodes in the future. The dam behavior will
then not only be affected by the implementation of the operator but will also be affected by
ShuffleMode
.
Enum Constant and Description |
---|
BLOCKING
Constant indicating that all output records from the source will not trigger output
records of the target.
|
END_INPUT
Constant indicating that only the last output record from the source will immediately
trigger one or more output records of the target.
|
PIPELINED
Constant indicating that some or all output records from the source will immediately
trigger one or more output records of the target.
|
Modifier and Type | Method and Description |
---|---|
boolean |
stricterOrEqual(ExecEdge.DamBehavior o) |
static ExecEdge.DamBehavior |
valueOf(String name)
Returns the enum constant of this type with the specified name.
|
static ExecEdge.DamBehavior[] |
values()
Returns an array containing the constants of this enum type, in
the order they are declared.
|
public static final ExecEdge.DamBehavior PIPELINED
public static final ExecEdge.DamBehavior END_INPUT
public static final ExecEdge.DamBehavior BLOCKING
public static ExecEdge.DamBehavior[] values()
for (ExecEdge.DamBehavior c : ExecEdge.DamBehavior.values()) System.out.println(c);
public static ExecEdge.DamBehavior 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 nullpublic boolean stricterOrEqual(ExecEdge.DamBehavior o)
Copyright © 2014–2021 The Apache Software Foundation. All rights reserved.