Uses of Class
org.apache.flink.cdc.connectors.base.options.StartupOptions

Packages that use StartupOptions

Package	Description
org.apache.flink.cdc.connectors.base.config
org.apache.flink.cdc.connectors.base.options
org.apache.flink.cdc.connectors.db2
org.apache.flink.cdc.connectors.db2.source
org.apache.flink.cdc.connectors.db2.source.config
org.apache.flink.cdc.connectors.db2.table
org.apache.flink.cdc.connectors.mongodb
org.apache.flink.cdc.connectors.mongodb.source
org.apache.flink.cdc.connectors.mongodb.source.config
org.apache.flink.cdc.connectors.mongodb.table
org.apache.flink.cdc.connectors.oracle
org.apache.flink.cdc.connectors.oracle.source
org.apache.flink.cdc.connectors.oracle.source.config
org.apache.flink.cdc.connectors.oracle.table
org.apache.flink.cdc.connectors.postgres.source
org.apache.flink.cdc.connectors.postgres.source.config
org.apache.flink.cdc.connectors.postgres.table
org.apache.flink.cdc.connectors.sqlserver
org.apache.flink.cdc.connectors.sqlserver.source
org.apache.flink.cdc.connectors.sqlserver.source.config
org.apache.flink.cdc.connectors.sqlserver.table

Uses of StartupOptions in org.apache.flink.cdc.connectors.base.config

Fields in org.apache.flink.cdc.connectors.base.config declared as StartupOptions

Modifier and Type	Field	Description
protected StartupOptions	BaseSourceConfig.startupOptions
protected StartupOptions	JdbcSourceConfigFactory.startupOptions

Methods in org.apache.flink.cdc.connectors.base.config that return StartupOptions

Modifier and Type	Method	Description
StartupOptions	BaseSourceConfig.getStartupOptions()
StartupOptions	SourceConfig.getStartupOptions()

Methods in org.apache.flink.cdc.connectors.base.config with parameters of type StartupOptions

Modifier and Type	Method	Description
JdbcSourceConfigFactory	JdbcSourceConfigFactory.startupOptions(StartupOptions startupOptions)	Specifies the startup options.

Constructors in org.apache.flink.cdc.connectors.base.config with parameters of type StartupOptions

Constructor	Description
BaseSourceConfig(StartupOptions startupOptions, int splitSize, int splitMetaGroupSize, double distributionFactorUpper, double distributionFactorLower, boolean includeSchemaChanges, boolean closeIdleReaders, boolean skipSnapshotBackfill, boolean isScanNewlyAddedTableEnabled, Properties dbzProperties, io.debezium.config.Configuration dbzConfiguration, boolean assignUnboundedChunkFirst, boolean releaseSnapshotMetadataEnabled)
JdbcSourceConfig(StartupOptions startupOptions, List<String> databaseList, List<String> schemaList, List<String> tableList, int splitSize, int splitMetaGroupSize, double distributionFactorUpper, double distributionFactorLower, boolean includeSchemaChanges, boolean closeIdleReaders, Properties dbzProperties, io.debezium.config.Configuration dbzConfiguration, String driverClassName, String hostname, int port, String username, String password, int fetchSize, String serverTimeZone, java.time.Duration connectTimeout, int connectMaxRetries, int connectionPoolSize, String chunkKeyColumn, boolean skipSnapshotBackfill, boolean isScanNewlyAddedTableEnabled, boolean assignUnboundedChunkFirst, boolean releaseSnapshotMetadataEnabled)

Uses of StartupOptions in org.apache.flink.cdc.connectors.base.options

Methods in org.apache.flink.cdc.connectors.base.options that return StartupOptions

Modifier and Type	Method	Description
static StartupOptions	StartupOptions.committed()	Never to perform snapshot on the monitored database tables upon first startup, just read from the previous committed posistion of the change log which means only have the changes since the connector last stopped.
static StartupOptions	StartupOptions.earliest()	Never to perform snapshot on the monitored database tables upon first startup, just read from the beginning of the change log.
static StartupOptions	StartupOptions.initial()	Performs an initial snapshot on the monitored database tables upon first startup, and continue to read the latest change log.
static StartupOptions	StartupOptions.latest()	Never to perform snapshot on the monitored database tables upon first startup, just read from the end of the change log which means only have the changes since the connector was started.
static StartupOptions	StartupOptions.snapshot()	Performs an initial snapshot on the monitored database tables upon first startup, and not read the change log anymore .
static StartupOptions	StartupOptions.specificOffset(String specificOffsetFile, int specificOffsetPos)	Never to perform snapshot on the monitored database tables upon first startup, and directly read change log from the specified offset.
static StartupOptions	StartupOptions.specificOffset(Map<String,String> offset)
static StartupOptions	StartupOptions.timestamp(long startupTimestampMillis)	Never to perform snapshot on the monitored database tables upon first startup, and directly read change log from the specified timestamp.

