Class StartupOptions
- java.lang.Object
-
- org.apache.flink.cdc.connectors.tidb.table.StartupOptions
-
public final class StartupOptions extends Object
TiDB CDC Source startup options.
-
-
Field Summary
Fields Modifier and Type Field Description StartupModestartupMode
-
Method Summary
All Methods Static Methods Instance Methods Concrete Methods Modifier and Type Method Description booleanequals(Object o)inthashCode()static StartupOptionsinitial()Performs an initial snapshot on the monitored database tables upon first startup, and continue to read the latest CDC events.static StartupOptionslatest()Never to perform snapshot on the monitored database tables upon first startup, just read from the latest CDC events which means only have the changes since the connector was started.
-
-
-
Field Detail
-
startupMode
public final StartupMode startupMode
-
-
Method Detail
-
initial
public static StartupOptions initial()
Performs an initial snapshot on the monitored database tables upon first startup, and continue to read the latest CDC events.
-
latest
public static StartupOptions latest()
Never to perform snapshot on the monitored database tables upon first startup, just read from the latest CDC events which means only have the changes since the connector was started.
-
-