@PublicEvolving public enum ChainingStrategy extends Enum<ChainingStrategy>
The default value used by the StreamOperator is
HEAD, which means that the operator
is not chained to its predecessor. Most operators override this with
they will be chained to predecessors whenever possible.
|Enum Constant and Description|
Operators will be eagerly chained whenever possible.
The operator will not be chained to the predecessor, but successors may chain to this operator.
The operator will not be chained to the preceding or succeeding operators.
|Modifier and Type||Method and Description|
Returns the enum constant of this type with the specified name.
Returns an array containing the constants of this enum type, in the order they are declared.
clone, compareTo, equals, finalize, getDeclaringClass, hashCode, name, ordinal, toString, valueOf
public static final ChainingStrategy ALWAYS
To optimize performance, it is generally a good practice to allow maximal chaining and increase operator parallelism.
public static final ChainingStrategy NEVER
public static final ChainingStrategy HEAD
public static ChainingStrategy values()
for (ChainingStrategy c : ChainingStrategy.values()) System.out.println(c);
public static ChainingStrategy valueOf(String name)
Copyright © 2014–2021 The Apache Software Foundation. All rights reserved.