Uses of Interface
org.apache.flink.cdc.connectors.base.dialect.DataSourceDialect

Packages that use DataSourceDialect

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

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

Subinterfaces of DataSourceDialect in org.apache.flink.cdc.connectors.base.dialect

Modifier and Type	Interface	Description
interface	JdbcDataSourceDialect	The dialect of JDBC data source.

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

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

Modifier and Type	Field	Description
protected DataSourceDialect<C>	IncrementalSource.dataSourceDialect

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

Constructor	Description
IncrementalSource(SourceConfig.Factory<C> configFactory, DebeziumDeserializationSchema<T> deserializationSchema, OffsetFactory offsetFactory, DataSourceDialect<C> dataSourceDialect)

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

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

Constructor	Description
HybridSplitAssigner(C sourceConfig, int currentParallelism, List<io.debezium.relational.TableId> remainingTables, boolean isTableIdCaseSensitive, DataSourceDialect<C> dialect, OffsetFactory offsetFactory, org.apache.flink.api.connector.source.SplitEnumeratorContext<? extends org.apache.flink.api.connector.source.SourceSplit> enumeratorContext)
HybridSplitAssigner(C sourceConfig, int currentParallelism, HybridPendingSplitsState checkpoint, DataSourceDialect<C> dialect, OffsetFactory offsetFactory, org.apache.flink.api.connector.source.SplitEnumeratorContext<? extends org.apache.flink.api.connector.source.SourceSplit> enumeratorContext)
SnapshotSplitAssigner(C sourceConfig, int currentParallelism, List<io.debezium.relational.TableId> remainingTables, boolean isTableIdCaseSensitive, DataSourceDialect<C> dialect, OffsetFactory offsetFactory)
SnapshotSplitAssigner(C sourceConfig, int currentParallelism, SnapshotPendingSplitsState checkpoint, DataSourceDialect<C> dialect, OffsetFactory offsetFactory)
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 DataSourceDialect in org.apache.flink.cdc.connectors.base.source.reader

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

Modifier and Type	Field	Description
protected DataSourceDialect<C>	IncrementalSourceReader.dialect

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

Constructor	Description
IncrementalSourceReader(org.apache.flink.connector.base.source.reader.synchronization.FutureCompletingBlockingQueue<org.apache.flink.connector.base.source.reader.RecordsWithSplitIds<SourceRecords>> elementQueue, java.util.function.Supplier<IncrementalSourceSplitReader<C>> splitReaderSupplier, org.apache.flink.connector.base.source.reader.RecordEmitter<SourceRecords,T,SourceSplitState> recordEmitter, org.apache.flink.configuration.Configuration config, IncrementalSourceReaderContext incrementalSourceReaderContext, C sourceConfig, SourceSplitSerializer sourceSplitSerializer, DataSourceDialect<C> dialect)
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)
IncrementalSourceSplitReader(int subtaskId, DataSourceDialect<C> dataSourceDialect, C sourceConfig, IncrementalSourceReaderContext context, SnapshotPhaseHooks snapshotHooks)

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

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

Modifier and Type	Method	Description
DataSourceDialect	FetchTask.Context.getDataSourceDialect()

Uses of DataSourceDialect in org.apache.flink.cdc.connectors.db2.source.dialect

Classes in org.apache.flink.cdc.connectors.db2.source.dialect that implement DataSourceDialect

Modifier and Type	Class	Description
class	Db2Dialect	The JdbcDataSourceDialect implementation for Db2 datasource.

Uses of DataSourceDialect in org.apache.flink.cdc.connectors.mongodb.source.dialect

Classes in org.apache.flink.cdc.connectors.mongodb.source.dialect that implement DataSourceDialect

Modifier and Type	Class	Description
class	MongoDBDialect	The DataSourceDialect implementation for MongoDB datasource.

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

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

Modifier and Type	Class	Description
class	OracleDialect	The JdbcDataSourceDialect implementation for Oracle datasource.

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

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

Modifier and Type	Class	Description
class	PostgresDialect	The dialect for Postgres.

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

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

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 DataSourceDialect in org.apache.flink.cdc.connectors.sqlserver.source.dialect

Classes in org.apache.flink.cdc.connectors.sqlserver.source.dialect that implement DataSourceDialect

Modifier and Type	Class	Description
class	SqlServerDialect	The JdbcDataSourceDialect implementation for SqlServer datasource.