MySqlSourceBuilder<T> |
MySqlSourceBuilder.assignUnboundedChunkFirst(boolean assignUnboundedChunkFirst) |
Whether the MySqlSource should assign the unbounded chunks first or not during
snapshot reading phase. |
static <T> MySqlSourceBuilder<T> |
MySqlSource.builder() |
Get a MySqlParallelSourceBuilder to build a MySqlSource. |
MySqlSourceBuilder<T> |
MySqlSourceBuilder.chunkKeyColumn(org.apache.flink.table.catalog.ObjectPath objectPath,
String chunkKeyColumn) |
The chunk key of table snapshot, captured tables are split into multiple chunks by the chunk
key column when read the snapshot of table.
|
MySqlSourceBuilder<T> |
MySqlSourceBuilder.closeIdleReaders(boolean closeIdleReaders) |
Whether to close idle readers at the end of the snapshot phase.
|
MySqlSourceBuilder<T> |
MySqlSourceBuilder.connectionPoolSize(int connectionPoolSize) |
The connection pool size.
|
MySqlSourceBuilder<T> |
MySqlSourceBuilder.connectMaxRetries(int connectMaxRetries) |
The max retry times to get connection.
|
MySqlSourceBuilder<T> |
MySqlSourceBuilder.connectTimeout(java.time.Duration connectTimeout) |
The maximum time that the connector should wait after trying to connect to the MySQL database
server before timing out.
|
MySqlSourceBuilder<T> |
MySqlSourceBuilder.databaseList(String... databaseList) |
An required list of regular expressions that match database names to be monitored; any
database name not included in the whitelist will be excluded from monitoring.
|
MySqlSourceBuilder<T> |
MySqlSourceBuilder.debeziumProperties(Properties properties) |
The Debezium MySQL connector properties.
|
MySqlSourceBuilder<T> |
MySqlSourceBuilder.deserializer(DebeziumDeserializationSchema<T> deserializer) |
The deserializer used to convert from consumed SourceRecord.
|
MySqlSourceBuilder<T> |
MySqlSourceBuilder.distributionFactorLower(double distributionFactorLower) |
The lower bound of split key evenly distribution factor, the factor is used to determine
whether the table is evenly distribution or not.
|
MySqlSourceBuilder<T> |
MySqlSourceBuilder.distributionFactorUpper(double distributionFactorUpper) |
The upper bound of split key evenly distribution factor, the factor is used to determine
whether the table is evenly distribution or not.
|
MySqlSourceBuilder<T> |
MySqlSourceBuilder.fetchSize(int fetchSize) |
The maximum fetch size for per poll when read table snapshot.
|
MySqlSourceBuilder<T> |
MySqlSourceBuilder.heartbeatInterval(java.time.Duration heartbeatInterval) |
The interval of heartbeat event.
|
MySqlSourceBuilder<T> |
MySqlSourceBuilder.heartbeatInterval(java.time.Duration heartbeatInterval,
boolean includeHeartbeatEvents) |
The interval of heartbeat event and whether to emit heartbeat events.
|
MySqlSourceBuilder<T> |
MySqlSourceBuilder.hostname(String hostname) |
|
MySqlSourceBuilder<T> |
MySqlSourceBuilder.includeSchemaChanges(boolean includeSchemaChanges) |
Whether the MySqlSource should output the schema changes or not. |
MySqlSourceBuilder<T> |
MySqlSourceBuilder.includeTransactionMetadataEvents(boolean includeTransactionMetadataEvents) |
Whether the MySqlSource should output the transaction metadata events or not. |
MySqlSourceBuilder<T> |
MySqlSourceBuilder.jdbcProperties(Properties jdbcProperties) |
Custom properties that will overwrite the default JDBC connection URL.
|
MySqlSourceBuilder<T> |
MySqlSourceBuilder.parseOnLineSchemaChanges(boolean parseOnLineSchemaChanges) |
Whether to parse gh-ost utility generated schema change events.
|
MySqlSourceBuilder<T> |
MySqlSourceBuilder.password(String password) |
Password to use when connecting to the MySQL database server.
|
MySqlSourceBuilder<T> |
MySqlSourceBuilder.port(int port) |
Integer port number of the MySQL database server.
|
MySqlSourceBuilder<T> |
MySqlSourceBuilder.releaseSnapshotMetadataEnabled(boolean releaseSnapshotMetadataEnabled) |
Whether the source coordinator should release the snapshot split metadata after entering the
binlog phase to reduce JobManager memory.
|
MySqlSourceBuilder<T> |
MySqlSourceBuilder.scanNewlyAddedTableEnabled(boolean scanNewlyAddedTableEnabled) |
Whether the MySqlSource should scan the newly added tables or not. |
MySqlSourceBuilder<T> |
MySqlSourceBuilder.serverId(String serverId) |
A numeric ID or a numeric ID range of this database client, The numeric ID syntax is like
'5400', the numeric ID range syntax is like '5400-5408', The numeric ID range syntax is
required when 'scan.incremental.snapshot.enabled' enabled.
|
MySqlSourceBuilder<T> |
MySqlSourceBuilder.serverTimeZone(String timeZone) |
The session time zone in database server, e.g.
|
MySqlSourceBuilder<T> |
MySqlSourceBuilder.skipSnapshotBackfill(boolean skipSnapshotBackfill) |
Whether to skip backfill in snapshot reading phase.
|
MySqlSourceBuilder<T> |
MySqlSourceBuilder.splitMetaGroupSize(int splitMetaGroupSize) |
The group size of split meta, if the meta size exceeds the group size, the meta will be
divided into multiple groups.
|
MySqlSourceBuilder<T> |
MySqlSourceBuilder.splitSize(int splitSize) |
The split size (number of rows) of table snapshot, captured tables are split into multiple
splits when read the snapshot of table.
|
MySqlSourceBuilder<T> |
MySqlSourceBuilder.startupOptions(StartupOptions startupOptions) |
Specifies the startup options.
|
MySqlSourceBuilder<T> |
MySqlSourceBuilder.tableList(String... tableList) |
An required list of regular expressions that match fully-qualified table identifiers for
tables to be monitored; any table not included in the list will be excluded from monitoring.
|
MySqlSourceBuilder<T> |
MySqlSourceBuilder.useLegacyJsonFormat(boolean useLegacyJsonFormat) |
Whether to use legacy json format.
|
MySqlSourceBuilder<T> |
MySqlSourceBuilder.username(String username) |
Name of the MySQL database to use when connecting to the MySQL database server.
|