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

Class SourceOptions

java.lang.Object

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

Direct Known Subclasses:

JdbcSourceOptions

public class SourceOptions
extends Object

Configurations for IncrementalSource.

Field Summary

Fields

Modifier and Type	Field	Description
static org.apache.flink.configuration.ConfigOption<Integer>	CHUNK_META_GROUP_SIZE
static org.apache.flink.configuration.ConfigOption<Boolean>	SCAN_INCREMENTAL_CLOSE_IDLE_READER_ENABLED
static org.apache.flink.configuration.ConfigOption<Boolean>	SCAN_INCREMENTAL_SNAPSHOT_BACKFILL_SKIP
static org.apache.flink.configuration.ConfigOption<Integer>	SCAN_INCREMENTAL_SNAPSHOT_CHUNK_SIZE
static org.apache.flink.configuration.ConfigOption<Boolean>	SCAN_INCREMENTAL_SNAPSHOT_ENABLED
static org.apache.flink.configuration.ConfigOption<Boolean>	SCAN_INCREMENTAL_SNAPSHOT_METADATA_RELEASE_ENABLED
static org.apache.flink.configuration.ConfigOption<Boolean>	SCAN_INCREMENTAL_SNAPSHOT_UNBOUNDED_CHUNK_FIRST_ENABLED
static org.apache.flink.configuration.ConfigOption<Boolean>	SCAN_NEWLY_ADDED_TABLE_ENABLED
static org.apache.flink.configuration.ConfigOption<Boolean>	SCAN_READ_CHANGELOG_AS_APPEND_ONLY_ENABLED
static org.apache.flink.configuration.ConfigOption<Integer>	SCAN_SNAPSHOT_FETCH_SIZE
static org.apache.flink.configuration.ConfigOption<String>	SCAN_STARTUP_MODE
static org.apache.flink.configuration.ConfigOption<String>	SCAN_STARTUP_SPECIFIC_OFFSET_FILE
static org.apache.flink.configuration.ConfigOption<Integer>	SCAN_STARTUP_SPECIFIC_OFFSET_POS
static org.apache.flink.configuration.ConfigOption<Long>	SCAN_STARTUP_TIMESTAMP_MILLIS
static org.apache.flink.configuration.ConfigOption<Double>	SPLIT_KEY_EVEN_DISTRIBUTION_FACTOR_LOWER_BOUND
static org.apache.flink.configuration.ConfigOption<Double>	SPLIT_KEY_EVEN_DISTRIBUTION_FACTOR_UPPER_BOUND

Constructor Summary

Constructors

Constructor	Description
SourceOptions()

Method Summary

Methods inherited from class java.lang.Object

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

Field Detail

SCAN_INCREMENTAL_SNAPSHOT_ENABLED

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

SCAN_INCREMENTAL_SNAPSHOT_CHUNK_SIZE

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

SCAN_SNAPSHOT_FETCH_SIZE

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

SCAN_STARTUP_MODE

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

SCAN_STARTUP_SPECIFIC_OFFSET_FILE

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

SCAN_STARTUP_SPECIFIC_OFFSET_POS

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

SCAN_STARTUP_TIMESTAMP_MILLIS

public static final org.apache.flink.configuration.ConfigOption<Long> SCAN_STARTUP_TIMESTAMP_MILLIS

CHUNK_META_GROUP_SIZE

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

SPLIT_KEY_EVEN_DISTRIBUTION_FACTOR_UPPER_BOUND

public static final org.apache.flink.configuration.ConfigOption<Double> SPLIT_KEY_EVEN_DISTRIBUTION_FACTOR_UPPER_BOUND

SPLIT_KEY_EVEN_DISTRIBUTION_FACTOR_LOWER_BOUND

public static final org.apache.flink.configuration.ConfigOption<Double> SPLIT_KEY_EVEN_DISTRIBUTION_FACTOR_LOWER_BOUND

SCAN_INCREMENTAL_CLOSE_IDLE_READER_ENABLED

@Experimental
public static final org.apache.flink.configuration.ConfigOption<Boolean> SCAN_INCREMENTAL_CLOSE_IDLE_READER_ENABLED

SCAN_INCREMENTAL_SNAPSHOT_BACKFILL_SKIP

@Experimental
public static final org.apache.flink.configuration.ConfigOption<Boolean> SCAN_INCREMENTAL_SNAPSHOT_BACKFILL_SKIP

SCAN_NEWLY_ADDED_TABLE_ENABLED

@Experimental
public static final org.apache.flink.configuration.ConfigOption<Boolean> SCAN_NEWLY_ADDED_TABLE_ENABLED

SCAN_INCREMENTAL_SNAPSHOT_METADATA_RELEASE_ENABLED

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

SCAN_INCREMENTAL_SNAPSHOT_UNBOUNDED_CHUNK_FIRST_ENABLED

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

SCAN_READ_CHANGELOG_AS_APPEND_ONLY_ENABLED

@Experimental
public static final org.apache.flink.configuration.ConfigOption<Boolean> SCAN_READ_CHANGELOG_AS_APPEND_ONLY_ENABLED

Constructor Detail

SourceOptions

public SourceOptions()