| Package | Description |
|---|---|
| com.ververica.cdc.debezium.table |
| Modifier and Type | Method and Description |
|---|---|
static DeserializationRuntimeConverter |
RowDataDebeziumDeserializeSchema.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.
|
| Modifier and Type | Method and Description |
|---|---|
Optional<DeserializationRuntimeConverter> |
DeserializationRuntimeConverterFactory.createUserDefinedConverter(org.apache.flink.table.types.logical.LogicalType logicalType,
java.time.ZoneId serverTimeZone)
Returns an optional
DeserializationRuntimeConverter. |
Copyright © 2022 The Apache Software Foundation. All rights reserved.