Class StartupOptions
- java.lang.Object
-
- org.apache.flink.cdc.connectors.db2.table.StartupOptions
-
public final class StartupOptions extends Object
Debezium 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 change events from the database's redo logs.static StartupOptionslatest()Never to perform snapshot on the monitored database tables upon first startup, just read from the end of the change 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 change events from the database's redo logs.
-
latest
public static StartupOptions latest()
Never to perform snapshot on the monitored database tables upon first startup, just read from the end of the change events which means only have the changes since the connector was started.
-
-