Uses of Interface
org.apache.flink.cdc.common.sink.ExistingTableSchemaExpansionSupport

Packages that use ExistingTableSchemaExpansionSupport

Package	Description
org.apache.flink.cdc.common.sink
org.apache.flink.cdc.connectors.fluss.sink
org.apache.flink.cdc.connectors.paimon.sink
org.apache.flink.cdc.runtime.operators.schema.common

Uses of ExistingTableSchemaExpansionSupport in org.apache.flink.cdc.common.sink

Methods in org.apache.flink.cdc.common.sink that return types with arguments of type ExistingTableSchemaExpansionSupport

Modifier and Type	Method	Description
default Optional<ExistingTableSchemaExpansionSupport>	MetadataApplier.getExistingTableSchemaExpansionSupport()	Returns optional support for safely expanding an existing target table schema.

Uses of ExistingTableSchemaExpansionSupport in org.apache.flink.cdc.connectors.fluss.sink

Classes in org.apache.flink.cdc.connectors.fluss.sink that implement ExistingTableSchemaExpansionSupport

Modifier and Type	Class	Description
class	FlussMetaDataApplier	MetadataApplier for fluss.

Methods in org.apache.flink.cdc.connectors.fluss.sink that return types with arguments of type ExistingTableSchemaExpansionSupport

Modifier and Type	Method	Description
Optional<ExistingTableSchemaExpansionSupport>	FlussMetaDataApplier.getExistingTableSchemaExpansionSupport()

Uses of ExistingTableSchemaExpansionSupport in org.apache.flink.cdc.connectors.paimon.sink

Classes in org.apache.flink.cdc.connectors.paimon.sink that implement ExistingTableSchemaExpansionSupport

Modifier and Type	Class	Description
class	PaimonMetadataApplier	A MetadataApplier that applies metadata changes to Paimon.

Methods in org.apache.flink.cdc.connectors.paimon.sink that return types with arguments of type ExistingTableSchemaExpansionSupport

Modifier and Type	Method	Description
Optional<ExistingTableSchemaExpansionSupport>	PaimonMetadataApplier.getExistingTableSchemaExpansionSupport()

Uses of ExistingTableSchemaExpansionSupport in org.apache.flink.cdc.runtime.operators.schema.common

Constructors in org.apache.flink.cdc.runtime.operators.schema.common with parameters of type ExistingTableSchemaExpansionSupport

Constructor	Description
ExistingTableSchemaExpander(MetadataApplier metadataApplier, ExistingTableSchemaExpansionSupport expansionSupport, SchemaChangeBehavior schemaChangeBehavior)
ExistingTableSchemaExpander(MetadataApplier metadataApplier, ExistingTableSchemaExpansionSupport expansionSupport, SchemaChangeBehavior schemaChangeBehavior, ExistingTableSchemaExpansionMode mode)