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

Interface TiKVDeserializationRuntimeConverter

All Superinterfaces:

Serializable

Functional Interface:

This is a functional interface and can therefore be used as the assignment target for a lambda expression or method reference.

@FunctionalInterface
public interface TiKVDeserializationRuntimeConverter
extends Serializable

Runtime converter that converts objects of TiKV into objects of Flink Table & SQL internal data structures.

Method Summary

Modifier and Type	Method	Description
Object	convert(Object object, org.tikv.common.meta.TiTableInfo tableInfo, org.tikv.common.types.DataType dataType)

Method Detail

convert

Object convert(Object object,
               org.tikv.common.meta.TiTableInfo tableInfo,
               org.tikv.common.types.DataType dataType)
        throws Exception

Throws:

Exception