static RowDataDebeziumDeserializeSchema.Builder |
RowDataDebeziumDeserializeSchema.newBuilder() |
|
RowDataDebeziumDeserializeSchema.Builder |
RowDataDebeziumDeserializeSchema.Builder.setAppendOnly(boolean appendOnly) |
|
RowDataDebeziumDeserializeSchema.Builder |
RowDataDebeziumDeserializeSchema.Builder.setChangelogMode(DebeziumChangelogMode changelogMode) |
|
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) |
|