com.ververica.cdc.debezium.table

Interface DeserializationRuntimeConverterFactory

All Superinterfaces:

Serializable

public interface DeserializationRuntimeConverterFactory
extends Serializable

Factory to create DeserializationRuntimeConverter according to LogicalType. It's usually used to create a user-defined DeserializationRuntimeConverter which has a higher resolve order than default converter.

Field Summary

Fields

Modifier and Type	Field and Description
static DeserializationRuntimeConverterFactory	DEFAULT A user-defined converter factory which always fallback to default converters.

Method Summary

Modifier and Type	Method and Description
Optional<DeserializationRuntimeConverter>	createUserDefinedConverter(org.apache.flink.table.types.logical.LogicalType logicalType, java.time.ZoneId serverTimeZone) Returns an optional DeserializationRuntimeConverter.

Field Detail

DEFAULT

static final DeserializationRuntimeConverterFactory DEFAULT

A user-defined converter factory which always fallback to default converters.

Method Detail

createUserDefinedConverter

Optional<DeserializationRuntimeConverter> createUserDefinedConverter(org.apache.flink.table.types.logical.LogicalType logicalType,
                                                                     java.time.ZoneId serverTimeZone)

Returns an optional DeserializationRuntimeConverter. Returns Optional.empty() if fallback to default converter.

Parameters:

logicalType - the Flink Table & SQL internal datatype to be converted from objects of Debezium

serverTimeZone - TimeZone used to convert data with timestamp type