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 and Description
static class	ChangelogMode.Builder Builder for configuring and creating instances of ChangelogMode.

Method Summary

Modifier and Type	Method and Description
static ChangelogMode	all() Shortcut for a changelog that can contain all RowKinds.
boolean	contains(RowKind kind)
boolean	containsOnly(RowKind kind)
boolean	equals(Object o)
Set<RowKind>	getContainedKinds()
int	hashCode()
static ChangelogMode	insertOnly() Shortcut for a simple RowKind.INSERT-only changelog.
static ChangelogMode.Builder	newBuilder() Builder for configuring and creating instances of ChangelogMode.
String	toString()
static ChangelogMode	upsert() Shortcut for an upsert changelog that describes idempotent updates on a key and thus does not contain RowKind.UPDATE_BEFORE rows.

Methods inherited from class java.lang.Object

clone, finalize, getClass, notify, notifyAll, wait, wait, wait

Method Detail

insertOnly

public static ChangelogMode insertOnly()

Shortcut for a simple RowKind.INSERT-only changelog.

upsert

public static ChangelogMode upsert()

Shortcut for an upsert changelog that describes idempotent updates on a key and thus does not contain RowKind.UPDATE_BEFORE rows.

all

public static ChangelogMode all()

Shortcut for a changelog that can contain all RowKinds.

newBuilder

public static ChangelogMode.Builder newBuilder()

Builder for configuring and creating instances of ChangelogMode.

getContainedKinds

public Set<RowKind> getContainedKinds()

contains

public boolean contains(RowKind kind)

containsOnly

public boolean containsOnly(RowKind kind)

equals

public boolean equals(Object o)

Overrides:

equals in class Object

hashCode

public int hashCode()

Overrides:

hashCode in class Object

toString

public String toString()

Overrides:

toString in class Object