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

Class OracleDataSourceOptions

java.lang.Object

org.apache.flink.cdc.connectors.oracle.source.OracleDataSourceOptions

@PublicEvolving
public class OracleDataSourceOptions
extends Object

Configurations for OracleDataSource.

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>	DATABASE
static ConfigOption<String>	DATABASE_CONNECTION_ADAPTER
static ConfigOption<String>	HOSTNAME
static ConfigOption<String>	JDBC_URL
static ConfigOption<String>	LOG_MINING_STRATEGY
static ConfigOption<String>	METADATA_LIST
static ConfigOption<String>	PASSWORD
static ConfigOption<Integer>	PORT
static ConfigOption<Boolean>	SCAN_INCREMENTAL_CLOSE_IDLE_READER_ENABLED
static ConfigOption<Boolean>	SCAN_INCREMENTAL_SNAPSHOT_BACKFILL_SKIP
static ConfigOption<Integer>	SCAN_INCREMENTAL_SNAPSHOT_CHUNK_SIZE
static ConfigOption<Integer>	SCAN_SNAPSHOT_FETCH_SIZE
static ConfigOption<String>	SCAN_STARTUP_MODE
static ConfigOption<String>	SERVER_TIME_ZONE
static ConfigOption<String>	TABLES
static ConfigOption<String>	USERNAME

Constructor Summary

Constructors

Constructor	Description
OracleDataSourceOptions()

Method Summary

Modifier and Type	Method	Description
static Map<String,String>	getPropertiesByPrefix(Configuration tableOptions, String prefix)

Methods inherited from class java.lang.Object

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

Field Detail

JDBC_URL

public static final ConfigOption<String> JDBC_URL

HOSTNAME

public static final ConfigOption<String> HOSTNAME

PORT

public static final ConfigOption<Integer> PORT

USERNAME

public static final ConfigOption<String> USERNAME

PASSWORD

public static final ConfigOption<String> PASSWORD

DATABASE

public static final ConfigOption<String> DATABASE

TABLES

public static final ConfigOption<String> TABLES

SERVER_TIME_ZONE

public static final ConfigOption<String> SERVER_TIME_ZONE

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

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

DATABASE_CONNECTION_ADAPTER

@Experimental
public static final ConfigOption<String> DATABASE_CONNECTION_ADAPTER

LOG_MINING_STRATEGY

@Experimental
public static final ConfigOption<String> LOG_MINING_STRATEGY

SCAN_INCREMENTAL_SNAPSHOT_BACKFILL_SKIP

@Experimental
public static final ConfigOption<Boolean> SCAN_INCREMENTAL_SNAPSHOT_BACKFILL_SKIP

METADATA_LIST

@Experimental
public static final ConfigOption<String> METADATA_LIST

Constructor Detail

OracleDataSourceOptions

public OracleDataSourceOptions()

Method Detail

getPropertiesByPrefix

public static Map<String,String> getPropertiesByPrefix(Configuration tableOptions,
                                                             String prefix)