Uses of StartupOptions in org.apache.flink.cdc.connectors.db2

Methods in org.apache.flink.cdc.connectors.db2 with parameters of type StartupOptions

Modifier and Type	Method	Description
Db2Source.Builder<T>	Db2Source.Builder.startupOptions(StartupOptions startupOptions)	Specifies the startup options.

Uses of StartupOptions in org.apache.flink.cdc.connectors.db2.source

Methods in org.apache.flink.cdc.connectors.db2.source with parameters of type StartupOptions

Modifier and Type	Method	Description
Db2SourceBuilder<T>	Db2SourceBuilder.startupOptions(StartupOptions startupOptions)	Specifies the startup options.

Uses of StartupOptions in org.apache.flink.cdc.connectors.db2.source.config

Constructors in org.apache.flink.cdc.connectors.db2.source.config with parameters of type StartupOptions

Constructor

Description

Db2SourceConfig(StartupOptions startupOptions, List<String> databaseList, List<String> tableList, int splitSize, int splitMetaGroupSize, double distributionFactorUpper, double distributionFactorLower, boolean includeSchemaChanges, boolean closeIdleReaders, Properties dbzProperties, io.debezium.config.Configuration dbzConfiguration, String driverClassName, String hostname, int port, String username, String password, int fetchSize, String serverTimeZone, java.time.Duration connectTimeout, int connectMaxRetries, int connectionPoolSize, String chunkKeyColumn, boolean skipSnapshotBackfill, boolean assignUnboundedChunkFirst, boolean releaseSnapshotMetadataEnabled)

Uses of StartupOptions in org.apache.flink.cdc.connectors.db2.table

Constructors in org.apache.flink.cdc.connectors.db2.table with parameters of type StartupOptions

Constructor

Description

Db2TableSource(org.apache.flink.table.catalog.ResolvedSchema physicalSchema, int port, String hostname, String database, String tableName, String username, String password, java.time.ZoneId serverTimeZone, Properties dbzProperties, StartupOptions startupOptions, boolean enableParallelRead, int splitSize, int splitMetaGroupSize, int fetchSize, java.time.Duration connectTimeout, int connectMaxRetries, int connectionPoolSize, double distributionFactorUpper, double distributionFactorLower, String chunkKeyColumn, boolean closeIdleReaders, boolean skipSnapshotBackfill, boolean assignUnboundedChunkFirst, boolean releaseSnapshotMetadataEnabled)

Uses of StartupOptions in org.apache.flink.cdc.connectors.mongodb

Methods in org.apache.flink.cdc.connectors.mongodb with parameters of type StartupOptions

Modifier and Type	Method	Description
MongoDBSource.Builder<T>	MongoDBSource.Builder.startupOptions(StartupOptions startupOptions)	scan.startup.mode

Uses of StartupOptions in org.apache.flink.cdc.connectors.mongodb.source

Methods in org.apache.flink.cdc.connectors.mongodb.source with parameters of type StartupOptions

Modifier and Type	Method	Description
MongoDBSourceBuilder<T>	MongoDBSourceBuilder.startupOptions(StartupOptions startupOptions)	scan.startup.mode

Uses of StartupOptions in org.apache.flink.cdc.connectors.mongodb.source.config

Methods in org.apache.flink.cdc.connectors.mongodb.source.config that return StartupOptions

Modifier and Type	Method	Description
StartupOptions	MongoDBSourceConfig.getStartupOptions()

Methods in org.apache.flink.cdc.connectors.mongodb.source.config with parameters of type StartupOptions

Modifier and Type	Method	Description
MongoDBSourceConfigFactory	MongoDBSourceConfigFactory.startupOptions(StartupOptions startupOptions)	scan.startup.mode

Uses of StartupOptions in org.apache.flink.cdc.connectors.mongodb.table

Constructors in org.apache.flink.cdc.connectors.mongodb.table with parameters of type StartupOptions

Constructor

Description

