Package org.apache.flink.cdc.connectors.sqlserver.source

Class SqlServerPipelineSource

java.lang.Object

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

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

org.apache.flink.cdc.connectors.sqlserver.source.SqlServerSourceBuilder.SqlServerIncrementalSource<Event>

org.apache.flink.cdc.connectors.sqlserver.source.SqlServerPipelineSource

All Implemented Interfaces:

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

@Internal
public class SqlServerPipelineSource
extends SqlServerSourceBuilder.SqlServerIncrementalSource<Event>

The SQL Server CDC Source for Pipeline connector, which supports parallel reading snapshot of table and then continue to capture data change from transaction log.

This source extends SqlServerSourceBuilder.SqlServerIncrementalSource and overrides the record emitter to use SqlServerPipelineRecordEmitter for proper handling of schema events in the CDC pipeline.

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
SqlServerPipelineSource(SqlServerSourceConfigFactory configFactory, DebeziumDeserializationSchema<Event> deserializationSchema, LsnFactory offsetFactory, SqlServerDialect dataSourceDialect)

Method Summary

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

Methods inherited from class org.apache.flink.cdc.connectors.sqlserver.source.SqlServerSourceBuilder.SqlServerIncrementalSource

builder

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

createEnumerator, createReader, 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

SqlServerPipelineSource

public SqlServerPipelineSource(SqlServerSourceConfigFactory configFactory,
                               DebeziumDeserializationSchema<Event> deserializationSchema,
                               LsnFactory offsetFactory,
                               SqlServerDialect dataSourceDialect)

Method Detail

createRecordEmitter

protected org.apache.flink.connector.base.source.reader.RecordEmitter<SourceRecords,Event,SourceSplitState> createRecordEmitter(SourceConfig sourceConfig,
                                                                                                                                            SourceReaderMetrics sourceReaderMetrics)

Overrides:

createRecordEmitter in class IncrementalSource<Event,JdbcSourceConfig>