Uses of Class
org.apache.flink.cdc.common.exceptions.SchemaEvolveException

Packages that use SchemaEvolveException

Package	Description
org.apache.flink.cdc.common.exceptions
org.apache.flink.cdc.common.sink
org.apache.flink.cdc.connectors.iceberg.sink
org.apache.flink.cdc.connectors.paimon.sink
org.apache.flink.cdc.connectors.starrocks.sink
org.apache.flink.cdc.connectors.values

Uses of SchemaEvolveException in org.apache.flink.cdc.common.exceptions

Subclasses of SchemaEvolveException in org.apache.flink.cdc.common.exceptions

Modifier and Type	Class	Description
class	UnsupportedSchemaChangeEventException	A special kind of SchemaEvolveException that sink doesn't support such event type.

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

Methods in org.apache.flink.cdc.common.sink that throw SchemaEvolveException

Modifier and Type	Method	Description
void	MetadataApplier.applySchemaChange(SchemaChangeEvent schemaChangeEvent)	Apply the given SchemaChangeEvent to external systems.
Optional<Schema>	ExistingTableSchemaExpansionSupport.getExistingTableSchema(TableId tableId)	Returns the current schema of the target table, or Optional.empty() if the table does not exist.

Uses of SchemaEvolveException in org.apache.flink.cdc.connectors.iceberg.sink

Methods in org.apache.flink.cdc.connectors.iceberg.sink that throw SchemaEvolveException

Modifier and Type	Method	Description
void	IcebergMetadataApplier.applySchemaChange(SchemaChangeEvent schemaChangeEvent)

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

Methods in org.apache.flink.cdc.connectors.paimon.sink that throw SchemaEvolveException

Modifier and Type	Method	Description
void	PaimonMetadataApplier.applySchemaChange(SchemaChangeEvent schemaChangeEvent)

Uses of SchemaEvolveException in org.apache.flink.cdc.connectors.starrocks.sink

Methods in org.apache.flink.cdc.connectors.starrocks.sink that throw SchemaEvolveException

Modifier and Type	Method	Description
void	StarRocksMetadataApplier.applySchemaChange(SchemaChangeEvent schemaChangeEvent)

Uses of SchemaEvolveException in org.apache.flink.cdc.connectors.values

Methods in org.apache.flink.cdc.connectors.values that throw SchemaEvolveException

Modifier and Type	Method	Description
void	ValuesDatabase.ErrorOnChangeMetadataApplier.applySchemaChange(SchemaChangeEvent schemaChangeEvent)