MongoDBTableSource(org.apache.flink.table.catalog.ResolvedSchema physicalSchema, String scheme, String hosts, String username, String password, String database, String collection, String connectionOptions, StartupOptions startupOptions, Integer initialSnapshottingQueueSize, Integer initialSnapshottingMaxThreads, String initialSnapshottingPipeline, Integer batchSize, Integer pollMaxBatchSize, Integer pollAwaitTimeMillis, Integer heartbeatIntervalMillis, java.time.ZoneId localTimeZone, boolean enableParallelRead, Integer splitMetaGroupSize, Integer splitSizeMB, Integer samplesPerChunk, boolean closeIdlerReaders, boolean enableFullDocPrePostImage, boolean noCursorTimeout, boolean skipSnapshotBackfill, boolean scanNewlyAddedTableEnabled, boolean assignUnboundedChunkFirst, boolean releaseSnapshotMetadataEnabled, boolean sslEnabled, boolean sslInvalidHostnameAllowed, String sslKeyStore, String sslKeyStorePassword, String sslKeyStoreType, String sslTrustStore, String sslTrustStorePassword, String sslTrustStoreType)

Uses of StartupOptions in org.apache.flink.cdc.connectors.oracle

Methods in org.apache.flink.cdc.connectors.oracle with parameters of type StartupOptions

Modifier and Type	Method	Description
OracleSource.Builder<T>	OracleSource.Builder.startupOptions(StartupOptions startupOptions)	Specifies the startup options.

Uses of StartupOptions in org.apache.flink.cdc.connectors.oracle.source

Methods in org.apache.flink.cdc.connectors.oracle.source with parameters of type StartupOptions

Modifier and Type	Method	Description
OracleSourceBuilder<T>	OracleSourceBuilder.startupOptions(StartupOptions startupOptions)	Specifies the startup options.

Uses of StartupOptions in org.apache.flink.cdc.connectors.oracle.source.config

Constructors in org.apache.flink.cdc.connectors.oracle.source.config with parameters of type StartupOptions

Constructor

Description

OracleSourceConfig(StartupOptions startupOptions, List<String> databaseList, List<String> tableList, int splitSize, int splitMetaGroupSize, double distributionFactorUpper, double distributionFactorLower, boolean includeSchemaChanges, boolean closeIdleReaders, Properties dbzProperties, io.debezium.config.Configuration dbzConfiguration, String driverClassName, String url, String hostname, int port, String username, String password, int fetchSize, String serverTimeZone, java.time.Duration connectTimeout, int connectMaxRetries, int connectionPoolSize, String chunkKeyColumn, boolean skipSnapshotBackfill, boolean scanNewlyAddedTableEnabled, boolean assignUnboundedChunkFirst, boolean releaseSnapshotMetadataEnabled)

Uses of StartupOptions in org.apache.flink.cdc.connectors.oracle.table

Constructors in org.apache.flink.cdc.connectors.oracle.table with parameters of type StartupOptions

Constructor

Description

OracleTableSource(org.apache.flink.table.catalog.ResolvedSchema physicalSchema, String url, int port, String hostname, String database, String tableName, String schemaName, String username, String password, Properties dbzProperties, StartupOptions startupOptions, boolean enableParallelRead, int splitSize, int splitMetaGroupSize, int fetchSize, java.time.Duration connectTimeout, int connectMaxRetries, int connectionPoolSize, double distributionFactorUpper, double distributionFactorLower, String chunkKeyColumn, boolean closeIdleReaders, boolean skipSnapshotBackfill, boolean scanNewlyAddedTableEnabled, boolean assignUnboundedChunkFirst, boolean releaseSnapshotMetadataEnabled)

Uses of StartupOptions in org.apache.flink.cdc.connectors.postgres.source

Methods in org.apache.flink.cdc.connectors.postgres.source with parameters of type StartupOptions

Modifier and Type	Method	Description
PostgresSourceBuilder<T>	PostgresSourceBuilder.startupOptions(StartupOptions startupOptions)	Specifies the startup options.

Uses of StartupOptions in org.apache.flink.cdc.connectors.postgres.source.config

Constructors in org.apache.flink.cdc.connectors.postgres.source.config with parameters of type StartupOptions

Constructor

Description

