com.ververica.cdc.debezium.table

Class RowDataDebeziumDeserializeSchema

java.lang.Object

com.ververica.cdc.debezium.table.RowDataDebeziumDeserializeSchema

All Implemented Interfaces:

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

public final class RowDataDebeziumDeserializeSchema
extends Object
implements DebeziumDeserializationSchema<org.apache.flink.table.data.RowData>

Deserialization schema from Debezium object to Flink Table/SQL internal data structure RowData.

See Also:

Serialized Form

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
static class	RowDataDebeziumDeserializeSchema.Builder Builder of RowDataDebeziumDeserializeSchema.
static interface	RowDataDebeziumDeserializeSchema.ValueValidator Custom validator to validate the row value.

Method Summary

Modifier and Type	Method and Description
static DeserializationRuntimeConverter	createNotNullConverter(org.apache.flink.table.types.logical.LogicalType type, java.time.ZoneId serverTimeZone, DeserializationRuntimeConverterFactory userDefinedConverterFactory) Creates a runtime converter which assuming input object is not null.
void	deserialize(org.apache.kafka.connect.source.SourceRecord record, org.apache.flink.util.Collector<org.apache.flink.table.data.RowData> out) Deserialize the Debezium record, it is represented in Kafka SourceRecord.
org.apache.flink.api.common.typeinfo.TypeInformation<org.apache.flink.table.data.RowData>	getProducedType()
static RowDataDebeziumDeserializeSchema.Builder	newBuilder() Returns a builder to build RowDataDebeziumDeserializeSchema.

Methods inherited from class java.lang.Object

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

Method Detail

newBuilder

public static RowDataDebeziumDeserializeSchema.Builder newBuilder()

Returns a builder to build RowDataDebeziumDeserializeSchema.

deserialize

public void deserialize(org.apache.kafka.connect.source.SourceRecord record,
                        org.apache.flink.util.Collector<org.apache.flink.table.data.RowData> out)
                 throws Exception

Description copied from interface: DebeziumDeserializationSchema

Deserialize the Debezium record, it is represented in Kafka SourceRecord.

Specified by:

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

Throws:

Exception

getProducedType

public org.apache.flink.api.common.typeinfo.TypeInformation<org.apache.flink.table.data.RowData> getProducedType()

Specified by:

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

createNotNullConverter

public static DeserializationRuntimeConverter createNotNullConverter(org.apache.flink.table.types.logical.LogicalType type,
                                                                     java.time.ZoneId serverTimeZone,
                                                                     DeserializationRuntimeConverterFactory userDefinedConverterFactory)

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