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

Class PostgresDataSourceOptions

java.lang.Object

org.apache.flink.cdc.connectors.postgres.source.PostgresDataSourceOptions

@PublicEvolving
public class PostgresDataSourceOptions
extends Object

Configurations for PostgresDataSource.

Field Summary

Fields

Modifier and Type	Field	Description
static ConfigOption<Double>	CHUNK_KEY_EVEN_DISTRIBUTION_FACTOR_LOWER_BOUND
static ConfigOption<Double>	CHUNK_KEY_EVEN_DISTRIBUTION_FACTOR_UPPER_BOUND
static ConfigOption<Integer>	CHUNK_META_GROUP_SIZE
static ConfigOption<Integer>	CONNECT_MAX_RETRIES
static ConfigOption<java.time.Duration>	CONNECT_TIMEOUT
static ConfigOption<Integer>	CONNECTION_POOL_SIZE
static ConfigOption<String>	DECODING_PLUGIN_NAME
static ConfigOption<java.time.Duration>	HEARTBEAT_INTERVAL
static ConfigOption<String>	HOSTNAME
static ConfigOption<String>	METADATA_LIST
static ConfigOption<String>	PASSWORD
static ConfigOption<Integer>	PG_PORT
static ConfigOption<Boolean>	SCAN_INCREMENTAL_CLOSE_IDLE_READER_ENABLED
static ConfigOption<Boolean>	SCAN_INCREMENTAL_SNAPSHOT_BACKFILL_SKIP
static ConfigOption<String>	SCAN_INCREMENTAL_SNAPSHOT_CHUNK_KEY_COLUMN
static ConfigOption<Integer>	SCAN_INCREMENTAL_SNAPSHOT_CHUNK_SIZE
static ConfigOption<Boolean>	SCAN_INCREMENTAL_SNAPSHOT_UNBOUNDED_CHUNK_FIRST_ENABLED
static ConfigOption<Integer>	SCAN_LSN_COMMIT_CHECKPOINTS_DELAY
static ConfigOption<Boolean>	SCAN_NEWLY_ADDED_TABLE_ENABLED
static ConfigOption<Boolean>	SCAN_PRE_EPOCH_TIMESTAMP_WALL_CLOCK_CONVERSION_ENABLED
static ConfigOption<Integer>	SCAN_SNAPSHOT_FETCH_SIZE
static ConfigOption<String>	SCAN_STARTUP_MODE
static ConfigOption<Boolean>	SCHEMA_CHANGE_ENABLED
static ConfigOption<String>	SERVER_TIME_ZONE
static ConfigOption<String>	SLOT_NAME
static ConfigOption<Double>	SPLIT_KEY_EVEN_DISTRIBUTION_FACTOR_LOWER_BOUND
static ConfigOption<Double>	SPLIT_KEY_EVEN_DISTRIBUTION_FACTOR_UPPER_BOUND
static ConfigOption<Boolean>	TABLE_ID_INCLUDE_DATABASE
static ConfigOption<String>	TABLES
static ConfigOption<String>	TABLES_EXCLUDE
static ConfigOption<String>	USERNAME

Constructor Summary

Constructors

Constructor	Description
PostgresDataSourceOptions()

Method Summary

Methods inherited from class java.lang.Object

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

Field Detail

HOSTNAME

public static final ConfigOption<String> HOSTNAME

PG_PORT

public static final ConfigOption<Integer> PG_PORT

USERNAME

public static final ConfigOption<String> USERNAME

PASSWORD

public static final ConfigOption<String> PASSWORD

TABLES

public static final ConfigOption<String> TABLES

DECODING_PLUGIN_NAME

public static final ConfigOption<String> DECODING_PLUGIN_NAME

SLOT_NAME

public static final ConfigOption<String> SLOT_NAME

SERVER_TIME_ZONE

public static final ConfigOption<String> SERVER_TIME_ZONE

SCAN_INCREMENTAL_SNAPSHOT_CHUNK_KEY_COLUMN

public static final ConfigOption<String> SCAN_INCREMENTAL_SNAPSHOT_CHUNK_KEY_COLUMN

