public enum MiniBatchMode extends Enum<MiniBatchMode>
Enum Constant and Description |
---|
None
Default value, meaning no mini-batch interval is required.
|
ProcTime
An operator in
#ProcTime mode requires watermarks emitted in proctime interval, i.e.,
unbounded group agg with mini-batch enabled. |
RowTime
An operator in
#RowTime mode requires watermarks extracted from elements, and emitted
in rowtime interval, e.g., window, window join... |
Modifier and Type | Method and Description |
---|---|
static MiniBatchMode |
valueOf(String name)
Returns the enum constant of this type with the specified name.
|
static MiniBatchMode[] |
values()
Returns an array containing the constants of this enum type, in
the order they are declared.
|
public static final MiniBatchMode ProcTime
#ProcTime
mode requires watermarks emitted in proctime interval, i.e.,
unbounded group agg with mini-batch enabled.public static final MiniBatchMode RowTime
#RowTime
mode requires watermarks extracted from elements, and emitted
in rowtime interval, e.g., window, window join...public static final MiniBatchMode None
public static MiniBatchMode[] values()
for (MiniBatchMode c : MiniBatchMode.values()) System.out.println(c);
public static MiniBatchMode 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.