com.ververica.cdc.debezium.table

Class RowDataDebeziumDeserializeSchema.Builder

java.lang.Object

com.ververica.cdc.debezium.table.RowDataDebeziumDeserializeSchema.Builder

Enclosing class:

RowDataDebeziumDeserializeSchema

public static class RowDataDebeziumDeserializeSchema.Builder
extends Object

Builder of RowDataDebeziumDeserializeSchema.

Constructor Summary

Constructors

Constructor and Description
Builder()

Method Summary

Modifier and Type	Method and Description
RowDataDebeziumDeserializeSchema	build()
RowDataDebeziumDeserializeSchema.Builder	setMetadataConverters(MetadataConverter[] metadataConverters)
RowDataDebeziumDeserializeSchema.Builder	setPhysicalRowType(org.apache.flink.table.types.logical.RowType physicalRowType)
RowDataDebeziumDeserializeSchema.Builder	setResultTypeInfo(org.apache.flink.api.common.typeinfo.TypeInformation<org.apache.flink.table.data.RowData> resultTypeInfo)
RowDataDebeziumDeserializeSchema.Builder	setServerTimeZone(java.time.ZoneId serverTimeZone)
RowDataDebeziumDeserializeSchema.Builder	setUserDefinedConverterFactory(DeserializationRuntimeConverterFactory userDefinedConverterFactory)
RowDataDebeziumDeserializeSchema.Builder	setValueValidator(RowDataDebeziumDeserializeSchema.ValueValidator validator)

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

Builder

public Builder()

Method Detail

setPhysicalRowType

public RowDataDebeziumDeserializeSchema.Builder setPhysicalRowType(org.apache.flink.table.types.logical.RowType physicalRowType)

setMetadataConverters

public RowDataDebeziumDeserializeSchema.Builder setMetadataConverters(MetadataConverter[] metadataConverters)

setResultTypeInfo

public RowDataDebeziumDeserializeSchema.Builder setResultTypeInfo(org.apache.flink.api.common.typeinfo.TypeInformation<org.apache.flink.table.data.RowData> resultTypeInfo)

setValueValidator

public RowDataDebeziumDeserializeSchema.Builder setValueValidator(RowDataDebeziumDeserializeSchema.ValueValidator validator)

setServerTimeZone

public RowDataDebeziumDeserializeSchema.Builder setServerTimeZone(java.time.ZoneId serverTimeZone)

setUserDefinedConverterFactory

public RowDataDebeziumDeserializeSchema.Builder setUserDefinedConverterFactory(DeserializationRuntimeConverterFactory userDefinedConverterFactory)

build

public RowDataDebeziumDeserializeSchema build()