Uses of Class
org.apache.flink.cdc.connectors.tidb.table.StartupOptions
-
Packages that use StartupOptions Package Description org.apache.flink.cdc.connectors.tidb org.apache.flink.cdc.connectors.tidb.table -
-
Uses of StartupOptions in org.apache.flink.cdc.connectors.tidb
Methods in org.apache.flink.cdc.connectors.tidb with parameters of type StartupOptions Modifier and Type Method Description TiDBSource.Builder<T>TiDBSource.Builder. startupOptions(StartupOptions startupOptions)Specifies the startup options. -
Uses of StartupOptions in org.apache.flink.cdc.connectors.tidb.table
Methods in org.apache.flink.cdc.connectors.tidb.table that return StartupOptions Modifier and Type Method Description static StartupOptionsStartupOptions. initial()Performs an initial snapshot on the monitored database tables upon first startup, and continue to read the latest CDC events.static StartupOptionsStartupOptions. 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.Constructors in org.apache.flink.cdc.connectors.tidb.table with parameters of type StartupOptions Constructor Description TiDBTableSource(org.apache.flink.table.catalog.ResolvedSchema physicalSchema, String database, String tableName, String pdAddresses, String hostMapping, StartupOptions startupOptions, Map<String,String> options)
-