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

Class RowDataTiKVEventDeserializationSchemaBase

java.lang.Object

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

All Implemented Interfaces:

Serializable

Direct Known Subclasses:

RowDataTiKVChangeEventDeserializationSchema, RowDataTiKVSnapshotEventDeserializationSchema

public class RowDataTiKVEventDeserializationSchemaBase
extends Object
implements Serializable

Base class of deserialization schema from TiKV RowValue (Snapshot or Change Event) to Flink Table/SQL internal data structure RowData.

See Also:

Serialized Form

Field Summary

Fields

Modifier and Type	Field	Description
protected TiKVDeserializationRuntimeConverter	physicalConverter	Runtime converter that converts Tikv Kvrpcpb.KvPairs into RowData consisted of physical column values.
protected org.tikv.common.meta.TiTableInfo	tableInfo	Information of the TiKV table.

Constructor Summary

Constructors

Constructor	Description
RowDataTiKVEventDeserializationSchemaBase(org.tikv.common.TiConfiguration tiConf, String database, String tableName, TiKVMetadataConverter[] metadataConverters, org.apache.flink.table.types.logical.RowType physicalDataType)

Method Summary

Modifier and Type	Method	Description
protected static TiKVDeserializationRuntimeConverter	createConverter(org.apache.flink.table.types.logical.LogicalType type)	Creates a runtime converter which is null safe.
static TiKVDeserializationRuntimeConverter	createNotNullConverter(org.apache.flink.table.types.logical.LogicalType type)	Creates a runtime converter which assuming input object is not null.
static Object	dealUnsignedColumnValue(org.tikv.common.types.DataType dataType, Object object)	Deal with unsigned column's value.
void	emit(TiKVMetadataConverter.TiKVRowValue inRecord, org.apache.flink.table.data.RowData physicalRow, org.apache.flink.util.Collector<org.apache.flink.table.data.RowData> collector)
protected org.tikv.common.meta.TiTableInfo	fetchTableInfo()

Methods inherited from class java.lang.Object

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

Field Detail

tableInfo

protected org.tikv.common.meta.TiTableInfo tableInfo

Information of the TiKV table. *

physicalConverter

protected final TiKVDeserializationRuntimeConverter physicalConverter

Runtime converter that converts Tikv Kvrpcpb.KvPairs into RowData consisted of physical column values.

Constructor Detail

RowDataTiKVEventDeserializationSchemaBase

public RowDataTiKVEventDeserializationSchemaBase(org.tikv.common.TiConfiguration tiConf,
                                                 String database,
                                                 String tableName,
                                                 TiKVMetadataConverter[] metadataConverters,
                                                 org.apache.flink.table.types.logical.RowType physicalDataType)

Method Detail

fetchTableInfo

protected org.tikv.common.meta.TiTableInfo fetchTableInfo()

emit

public void emit(TiKVMetadataConverter.TiKVRowValue inRecord,
                 org.apache.flink.table.data.RowData physicalRow,
                 org.apache.flink.util.Collector<org.apache.flink.table.data.RowData> collector)

createConverter

protected static TiKVDeserializationRuntimeConverter createConverter(org.apache.flink.table.types.logical.LogicalType type)

Creates a runtime converter which is null safe.

createNotNullConverter

public static TiKVDeserializationRuntimeConverter createNotNullConverter(org.apache.flink.table.types.logical.LogicalType type)

Creates a runtime converter which assuming input object is not null.

dealUnsignedColumnValue

public static Object dealUnsignedColumnValue(org.tikv.common.types.DataType dataType,
                                             Object object)

Deal with unsigned column's value.