Package org.apache.flink.cdc.connectors.tidb

Interface TiKVChangeEventDeserializationSchema<T>

  • Type Parameters:
    T - The type created by the deserialization schema.
    All Superinterfaces:
    org.apache.flink.api.java.typeutils.ResultTypeQueryable<T>, Serializable
    All Known Implementing Classes:
    RowDataTiKVChangeEventDeserializationSchema
    @PublicEvolving
public interface TiKVChangeEventDeserializationSchema<T>
extends Serializable, org.apache.flink.api.java.typeutils.ResultTypeQueryable<T>
    The deserialization schema describes how to turn the TiKV Change Event into data types (Java/Scala objects) that are processed by Flink.

    • Method Summary

      All Methods Instance Methods Abstract Methods 
      Modifier and Type Method Description
      void deserialize​(org.tikv.kvproto.Cdcpb.Event.Row record, org.apache.flink.util.Collector<T> out)
      Deserialize the TiDB record.

      • Methods inherited from interface org.apache.flink.api.java.typeutils.ResultTypeQueryable

        getProducedType

    • Method Detail

      • deserialize

        void deserialize​(org.tikv.kvproto.Cdcpb.Event.Row record,
                 org.apache.flink.util.Collector<T> out)
          throws Exception
        Deserialize the TiDB record.
        Throws:
        Exception