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

Class RowDataTiKVChangeEventDeserializationSchema

java.lang.Object

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

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

All Implemented Interfaces:

Serializable, org.apache.flink.api.java.typeutils.ResultTypeQueryable<org.apache.flink.table.data.RowData>, TiKVChangeEventDeserializationSchema<org.apache.flink.table.data.RowData>

public class RowDataTiKVChangeEventDeserializationSchema
extends RowDataTiKVEventDeserializationSchemaBase
implements TiKVChangeEventDeserializationSchema<org.apache.flink.table.data.RowData>

Deserialization schema from TiKV Change Event to Flink Table/SQL internal data structure RowData.

See Also:

Serialized Form

Field Summary

Fields inherited from class org.apache.flink.cdc.connectors.tidb.table.RowDataTiKVEventDeserializationSchemaBase

physicalConverter, tableInfo

Constructor Summary

Constructors

Constructor	Description
RowDataTiKVChangeEventDeserializationSchema(org.tikv.common.TiConfiguration tiConf, String database, String tableName, org.apache.flink.api.common.typeinfo.TypeInformation<org.apache.flink.table.data.RowData> resultTypeInfo, TiKVMetadataConverter[] metadataConverters, org.apache.flink.table.types.logical.RowType physicalDataType)

Method Summary

Modifier and Type	Method	Description
void	deserialize(org.tikv.kvproto.Cdcpb.Event.Row row, org.apache.flink.util.Collector<org.apache.flink.table.data.RowData> out)	Deserialize the TiDB record.
org.apache.flink.api.common.typeinfo.TypeInformation	getProducedType()

Methods inherited from class org.apache.flink.cdc.connectors.tidb.table.RowDataTiKVEventDeserializationSchemaBase

createConverter, createNotNullConverter, dealUnsignedColumnValue, emit, fetchTableInfo

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

RowDataTiKVChangeEventDeserializationSchema

public RowDataTiKVChangeEventDeserializationSchema(org.tikv.common.TiConfiguration tiConf,
                                                   String database,
                                                   String tableName,
                                                   org.apache.flink.api.common.typeinfo.TypeInformation<org.apache.flink.table.data.RowData> resultTypeInfo,
                                                   TiKVMetadataConverter[] metadataConverters,
                                                   org.apache.flink.table.types.logical.RowType physicalDataType)

Method Detail

deserialize

public void deserialize(org.tikv.kvproto.Cdcpb.Event.Row row,
                        org.apache.flink.util.Collector<org.apache.flink.table.data.RowData> out)
                 throws Exception

Description copied from interface: TiKVChangeEventDeserializationSchema

Deserialize the TiDB record.

Specified by:

deserialize in interface TiKVChangeEventDeserializationSchema<org.apache.flink.table.data.RowData>

Throws:

Exception

getProducedType

public org.apache.flink.api.common.typeinfo.TypeInformation getProducedType()

Specified by:

getProducedType in interface org.apache.flink.api.java.typeutils.ResultTypeQueryable<org.apache.flink.table.data.RowData>