| Modifier and Type | Method and Description |
|---|---|
MySqlSource.Builder<T> |
MySqlSource.Builder.startupOptions(StartupOptions startupOptions)
Deprecated.
Specifies the startup options.
|
| Modifier and Type | Method and Description |
|---|---|
MySqlSourceBuilder<T> |
MySqlSourceBuilder.startupOptions(StartupOptions startupOptions)
Specifies the startup options.
|
| Modifier and Type | Method and Description |
|---|---|
StartupOptions |
MySqlSourceConfig.getStartupOptions() |
| Modifier and Type | Method and Description |
|---|---|
MySqlSourceConfigFactory |
MySqlSourceConfigFactory.startupOptions(StartupOptions startupOptions)
Specifies the startup options.
|
| Modifier and Type | Method and 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.specificOffset(String specificOffsetFile,
int specificOffsetPos)
Never to perform snapshot on the monitored database tables upon first startup, and directly
read binlog from the specified offset.
|
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.
|
| Constructor and 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,
Properties jdbcProperties,
java.time.Duration heartbeatInterval) |
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,
java.time.Duration heartbeatInterval) |
Copyright © 2022 The Apache Software Foundation. All rights reserved.