Package org.apache.flink.cdc.debezium.table

Class RowDataDebeziumDeserializeSchema

java.lang.Object

org.apache.flink.cdc.debezium.table.RowDataDebeziumDeserializeSchema

All Implemented Interfaces:

Serializable, org.apache.flink.api.java.typeutils.ResultTypeQueryable<org.apache.flink.table.data.RowData>, DebeziumDeserializationSchema<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	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	Description
static DeserializationRuntimeConverter	createConverter(org.apache.flink.table.types.logical.LogicalType type, java.time.ZoneId serverTimeZone, DeserializationRuntimeConverterFactory userDefinedConverterFactory)	Creates a runtime converter which is null safe.
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>

createConverter

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

Creates a runtime converter which is null safe.

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.