Uses of Interface
org.apache.flink.cdc.connectors.base.config.SourceConfig

Packages that use SourceConfig

Package	Description
org.apache.flink.cdc.connectors.base.config
org.apache.flink.cdc.connectors.base.dialect
org.apache.flink.cdc.connectors.base.relational.connection
org.apache.flink.cdc.connectors.base.source
org.apache.flink.cdc.connectors.base.source.assigner
org.apache.flink.cdc.connectors.base.source.enumerator
org.apache.flink.cdc.connectors.base.source.reader
org.apache.flink.cdc.connectors.base.source.reader.external
org.apache.flink.cdc.connectors.db2.source.config
org.apache.flink.cdc.connectors.mongodb.source
org.apache.flink.cdc.connectors.mongodb.source.config
org.apache.flink.cdc.connectors.oracle.source.config
org.apache.flink.cdc.connectors.oracle.source.reader
org.apache.flink.cdc.connectors.postgres.source
org.apache.flink.cdc.connectors.postgres.source.config
org.apache.flink.cdc.connectors.postgres.source.reader
org.apache.flink.cdc.connectors.sqlserver.source
org.apache.flink.cdc.connectors.sqlserver.source.config

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

Classes in org.apache.flink.cdc.connectors.base.config with type parameters of type SourceConfig

Modifier and Type	Interface	Description
static interface	SourceConfig.Factory<C extends SourceConfig>	Factory for the SourceConfig.

Classes in org.apache.flink.cdc.connectors.base.config that implement SourceConfig

Modifier and Type	Class	Description
class	BaseSourceConfig	A basic Source configuration which is used by IncrementalSource.
class	JdbcSourceConfig	A Source configuration which is used by IncrementalSource which used JDBC data source.

Uses of SourceConfig in org.apache.flink.cdc.connectors.base.dialect

Classes in org.apache.flink.cdc.connectors.base.dialect with type parameters of type SourceConfig

Modifier and Type	Interface	Description
interface	DataSourceDialect<C extends SourceConfig>	The dialect of data source.

Uses of SourceConfig in org.apache.flink.cdc.connectors.base.relational.connection

Classes in org.apache.flink.cdc.connectors.base.relational.connection with type parameters of type SourceConfig

Modifier and Type	Interface	Description
interface	ConnectionPools<P,C extends SourceConfig>	A pool collection that consists of multiple connection pools.

Uses of SourceConfig in org.apache.flink.cdc.connectors.base.source

Classes in org.apache.flink.cdc.connectors.base.source with type parameters of type SourceConfig

Modifier and Type	Class	Description
class	IncrementalSource<T,C extends SourceConfig>	The basic source of Incremental Snapshot framework for datasource, it is based on FLIP-27 and Watermark Signal Algorithm which supports parallel reading snapshot of table and then continue to capture data change by streaming reading.

Methods in org.apache.flink.cdc.connectors.base.source with parameters of type SourceConfig

Modifier and Type	Method	Description
protected org.apache.flink.connector.base.source.reader.RecordEmitter<SourceRecords,T,SourceSplitState>	IncrementalSource.createRecordEmitter(SourceConfig sourceConfig, SourceReaderMetrics sourceReaderMetrics)

Uses of SourceConfig in org.apache.flink.cdc.connectors.base.source.assigner

Classes in org.apache.flink.cdc.connectors.base.source.assigner with type parameters of type SourceConfig

Modifier and Type	Class	Description
class	HybridSplitAssigner<C extends SourceConfig>	Assigner for Hybrid split which contains snapshot splits and stream splits.
class	SnapshotSplitAssigner<C extends SourceConfig>	Assigner for snapshot split.

Constructors in org.apache.flink.cdc.connectors.base.source.assigner with parameters of type SourceConfig

Constructor	Description
StreamSplitAssigner(SourceConfig sourceConfig, DataSourceDialect dialect, OffsetFactory offsetFactory, org.apache.flink.api.connector.source.SplitEnumeratorContext<? extends org.apache.flink.api.connector.source.SourceSplit> enumeratorContext)
StreamSplitAssigner(SourceConfig sourceConfig, StreamPendingSplitsState checkpoint, DataSourceDialect dialect, OffsetFactory offsetFactory, org.apache.flink.api.connector.source.SplitEnumeratorContext<? extends org.apache.flink.api.connector.source.SourceSplit> enumeratorContext)

Uses of SourceConfig in org.apache.flink.cdc.connectors.base.source.enumerator

Constructors in org.apache.flink.cdc.connectors.base.source.enumerator with parameters of type SourceConfig

Constructor	Description
IncrementalSourceEnumerator(org.apache.flink.api.connector.source.SplitEnumeratorContext<SourceSplitBase> context, SourceConfig sourceConfig, SplitAssigner splitAssigner, org.apache.flink.api.connector.source.Boundedness boundedness)

Uses of SourceConfig in org.apache.flink.cdc.connectors.base.source.reader

Classes in org.apache.flink.cdc.connectors.base.source.reader with type parameters of type SourceConfig

