Package org.apache.flink.table.connector
Class ChangelogMode
- java.lang.Object
-
- org.apache.flink.table.connector.ChangelogMode
-
@PublicEvolving public final class ChangelogMode extends Object
The set of changes contained in a changelog.- See Also:
RowKind
-
-
Nested Class Summary
Nested Classes Modifier and Type Class Description static class
ChangelogMode.Builder
Builder for configuring and creating instances ofChangelogMode
.
-
Method Summary
All Methods Static Methods Instance Methods Concrete Methods Modifier and Type Method Description static ChangelogMode
all()
Shortcut for a changelog that can contain allRowKind
s.boolean
contains(RowKind kind)
boolean
containsOnly(RowKind kind)
boolean
equals(Object o)
Set<RowKind>
getContainedKinds()
int
hashCode()
static ChangelogMode
insertOnly()
Shortcut for a simpleRowKind.INSERT
-only changelog.static ChangelogMode.Builder
newBuilder()
Builder for configuring and creating instances ofChangelogMode
.String
toString()
static ChangelogMode
upsert()
Shortcut for an upsert changelog that describes idempotent updates on a key and thus does not containRowKind.UPDATE_BEFORE
rows.
-
-
-
Method Detail
-
insertOnly
public static ChangelogMode insertOnly()
Shortcut for a simpleRowKind.INSERT
-only changelog.
-
upsert
public static ChangelogMode upsert()
Shortcut for an upsert changelog that describes idempotent updates on a key and thus does not containRowKind.UPDATE_BEFORE
rows.
-
all
public static ChangelogMode all()
Shortcut for a changelog that can contain allRowKind
s.
-
newBuilder
public static ChangelogMode.Builder newBuilder()
Builder for configuring and creating instances ofChangelogMode
.
-
contains
public boolean contains(RowKind kind)
-
containsOnly
public boolean containsOnly(RowKind kind)
-
-