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

Class RowDataTiKVSnapshotEventDeserializationSchema

java.lang.Object

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

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

All Implemented Interfaces:

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

public class RowDataTiKVSnapshotEventDeserializationSchema
extends RowDataTiKVEventDeserializationSchemaBase
implements TiKVSnapshotEventDeserializationSchema<org.apache.flink.table.data.RowData>

Deserialization schema from TiKV Snapshot 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
RowDataTiKVSnapshotEventDeserializationSchema(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.Kvrpcpb.KvPair record, 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

RowDataTiKVSnapshotEventDeserializationSchema

public RowDataTiKVSnapshotEventDeserializationSchema(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

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>

deserialize

public void deserialize(org.tikv.kvproto.Kvrpcpb.KvPair record,
                        org.apache.flink.util.Collector<org.apache.flink.table.data.RowData> out)
                 throws Exception

Description copied from interface: TiKVSnapshotEventDeserializationSchema

Deserialize the TiDB record.

Specified by:

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

Throws:

Exception