Package org.apache.flink.cdc.debezium.table

Class RowDataDebeziumDeserializeSchema.Builder

java.lang.Object

org.apache.flink.cdc.debezium.table.RowDataDebeziumDeserializeSchema.Builder

Enclosing class:

RowDataDebeziumDeserializeSchema

public static class RowDataDebeziumDeserializeSchema.Builder
extends Object

Builder of RowDataDebeziumDeserializeSchema.

Constructor Summary

Constructors

Constructor	Description
Builder()

Method Summary

Modifier and Type	Method	Description
RowDataDebeziumDeserializeSchema	build()
RowDataDebeziumDeserializeSchema.Builder	setAppendOnly(boolean appendOnly)
RowDataDebeziumDeserializeSchema.Builder	setChangelogMode(DebeziumChangelogMode changelogMode)
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)

setChangelogMode

public RowDataDebeziumDeserializeSchema.Builder setChangelogMode(DebeziumChangelogMode changelogMode)

setAppendOnly

public RowDataDebeziumDeserializeSchema.Builder setAppendOnly(boolean appendOnly)

build

public RowDataDebeziumDeserializeSchema build()