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