public static enum StreamConfig.InputRequirement extends Enum<StreamConfig.InputRequirement>
SORTEDinputs, records are sorted/grouped by key and all records of a given key are passed to the operator consecutively before moving on to the next group.
|Enum Constant and Description|
Records from all sorted inputs are grouped (sorted) by key and are then fed to the operator one group at a time.
|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 StreamConfig.InputRequirement SORTED
public static final StreamConfig.InputRequirement PASS_THROUGH
PASS_THROUGHinputs are passed to the operator before passing any records from
SORTEDinputs. There are no guarantees on ordering between and within the different
public static StreamConfig.InputRequirement values()
for (StreamConfig.InputRequirement c : StreamConfig.InputRequirement.values()) System.out.println(c);
public static StreamConfig.InputRequirement valueOf(String name)
name- the name of the enum constant to be returned.
IllegalArgumentException- if this enum type has no constant with the specified name
NullPointerException- if the argument is null
Copyright © 2014–2023 The Apache Software Foundation. All rights reserved.