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

Class TiKVMetadataConverter.TiKVRowValue

java.lang.Object

org.apache.flink.cdc.connectors.tidb.table.TiKVMetadataConverter.TiKVRowValue

Enclosing interface:

TiKVMetadataConverter

public static class TiKVMetadataConverter.TiKVRowValue
extends Object

TiKV Row Value.

Field Summary

Fields

Modifier and Type	Field	Description
boolean	isSnapshotRecord
org.tikv.kvproto.Kvrpcpb.KvPair	kvPair
org.tikv.kvproto.Cdcpb.Event.Row	row

Constructor Summary

Constructors

Constructor	Description
TiKVRowValue(org.tikv.kvproto.Cdcpb.Event.Row row)
TiKVRowValue(org.tikv.kvproto.Kvrpcpb.KvPair kvPair)

Method Summary

Methods inherited from class java.lang.Object

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

Field Detail

isSnapshotRecord

public boolean isSnapshotRecord

kvPair

public org.tikv.kvproto.Kvrpcpb.KvPair kvPair

row

public org.tikv.kvproto.Cdcpb.Event.Row row

Constructor Detail

TiKVRowValue

public TiKVRowValue(org.tikv.kvproto.Kvrpcpb.KvPair kvPair)

TiKVRowValue

public TiKVRowValue(org.tikv.kvproto.Cdcpb.Event.Row row)