PostgresSourceBuilder<T> |
PostgresSourceBuilder.assignUnboundedChunkFirst(boolean assignUnboundedChunkFirst) |
|
static <T> PostgresSourceBuilder<T> |
PostgresSourceBuilder.PostgresIncrementalSource.builder() |
|
PostgresSourceBuilder<T> |
PostgresSourceBuilder.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.
|
PostgresSourceBuilder<T> |
PostgresSourceBuilder.closeIdleReaders(boolean closeIdleReaders) |
scan.incremental.close-idle-reader.enabled
|
PostgresSourceBuilder<T> |
PostgresSourceBuilder.connectionPoolSize(int connectionPoolSize) |
The connection pool size.
|
PostgresSourceBuilder<T> |
PostgresSourceBuilder.connectMaxRetries(int connectMaxRetries) |
The max retry times to get connection.
|
PostgresSourceBuilder<T> |
PostgresSourceBuilder.connectTimeout(java.time.Duration connectTimeout) |
The maximum time that the connector should wait after trying to connect to the Postgres
database server before timing out.
|
PostgresSourceBuilder<T> |
PostgresSourceBuilder.database(String database) |
The name of the PostgreSQL database from which to stream the changes.
|
PostgresSourceBuilder<T> |
PostgresSourceBuilder.debeziumProperties(Properties properties) |
The Debezium Postgres connector properties.
|
PostgresSourceBuilder<T> |
PostgresSourceBuilder.decodingPluginName(String name) |
The name of the Postgres logical decoding plug-in installed on the server.
|
PostgresSourceBuilder<T> |
PostgresSourceBuilder.deserializer(DebeziumDeserializationSchema<T> deserializer) |
The deserializer used to convert from consumed SourceRecord.
|
PostgresSourceBuilder<T> |
PostgresSourceBuilder.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.
|
PostgresSourceBuilder<T> |
PostgresSourceBuilder.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.
|
PostgresSourceBuilder<T> |
PostgresSourceBuilder.fetchSize(int fetchSize) |
The maximum fetch size for per poll when read table snapshot.
|
PostgresSourceBuilder<T> |
PostgresSourceBuilder.heartbeatInterval(java.time.Duration heartbeatInterval) |
The heartbeat interval for the Postgres server.
|
PostgresSourceBuilder<T> |
PostgresSourceBuilder.hostname(String hostname) |
The hostname of the database to monitor for changes.
|
PostgresSourceBuilder<T> |
PostgresSourceBuilder.includeDatabaseInTableId(boolean includeDatabaseInTableId) |
Whether to include database in the generated Table ID.
|
PostgresSourceBuilder<T> |
PostgresSourceBuilder.includeLogicalMessages(List<String> prefixes) |
Enable emitting Postgres logical decoding messages (records produced by
pg_logical_emit_message) to the deserializer.
|
PostgresSourceBuilder<T> |
PostgresSourceBuilder.includePartitionedTables(boolean includePartitionedTables) |
Whether the connector should read partitioned tables via partition root or not.
|
PostgresSourceBuilder<T> |
PostgresSourceBuilder.includeSchemaChanges(boolean includeSchemaChanges) |
Whether to infer schema change event on relation message.
|
PostgresSourceBuilder<T> |
PostgresSourceBuilder.lsnCommitCheckpointsDelay(int lsnCommitDelay) |
Set the LSN checkpoints delay number for Postgres to commit the offsets.
|
PostgresSourceBuilder<T> |
PostgresSourceBuilder.password(String password) |
Password to use when connecting to the Postgres database server.
|
PostgresSourceBuilder<T> |
PostgresSourceBuilder.port(int port) |
Integer port number of the Postgres database server.
|
PostgresSourceBuilder<T> |
PostgresSourceBuilder.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).
|
PostgresSourceBuilder<T> |
PostgresSourceBuilder.scanNewlyAddedTableEnabled(boolean scanNewlyAddedTableEnabled) |
|
PostgresSourceBuilder<T> |
PostgresSourceBuilder.schemaList(String... schemaList) |
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.
|
PostgresSourceBuilder<T> |
PostgresSourceBuilder.serverTimeZone(String timeZone) |
The session time zone in database server, e.g.
|
PostgresSourceBuilder<T> |
PostgresSourceBuilder.skipSnapshotBackfill(boolean skipSnapshotBackfill) |
Whether to skip backfill in snapshot reading phase.
|
PostgresSourceBuilder<T> |
PostgresSourceBuilder.slotName(String slotName) |
The name of the PostgreSQL logical decoding slot that was created for streaming changes from
a particular plug-in for a particular database/schema.
|
PostgresSourceBuilder<T> |
PostgresSourceBuilder.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.
|
PostgresSourceBuilder<T> |
PostgresSourceBuilder.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.
|
PostgresSourceBuilder<T> |
PostgresSourceBuilder.startupOptions(StartupOptions startupOptions) |
Specifies the startup options.
|
PostgresSourceBuilder<T> |
PostgresSourceBuilder.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.
|
PostgresSourceBuilder<T> |
PostgresSourceBuilder.username(String username) |
Name of the Postgres database to use when connecting to the Postgres database server.
|