| Package | Description |
|---|---|
| com.ververica.cdc.debezium.table |
| Modifier and Type | Method and Description |
|---|---|
static RowDataDebeziumDeserializeSchema.Builder |
RowDataDebeziumDeserializeSchema.newBuilder()
Returns a builder to build
RowDataDebeziumDeserializeSchema. |
RowDataDebeziumDeserializeSchema.Builder |
RowDataDebeziumDeserializeSchema.Builder.setMetadataConverters(MetadataConverter[] metadataConverters) |
RowDataDebeziumDeserializeSchema.Builder |
RowDataDebeziumDeserializeSchema.Builder.setPhysicalRowType(org.apache.flink.table.types.logical.RowType physicalRowType) |
RowDataDebeziumDeserializeSchema.Builder |
RowDataDebeziumDeserializeSchema.Builder.setResultTypeInfo(org.apache.flink.api.common.typeinfo.TypeInformation<org.apache.flink.table.data.RowData> resultTypeInfo) |
RowDataDebeziumDeserializeSchema.Builder |
RowDataDebeziumDeserializeSchema.Builder.setServerTimeZone(java.time.ZoneId serverTimeZone) |
RowDataDebeziumDeserializeSchema.Builder |
RowDataDebeziumDeserializeSchema.Builder.setUserDefinedConverterFactory(DeserializationRuntimeConverterFactory userDefinedConverterFactory) |
RowDataDebeziumDeserializeSchema.Builder |
RowDataDebeziumDeserializeSchema.Builder.setValueValidator(RowDataDebeziumDeserializeSchema.ValueValidator validator) |
Copyright © 2022 The Apache Software Foundation. All rights reserved.