SqlServerSourceBuilder<T> |
SqlServerSourceBuilder.assignUnboundedChunkFirst(boolean assignUnboundedChunkFirst) |
Whether the SqlServerSourceBuilder should assign the unbounded chunks first or not
during snapshot reading phase. |
static <T> SqlServerSourceBuilder<T> |
SqlServerSourceBuilder.SqlServerIncrementalSource.builder() |
|
SqlServerSourceBuilder<T> |
SqlServerSourceBuilder.chunkKeyColumn(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.
|
SqlServerSourceBuilder<T> |
SqlServerSourceBuilder.closeIdleReaders(boolean closeIdleReaders) |
Whether to close idle readers at the end of the snapshot phase.
|
SqlServerSourceBuilder<T> |
SqlServerSourceBuilder.connectionPoolSize(int connectionPoolSize) |
The connection pool size.
|
SqlServerSourceBuilder<T> |
SqlServerSourceBuilder.connectMaxRetries(int connectMaxRetries) |
The max retry times to get connection.
|
SqlServerSourceBuilder<T> |
SqlServerSourceBuilder.connectTimeout(java.time.Duration connectTimeout) |
The maximum time that the connector should wait after trying to connect to the SqlSever
database server before timing out.
|
SqlServerSourceBuilder<T> |
SqlServerSourceBuilder.databaseList(String... databaseList) |
A 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.
|
SqlServerSourceBuilder<T> |
SqlServerSourceBuilder.debeziumProperties(Properties properties) |
The Debezium SqlSever connector properties.
|
SqlServerSourceBuilder<T> |
SqlServerSourceBuilder.deserializer(DebeziumDeserializationSchema<T> deserializer) |
The deserializer used to convert from consumed SourceRecord.
|
SqlServerSourceBuilder<T> |
SqlServerSourceBuilder.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.
|
SqlServerSourceBuilder<T> |
SqlServerSourceBuilder.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.
|
SqlServerSourceBuilder<T> |
SqlServerSourceBuilder.fetchSize(int fetchSize) |
The maximum fetch size for per poll when read table snapshot.
|
SqlServerSourceBuilder<T> |
SqlServerSourceBuilder.hostname(String hostname) |
Hostname of the SQL Server database server.
|
SqlServerSourceBuilder<T> |
SqlServerSourceBuilder.includeSchemaChanges(boolean includeSchemaChanges) |
|
SqlServerSourceBuilder<T> |
SqlServerSourceBuilder.password(String password) |
Password to use when connecting to the SqlSever database server.
|
SqlServerSourceBuilder<T> |
SqlServerSourceBuilder.port(int port) |
Integer port number of the SqlServer database server.
|
SqlServerSourceBuilder<T> |
SqlServerSourceBuilder.releaseSnapshotMetadataEnabled(boolean releaseSnapshotMetadataEnabled) |
Whether to release the finished snapshot split metadata from the coordinator after entering
the stream phase, to reduce JobManager memory pressure (FLINK-40697).
|
SqlServerSourceBuilder<T> |
SqlServerSourceBuilder.serverTimeZone(String timeZone) |
The session time zone in database server, e.g.
|
SqlServerSourceBuilder<T> |
SqlServerSourceBuilder.skipSnapshotBackfill(boolean skipSnapshotBackfill) |
Whether to skip backfill in snapshot reading phase.
|
SqlServerSourceBuilder<T> |
SqlServerSourceBuilder.splitMetaGroupSize(int splitMetaGroupSize) |
The group size of split meta, if the meta size exceeds the group size, the meta will be will
be divided into multiple groups.
|
SqlServerSourceBuilder<T> |
SqlServerSourceBuilder.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.
|
SqlServerSourceBuilder<T> |
SqlServerSourceBuilder.startupOptions(StartupOptions startupOptions) |
Specifies the startup options.
|
SqlServerSourceBuilder<T> |
SqlServerSourceBuilder.tableList(String... tableList) |
A 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.
|
SqlServerSourceBuilder<T> |
SqlServerSourceBuilder.username(String username) |
Name of the SqlSever database to use when connecting to the SqlSever database server.
|