Package org.apache.flink.cdc.connectors.base.source.jdbc

Class JdbcIncrementalSource<T>

java.lang.Object

org.apache.flink.cdc.connectors.base.source.IncrementalSource<T,JdbcSourceConfig>

org.apache.flink.cdc.connectors.base.source.jdbc.JdbcIncrementalSource<T>

All Implemented Interfaces:

Serializable, org.apache.flink.api.connector.source.Source<T,SourceSplitBase,PendingSplitsState>, org.apache.flink.api.connector.source.SourceReaderFactory<T,SourceSplitBase>, org.apache.flink.api.java.typeutils.ResultTypeQueryable<T>

Direct Known Subclasses:

Db2SourceBuilder.Db2IncrementalSource, OracleSourceBuilder.OracleIncrementalSource, PostgresSourceBuilder.PostgresIncrementalSource, SqlServerSourceBuilder.SqlServerIncrementalSource

public class JdbcIncrementalSource<T>
extends IncrementalSource<T,JdbcSourceConfig>

The basic source of Incremental Snapshot framework for JDBC 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.

See Also:

Serialized Form

Field Summary

Fields inherited from class org.apache.flink.cdc.connectors.base.source.IncrementalSource

configFactory, dataSourceDialect, deserializationSchema, offsetFactory, snapshotHooks, sourceSplitSerializer

Constructor Summary

Constructors

Constructor	Description
JdbcIncrementalSource(JdbcSourceConfigFactory configFactory, DebeziumDeserializationSchema<T> deserializationSchema, OffsetFactory offsetFactory, JdbcDataSourceDialect dataSourceDialect)

Method Summary

Methods inherited from class org.apache.flink.cdc.connectors.base.source.IncrementalSource

createEnumerator, createReader, createRecordEmitter, getBoundedness, getEnumeratorCheckpointSerializer, getProducedType, getSplitSerializer, restoreEnumerator, setSnapshotHooks

Methods inherited from class java.lang.Object

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

Constructor Detail

JdbcIncrementalSource

public JdbcIncrementalSource(JdbcSourceConfigFactory configFactory,
                             DebeziumDeserializationSchema<T> deserializationSchema,
                             OffsetFactory offsetFactory,
                             JdbcDataSourceDialect dataSourceDialect)