Class TiDBSource
- java.lang.Object
-
- org.apache.flink.cdc.connectors.tidb.TiDBSource
-
public class TiDBSource extends Object
A builder to build a SourceFunction which can read snapshot and continue to read CDC events.
-
-
Nested Class Summary
Nested Classes Modifier and Type Class Description static classTiDBSource.Builder<T>Builder class ofTiDBSource.
-
Constructor Summary
Constructors Constructor Description TiDBSource()
-
-
-
Method Detail
-
builder
public static <T> TiDBSource.Builder<T> builder()
-
-