Package org.apache.flink.cdc.connectors.postgres.source.config

Class PostgresSourceOptions

java.lang.Object

org.apache.flink.cdc.connectors.base.options.SourceOptions

org.apache.flink.cdc.connectors.base.options.JdbcSourceOptions

org.apache.flink.cdc.connectors.postgres.source.config.PostgresSourceOptions

public class PostgresSourceOptions
extends JdbcSourceOptions

Configurations for PostgresSourceBuilder.PostgresIncrementalSource.

Field Summary

Fields

Modifier and Type	Field	Description
static org.apache.flink.configuration.ConfigOption<DebeziumChangelogMode>	CHANGELOG_MODE
static org.apache.flink.configuration.ConfigOption<String>	DECODING_PLUGIN_NAME
static org.apache.flink.configuration.ConfigOption<java.time.Duration>	HEARTBEAT_INTERVAL
static org.apache.flink.configuration.ConfigOption<Integer>	PG_PORT
static org.apache.flink.configuration.ConfigOption<Boolean>	SCAN_INCLUDE_PARTITIONED_TABLES_ENABLED
static org.apache.flink.configuration.ConfigOption<Boolean>	SCAN_INCREMENTAL_SNAPSHOT_ENABLED
static org.apache.flink.configuration.ConfigOption<Integer>	SCAN_LSN_COMMIT_CHECKPOINTS_DELAY
static org.apache.flink.configuration.ConfigOption<Boolean>	SCAN_PRE_EPOCH_TIMESTAMP_WALL_CLOCK_CONVERSION_ENABLED
static org.apache.flink.configuration.ConfigOption<String>	SLOT_NAME
static org.apache.flink.configuration.ConfigOption<Boolean>	TABLE_ID_INCLUDE_DATABASE

Fields inherited from class org.apache.flink.cdc.connectors.base.options.JdbcSourceOptions

CONNECT_MAX_RETRIES, CONNECT_TIMEOUT, CONNECTION_POOL_SIZE, DATABASE_NAME, HOSTNAME, PASSWORD, SCAN_INCREMENTAL_SNAPSHOT_CHUNK_KEY_COLUMN, SCHEMA_NAME, SERVER_ID, SERVER_TIME_ZONE, TABLE_NAME, USERNAME

Fields inherited from class org.apache.flink.cdc.connectors.base.options.SourceOptions

CHUNK_META_GROUP_SIZE, SCAN_INCREMENTAL_CLOSE_IDLE_READER_ENABLED, SCAN_INCREMENTAL_SNAPSHOT_BACKFILL_SKIP, SCAN_INCREMENTAL_SNAPSHOT_CHUNK_SIZE, SCAN_INCREMENTAL_SNAPSHOT_METADATA_RELEASE_ENABLED, SCAN_INCREMENTAL_SNAPSHOT_UNBOUNDED_CHUNK_FIRST_ENABLED, SCAN_NEWLY_ADDED_TABLE_ENABLED, SCAN_READ_CHANGELOG_AS_APPEND_ONLY_ENABLED, SCAN_SNAPSHOT_FETCH_SIZE, SCAN_STARTUP_MODE, SCAN_STARTUP_SPECIFIC_OFFSET_FILE, SCAN_STARTUP_SPECIFIC_OFFSET_POS, SCAN_STARTUP_TIMESTAMP_MILLIS, SPLIT_KEY_EVEN_DISTRIBUTION_FACTOR_LOWER_BOUND, SPLIT_KEY_EVEN_DISTRIBUTION_FACTOR_UPPER_BOUND

Constructor Summary

Constructors

Constructor	Description
PostgresSourceOptions()

Method Summary

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Field Detail

PG_PORT

public static final org.apache.flink.configuration.ConfigOption<Integer> PG_PORT

DECODING_PLUGIN_NAME

public static final org.apache.flink.configuration.ConfigOption<String> DECODING_PLUGIN_NAME

SLOT_NAME

public static final org.apache.flink.configuration.ConfigOption<String> SLOT_NAME

CHANGELOG_MODE

public static final org.apache.flink.configuration.ConfigOption<DebeziumChangelogMode> CHANGELOG_MODE

SCAN_INCREMENTAL_SNAPSHOT_ENABLED

public static final org.apache.flink.configuration.ConfigOption<Boolean> SCAN_INCREMENTAL_SNAPSHOT_ENABLED

HEARTBEAT_INTERVAL

public static final org.apache.flink.configuration.ConfigOption<java.time.Duration> HEARTBEAT_INTERVAL

SCAN_LSN_COMMIT_CHECKPOINTS_DELAY

public static final org.apache.flink.configuration.ConfigOption<Integer> SCAN_LSN_COMMIT_CHECKPOINTS_DELAY

SCAN_INCLUDE_PARTITIONED_TABLES_ENABLED

public static final org.apache.flink.configuration.ConfigOption<Boolean> SCAN_INCLUDE_PARTITIONED_TABLES_ENABLED

TABLE_ID_INCLUDE_DATABASE

public static final org.apache.flink.configuration.ConfigOption<Boolean> TABLE_ID_INCLUDE_DATABASE

SCAN_PRE_EPOCH_TIMESTAMP_WALL_CLOCK_CONVERSION_ENABLED

public static final org.apache.flink.configuration.ConfigOption<Boolean> SCAN_PRE_EPOCH_TIMESTAMP_WALL_CLOCK_CONVERSION_ENABLED

Constructor Detail

PostgresSourceOptions

public PostgresSourceOptions()