| Package | Description |
|---|---|
| com.ververica.cdc.debezium.table |
| Modifier and Type | Field and Description |
|---|---|
static DeserializationRuntimeConverterFactory |
DeserializationRuntimeConverterFactory.DEFAULT
A user-defined converter factory which always fallback to default converters.
|
| 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.
|
RowDataDebeziumDeserializeSchema.Builder |
RowDataDebeziumDeserializeSchema.Builder.setUserDefinedConverterFactory(DeserializationRuntimeConverterFactory userDefinedConverterFactory) |
Copyright © 2022 The Apache Software Foundation. All rights reserved.