Db2SourceBuilder<T> |
Db2SourceBuilder.assignUnboundedChunkFirst(boolean assignUnboundedChunkFirst) |
|
static <T> Db2SourceBuilder<T> |
Db2SourceBuilder.Db2IncrementalSource.builder() |
|
Db2SourceBuilder<T> |
Db2SourceBuilder.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.
|
Db2SourceBuilder<T> |
Db2SourceBuilder.closeIdleReaders(boolean closeIdleReaders) |
Whether to close idle readers at the end of the snapshot phase.
|
Db2SourceBuilder<T> |
Db2SourceBuilder.connectionPoolSize(int connectionPoolSize) |
The connection pool size.
|
Db2SourceBuilder<T> |
Db2SourceBuilder.connectMaxRetries(int connectMaxRetries) |
The max retry times to get connection.
|
Db2SourceBuilder<T> |
Db2SourceBuilder.connectTimeout(java.time.Duration connectTimeout) |
The maximum time that the connector should wait after trying to connect to the Db2 database
server before timing out.
|
Db2SourceBuilder<T> |
Db2SourceBuilder.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.
|
Db2SourceBuilder<T> |
Db2SourceBuilder.debeziumProperties(Properties properties) |
The Debezium Db2 connector properties.
|
Db2SourceBuilder<T> |
Db2SourceBuilder.deserializer(DebeziumDeserializationSchema<T> deserializer) |
The deserializer used to convert from consumed SourceRecord.
|
Db2SourceBuilder<T> |
Db2SourceBuilder.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.
|
Db2SourceBuilder<T> |
Db2SourceBuilder.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.
|
Db2SourceBuilder<T> |
Db2SourceBuilder.fetchSize(int fetchSize) |
The maximum fetch size for per poll when read table snapshot.
|
Db2SourceBuilder<T> |
Db2SourceBuilder.hostname(String hostname) |
Hostname of the Db2 database server.
|
Db2SourceBuilder<T> |
Db2SourceBuilder.includeSchemaChanges(boolean includeSchemaChanges) |
|
Db2SourceBuilder<T> |
Db2SourceBuilder.password(String password) |
Password to use when connecting to the Db2 database server.
|
Db2SourceBuilder<T> |
Db2SourceBuilder.port(int port) |
Integer port number of the Db2 database server.
|
Db2SourceBuilder<T> |
Db2SourceBuilder.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).
|
Db2SourceBuilder<T> |
Db2SourceBuilder.serverTimeZone(String timeZone) |
The session time zone in database server, e.g.
|
Db2SourceBuilder<T> |
Db2SourceBuilder.skipSnapshotBackfill(boolean skipSnapshotBackfill) |
Whether to skip backfill in snapshot reading phase.
|
Db2SourceBuilder<T> |
Db2SourceBuilder.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.
|
Db2SourceBuilder<T> |
Db2SourceBuilder.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.
|
Db2SourceBuilder<T> |
Db2SourceBuilder.startupOptions(StartupOptions startupOptions) |
Specifies the startup options.
|
Db2SourceBuilder<T> |
Db2SourceBuilder.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.
|
Db2SourceBuilder<T> |
Db2SourceBuilder.username(String username) |
Name of the Db2 database to use when connecting to the Db2 database server.
|