Uses of Interface
org.apache.flink.cdc.connectors.tidb.TiKVSnapshotEventDeserializationSchema
-
Packages that use TiKVSnapshotEventDeserializationSchema Package Description org.apache.flink.cdc.connectors.tidb org.apache.flink.cdc.connectors.tidb.table -
-
Uses of TiKVSnapshotEventDeserializationSchema in org.apache.flink.cdc.connectors.tidb
Methods in org.apache.flink.cdc.connectors.tidb with parameters of type TiKVSnapshotEventDeserializationSchema Modifier and Type Method Description TiDBSource.Builder<T>TiDBSource.Builder. snapshotEventDeserializer(TiKVSnapshotEventDeserializationSchema<T> snapshotEventDeserializationSchema)The deserializer used to convert from consumed snapshot event from TiKV.Constructors in org.apache.flink.cdc.connectors.tidb with parameters of type TiKVSnapshotEventDeserializationSchema Constructor Description TiKVRichParallelSourceFunction(TiKVSnapshotEventDeserializationSchema<T> snapshotEventDeserializationSchema, TiKVChangeEventDeserializationSchema<T> changeEventDeserializationSchema, org.tikv.common.TiConfiguration tiConf, StartupMode startupMode, String database, String tableName) -
Uses of TiKVSnapshotEventDeserializationSchema in org.apache.flink.cdc.connectors.tidb.table
Classes in org.apache.flink.cdc.connectors.tidb.table that implement TiKVSnapshotEventDeserializationSchema Modifier and Type Class Description classRowDataTiKVSnapshotEventDeserializationSchemaDeserialization schema from TiKV Snapshot Event to Flink Table/SQL internal data structureRowData.
-