PostgresSourceConfig(int subtaskId, StartupOptions startupOptions, List<String> databaseList, List<String> schemaList, List<String> tableList, int splitSize, int splitMetaGroupSize, double distributionFactorUpper, double distributionFactorLower, boolean includeSchemaChanges, boolean closeIdleReaders, Properties dbzProperties, io.debezium.config.Configuration dbzConfiguration, String driverClassName, String hostname, int port, String username, String password, int fetchSize, String serverTimeZone, java.time.Duration connectTimeout, int connectMaxRetries, int connectionPoolSize, String chunkKeyColumn, boolean skipSnapshotBackfill, boolean isScanNewlyAddedTableEnabled, int lsnCommitCheckpointsDelay, boolean assignUnboundedChunkFirst, boolean includePartitionedTables, boolean includeDatabaseInTableId, List<String> logicalMessagePrefixes, boolean releaseSnapshotMetadataEnabled)

Uses of StartupOptions in org.apache.flink.cdc.connectors.postgres.table

Constructors in org.apache.flink.cdc.connectors.postgres.table with parameters of type StartupOptions

Constructor

Description

PostgreSQLTableSource(org.apache.flink.table.catalog.ResolvedSchema physicalSchema, int port, String hostname, String database, String schemaName, String tableName, String username, String password, String pluginName, String slotName, DebeziumChangelogMode changelogMode, Properties dbzProperties, boolean enableParallelRead, int splitSize, int splitMetaGroupSize, int fetchSize, java.time.Duration connectTimeout, int connectMaxRetries, int connectionPoolSize, double distributionFactorUpper, double distributionFactorLower, java.time.Duration heartbeatInterval, StartupOptions startupOptions, String chunkKeyColumn, boolean closeIdleReaders, boolean skipSnapshotBackfill, boolean isScanNewlyAddedTableEnabled, int lsnCommitCheckpointsDelay, boolean assignUnboundedChunkFirst, boolean appendOnly, boolean includePartitionedTables, boolean releaseSnapshotMetadataEnabled)

Uses of StartupOptions in org.apache.flink.cdc.connectors.sqlserver

Methods in org.apache.flink.cdc.connectors.sqlserver with parameters of type StartupOptions

Modifier and Type	Method	Description
SqlServerSource.Builder<T>	SqlServerSource.Builder.startupOptions(StartupOptions startupOptions)	Specifies the startup options.

Uses of StartupOptions in org.apache.flink.cdc.connectors.sqlserver.source

Methods in org.apache.flink.cdc.connectors.sqlserver.source with parameters of type StartupOptions

Modifier and Type	Method	Description
SqlServerSourceBuilder<T>	SqlServerSourceBuilder.startupOptions(StartupOptions startupOptions)	Specifies the startup options.

Uses of StartupOptions in org.apache.flink.cdc.connectors.sqlserver.source.config

Methods in org.apache.flink.cdc.connectors.sqlserver.source.config with parameters of type StartupOptions

Modifier and Type	Method	Description
SqlServerSourceConfigFactory	SqlServerSourceConfigFactory.startupOptions(StartupOptions startupOptions)

Constructors in org.apache.flink.cdc.connectors.sqlserver.source.config with parameters of type StartupOptions

Constructor

Description

SqlServerSourceConfig(StartupOptions startupOptions, List<String> databaseList, List<String> tableList, int splitSize, int splitMetaGroupSize, double distributionFactorUpper, double distributionFactorLower, boolean includeSchemaChanges, boolean closeIdleReaders, Properties dbzProperties, io.debezium.config.Configuration dbzConfiguration, String driverClassName, String hostname, int port, String username, String password, int fetchSize, String serverTimeZone, java.time.Duration connectTimeout, int connectMaxRetries, int connectionPoolSize, String chunkKeyColumn, boolean skipSnapshotBackfill, boolean scanNewlyAddedTableEnabled, boolean assignUnboundedChunkFirst, boolean releaseSnapshotMetadataEnabled)

Uses of StartupOptions in org.apache.flink.cdc.connectors.sqlserver.table

Constructors in org.apache.flink.cdc.connectors.sqlserver.table with parameters of type StartupOptions

Constructor

Description

SqlServerTableSource(org.apache.flink.table.catalog.ResolvedSchema physicalSchema, int port, String hostname, String database, String tableName, java.time.ZoneId serverTimeZone, String username, String password, Properties dbzProperties, StartupOptions startupOptions, boolean enableParallelRead, int splitSize, int splitMetaGroupSize, int fetchSize, java.time.Duration connectTimeout, int connectMaxRetries, int connectionPoolSize, double distributionFactorUpper, double distributionFactorLower, String chunkKeyColumn, boolean closeIdleReaders, boolean skipSnapshotBackfill, boolean assignUnboundedChunkFirst, boolean releaseSnapshotMetadataEnabled)