DeserializationRuntimeConverterFactory (flink-cdc-parent 3.8-SNAPSHOT API)

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 Description

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

Method Summary

All Methods Instance Methods Abstract Methods
Modifier and Type	Method	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