Uses of Class
org.apache.flink.cdc.connectors.mysql.table.StartupOptions

Packages that use StartupOptions

Package	Description
org.apache.flink.cdc.connectors.mysql
org.apache.flink.cdc.connectors.mysql.source
org.apache.flink.cdc.connectors.mysql.source.config
org.apache.flink.cdc.connectors.mysql.table

Uses of StartupOptions in org.apache.flink.cdc.connectors.mysql

Methods in org.apache.flink.cdc.connectors.mysql with parameters of type StartupOptions

Modifier and Type	Method	Description
MySqlSource.Builder<T>	MySqlSource.Builder.startupOptions(StartupOptions startupOptions)	Deprecated. Specifies the startup options.

Uses of StartupOptions in org.apache.flink.cdc.connectors.mysql.source

Methods in org.apache.flink.cdc.connectors.mysql.source with parameters of type StartupOptions

Modifier and Type	Method	Description
MySqlSourceBuilder<T>	MySqlSourceBuilder.startupOptions(StartupOptions startupOptions)	Specifies the startup options.

Uses of StartupOptions in org.apache.flink.cdc.connectors.mysql.source.config

Methods in org.apache.flink.cdc.connectors.mysql.source.config that return StartupOptions

Modifier and Type	Method	Description
StartupOptions	MySqlSourceConfig.getStartupOptions()

Methods in org.apache.flink.cdc.connectors.mysql.source.config with parameters of type StartupOptions

Modifier and Type	Method	Description
MySqlSourceConfigFactory	MySqlSourceConfigFactory.startupOptions(StartupOptions startupOptions)	Specifies the startup options.

Uses of StartupOptions in org.apache.flink.cdc.connectors.mysql.table

Methods in org.apache.flink.cdc.connectors.mysql.table that return StartupOptions

Modifier and Type	Method	Description
static StartupOptions	StartupOptions.earliest()	Never to perform snapshot on the monitored database tables upon first startup, just read from the beginning of the binlog.
static StartupOptions	StartupOptions.initial()	Performs an initial snapshot on the monitored database tables upon first startup, and continue to read the latest binlog.
static StartupOptions	StartupOptions.latest()	Never to perform snapshot on the monitored database tables upon first startup, just read from the end of the binlog which means only have the changes since the connector was started.
static StartupOptions	StartupOptions.snapshot()	Performs an initial snapshot on the monitored database tables upon first startup, and not read the binlog anymore .
static StartupOptions	StartupOptions.specificOffset(String gtidSet)
static StartupOptions	StartupOptions.specificOffset(String specificOffsetFile, long specificOffsetPos)	Never to perform snapshot on the monitored database tables upon first startup, and directly read binlog from the specified offset.
static StartupOptions	StartupOptions.specificOffset(BinlogOffset binlogOffset)
static StartupOptions	StartupOptions.timestamp(long startupTimestampMillis)	Never to perform snapshot on the monitored database tables upon first startup, and directly read binlog from the specified timestamp.

Constructors in org.apache.flink.cdc.connectors.mysql.table with parameters of type StartupOptions

Constructor

Description

MySqlTableSource(org.apache.flink.table.catalog.ResolvedSchema physicalSchema, int port, String hostname, String database, String tableName, String username, String password, java.time.ZoneId serverTimeZone, Properties dbzProperties, String serverId, boolean enableParallelRead, int splitSize, int splitMetaGroupSize, int fetchSize, java.time.Duration connectTimeout, int connectMaxRetries, int connectionPoolSize, double distributionFactorUpper, double distributionFactorLower, StartupOptions startupOptions, boolean scanNewlyAddedTableEnabled, boolean releaseSnapshotMetadataEnabled, boolean closeIdleReaders, Properties jdbcProperties, java.time.Duration heartbeatInterval, String chunkKeyColumn, boolean skipSnapshotBackFill, boolean parseOnlineSchemaChanges, boolean useLegacyJsonFormat, boolean assignUnboundedChunkFirst, boolean appendOnly)