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

Class SqlServerSourceBuilder.SqlServerIncrementalSource<T>

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<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:

SqlServerPipelineSource

Enclosing class:

SqlServerSourceBuilder<T>

public static class SqlServerSourceBuilder.SqlServerIncrementalSource<T>
extends JdbcIncrementalSource<T>

The JdbcIncrementalSource implementation for SqlServer.

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

Method Summary

Modifier and Type	Method	Description
static <T> SqlServerSourceBuilder<T>	builder()

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

SqlServerIncrementalSource

public SqlServerIncrementalSource(SqlServerSourceConfigFactory configFactory,
                                  DebeziumDeserializationSchema<T> deserializationSchema,
                                  LsnFactory offsetFactory,
                                  SqlServerDialect dataSourceDialect)

Method Detail

builder

public static <T> SqlServerSourceBuilder<T> builder()