SCAN_INCREMENTAL_SNAPSHOT_CHUNK_SIZE

public static final ConfigOption<Integer> SCAN_INCREMENTAL_SNAPSHOT_CHUNK_SIZE

SCAN_SNAPSHOT_FETCH_SIZE

public static final ConfigOption<Integer> SCAN_SNAPSHOT_FETCH_SIZE

CONNECT_TIMEOUT

public static final ConfigOption<java.time.Duration> CONNECT_TIMEOUT

CONNECTION_POOL_SIZE

public static final ConfigOption<Integer> CONNECTION_POOL_SIZE

CONNECT_MAX_RETRIES

public static final ConfigOption<Integer> CONNECT_MAX_RETRIES

SCAN_STARTUP_MODE

public static final ConfigOption<String> SCAN_STARTUP_MODE

HEARTBEAT_INTERVAL

public static final ConfigOption<java.time.Duration> HEARTBEAT_INTERVAL

SPLIT_KEY_EVEN_DISTRIBUTION_FACTOR_UPPER_BOUND

public static final ConfigOption<Double> SPLIT_KEY_EVEN_DISTRIBUTION_FACTOR_UPPER_BOUND

SPLIT_KEY_EVEN_DISTRIBUTION_FACTOR_LOWER_BOUND

public static final ConfigOption<Double> SPLIT_KEY_EVEN_DISTRIBUTION_FACTOR_LOWER_BOUND

SCAN_INCREMENTAL_SNAPSHOT_BACKFILL_SKIP

public static final ConfigOption<Boolean> SCAN_INCREMENTAL_SNAPSHOT_BACKFILL_SKIP

CHUNK_META_GROUP_SIZE

@Experimental
public static final ConfigOption<Integer> CHUNK_META_GROUP_SIZE

CHUNK_KEY_EVEN_DISTRIBUTION_FACTOR_UPPER_BOUND

@Experimental
public static final ConfigOption<Double> CHUNK_KEY_EVEN_DISTRIBUTION_FACTOR_UPPER_BOUND

CHUNK_KEY_EVEN_DISTRIBUTION_FACTOR_LOWER_BOUND

@Experimental
public static final ConfigOption<Double> CHUNK_KEY_EVEN_DISTRIBUTION_FACTOR_LOWER_BOUND

SCAN_INCREMENTAL_CLOSE_IDLE_READER_ENABLED

@Experimental
public static final ConfigOption<Boolean> SCAN_INCREMENTAL_CLOSE_IDLE_READER_ENABLED

TABLES_EXCLUDE

@Experimental
public static final ConfigOption<String> TABLES_EXCLUDE

SCAN_LSN_COMMIT_CHECKPOINTS_DELAY

public static final ConfigOption<Integer> SCAN_LSN_COMMIT_CHECKPOINTS_DELAY

METADATA_LIST

@Experimental
public static final ConfigOption<String> METADATA_LIST

SCAN_INCREMENTAL_SNAPSHOT_UNBOUNDED_CHUNK_FIRST_ENABLED

@Experimental
public static final ConfigOption<Boolean> SCAN_INCREMENTAL_SNAPSHOT_UNBOUNDED_CHUNK_FIRST_ENABLED

TABLE_ID_INCLUDE_DATABASE

public static final ConfigOption<Boolean> TABLE_ID_INCLUDE_DATABASE

SCAN_PRE_EPOCH_TIMESTAMP_WALL_CLOCK_CONVERSION_ENABLED

public static final ConfigOption<Boolean> SCAN_PRE_EPOCH_TIMESTAMP_WALL_CLOCK_CONVERSION_ENABLED

SCHEMA_CHANGE_ENABLED

@Experimental
public static final ConfigOption<Boolean> SCHEMA_CHANGE_ENABLED

SCAN_NEWLY_ADDED_TABLE_ENABLED

public static final ConfigOption<Boolean> SCAN_NEWLY_ADDED_TABLE_ENABLED

Constructor Detail

PostgresDataSourceOptions

public PostgresDataSourceOptions()