Package org.apache.flink.cdc.connectors.kafka.json

Class TableSchemaInfo

java.lang.Object

org.apache.flink.cdc.connectors.kafka.json.TableSchemaInfo

public class TableSchemaInfo
extends Object

maintain the SerializationSchema of a specific TableId.

Constructor Summary

Constructors

Constructor	Description
TableSchemaInfo(TableId tableId, Schema schema, org.apache.flink.api.common.serialization.SerializationSchema<org.apache.flink.table.data.RowData> serializationSchema, java.time.ZoneId zoneId)

Method Summary

Modifier and Type	Method	Description
org.apache.flink.table.data.RowData	getRowDataFromRecordData(RecordData recordData, boolean primaryKeyOnly)	convert to RowData, which will be pass to serializationSchema.
Schema	getSchema()
org.apache.flink.api.common.serialization.SerializationSchema<org.apache.flink.table.data.RowData>	getSerializationSchema()

Methods inherited from class java.lang.Object

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

Constructor Detail

TableSchemaInfo

public TableSchemaInfo(TableId tableId,
                       Schema schema,
                       org.apache.flink.api.common.serialization.SerializationSchema<org.apache.flink.table.data.RowData> serializationSchema,
                       java.time.ZoneId zoneId)

Method Detail

getRowDataFromRecordData

public org.apache.flink.table.data.RowData getRowDataFromRecordData(RecordData recordData,
                                                                    boolean primaryKeyOnly)

convert to RowData, which will be pass to serializationSchema.

getSchema

public Schema getSchema()

getSerializationSchema

public org.apache.flink.api.common.serialization.SerializationSchema<org.apache.flink.table.data.RowData> getSerializationSchema()