Modifier and Type	Class	Description
class	IncrementalSourceReader<T,C extends SourceConfig>	The multi-parallel source reader for table snapshot phase from SnapshotSplit and then single-parallel source reader for table stream phase from StreamSplit.
class	IncrementalSourceSplitReader<C extends SourceConfig>	Basic class read SourceSplitBase and return SourceRecord.

Fields in org.apache.flink.cdc.connectors.base.source.reader declared as SourceConfig

Modifier and Type	Field	Description
protected C	IncrementalSourceReader.sourceConfig

Constructors in org.apache.flink.cdc.connectors.base.source.reader with parameters of type SourceConfig

Constructor

Description

IncrementalSourceReaderWithCommit(org.apache.flink.connector.base.source.reader.synchronization.FutureCompletingBlockingQueue elementQueue, java.util.function.Supplier supplier, org.apache.flink.connector.base.source.reader.RecordEmitter recordEmitter, org.apache.flink.configuration.Configuration config, IncrementalSourceReaderContext incrementalSourceReaderContext, SourceConfig sourceConfig, SourceSplitSerializer sourceSplitSerializer, DataSourceDialect dialect)

Uses of SourceConfig in org.apache.flink.cdc.connectors.base.source.reader.external

Methods in org.apache.flink.cdc.connectors.base.source.reader.external that return SourceConfig

Modifier and Type	Method	Description
SourceConfig	FetchTask.Context.getSourceConfig()
SourceConfig	JdbcSourceFetchTaskContext.getSourceConfig()

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

Classes in org.apache.flink.cdc.connectors.db2.source.config that implement SourceConfig

Modifier and Type	Class	Description
class	Db2SourceConfig	Describes the connection information of the Db2 database and the configuration information for performing snapshotting and streaming reading, such as splitSize.

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

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

Modifier and Type	Method	Description
protected org.apache.flink.connector.base.source.reader.RecordEmitter<SourceRecords,T,SourceSplitState>	MongoDBSource.createRecordEmitter(SourceConfig sourceConfig, SourceReaderMetrics sourceReaderMetrics)

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

Classes in org.apache.flink.cdc.connectors.mongodb.source.config that implement SourceConfig

Modifier and Type	Class	Description
class	MongoDBSourceConfig	A MongoDB Source configuration which is used by MongoDBSource.

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

Classes in org.apache.flink.cdc.connectors.oracle.source.config that implement SourceConfig

Modifier and Type	Class	Description
class	OracleSourceConfig	Describes the connection information of the Oracle database and the configuration information for performing snapshotting and streaming reading, such as splitSize.

Uses of SourceConfig in org.apache.flink.cdc.connectors.oracle.source.reader

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

Modifier and Type	Method	Description
protected org.apache.flink.connector.base.source.reader.RecordEmitter<SourceRecords,Event,SourceSplitState>	OracleTableSourceReader.createRecordEmitter(SourceConfig sourceConfig, SourceReaderMetrics sourceReaderMetrics)

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

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

Modifier and Type	Method	Description
protected org.apache.flink.connector.base.source.reader.RecordEmitter<SourceRecords,T,SourceSplitState>	PostgresDataSource.PostgresPipelineSource.createRecordEmitter(SourceConfig sourceConfig, SourceReaderMetrics sourceReaderMetrics)
protected org.apache.flink.connector.base.source.reader.RecordEmitter<SourceRecords,T,SourceSplitState>	PostgresSourceBuilder.PostgresIncrementalSource.createRecordEmitter(SourceConfig sourceConfig, SourceReaderMetrics sourceReaderMetrics)

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

Classes in org.apache.flink.cdc.connectors.postgres.source.config that implement SourceConfig

Modifier and Type	Class	Description
class	PostgresSourceConfig	The configuration for Postgres CDC source.

Uses of SourceConfig in org.apache.flink.cdc.connectors.postgres.source.reader

Constructors in org.apache.flink.cdc.connectors.postgres.source.reader with parameters of type SourceConfig

Constructor

Description

PostgresSourceReader(org.apache.flink.connector.base.source.reader.synchronization.FutureCompletingBlockingQueue elementQueue, java.util.function.Supplier supplier, org.apache.flink.connector.base.source.reader.RecordEmitter recordEmitter, org.apache.flink.configuration.Configuration config, IncrementalSourceReaderContext incrementalSourceReaderContext, SourceConfig sourceConfig, SourceSplitSerializer sourceSplitSerializer, DataSourceDialect dialect)

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

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

Modifier and Type	Method	Description
protected org.apache.flink.connector.base.source.reader.RecordEmitter<SourceRecords,Event,SourceSplitState>	SqlServerPipelineSource.createRecordEmitter(SourceConfig sourceConfig, SourceReaderMetrics sourceReaderMetrics)

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

Classes in org.apache.flink.cdc.connectors.sqlserver.source.config that implement SourceConfig

Modifier and Type	Class	Description
class	SqlServerSourceConfig	Describes the connection information of the SQL Server database and the configuration information for performing snapshotting and streaming reading, such as splitSize.