MetadataApplier (flink-cdc-parent 3.8-SNAPSHOT API)

All Superinterfaces:

AutoCloseable, Serializable

All Known Implementing Classes:

DorisMetadataApplier, FlussMetaDataApplier, HudiMetadataApplier, IcebergMetadataApplier, KafkaMetaDataApplier, MaxComputeMetadataApplier, OceanBaseMetadataApplier, PaimonMetadataApplier, StarRocksMetadataApplier, ValuesDatabase.ErrorOnChangeMetadataApplier, ValuesDatabase.ValuesMetadataApplier
```
@PublicEvolving
public interface MetadataApplier
extends Serializable, AutoCloseable
```
MetadataApplier is used to apply metadata changes to external systems.

Method Summary

All Methods Instance Methods Abstract Methods Default Methods
Modifier and Type	Method	Description
`default boolean`	`acceptsSchemaEvolutionType(SchemaChangeEventType schemaChangeEventType)`	Checks if this metadata applier should this event type.
`void`	`applySchemaChange(SchemaChangeEvent schemaChangeEvent)`	Apply the given `SchemaChangeEvent` to external systems.
`default void`	`close()`	Closes the metadata applier and its underlying resources.
`default Optional<ExistingTableSchemaExpansionSupport>`	`getExistingTableSchemaExpansionSupport()`	Returns optional support for safely expanding an existing target table schema.
`default Set<SchemaChangeEventType>`	`getSupportedSchemaEvolutionTypes()`	Checks what kind of schema change events downstream can handle.
`default MetadataApplier`	`setAcceptedSchemaEvolutionTypes(Set<SchemaChangeEventType> schemaEvolutionTypes)`	Sets enabled schema evolution event types of current metadata applier.

- Method Detail
  - applySchemaChange
```
void applySchemaChange(SchemaChangeEvent schemaChangeEvent)
                throws SchemaEvolveException
```
    Apply the given SchemaChangeEvent to external systems.
    
    Throws:
    
    SchemaEvolveException
  - getExistingTableSchemaExpansionSupport
```
@Experimental
default Optional<ExistingTableSchemaExpansionSupport> getExistingTableSchemaExpansionSupport()
```
    Returns optional support for safely expanding an existing target table schema.
  - setAcceptedSchemaEvolutionTypes
```
default MetadataApplier setAcceptedSchemaEvolutionTypes(Set<SchemaChangeEventType> schemaEvolutionTypes)
```
    Sets enabled schema evolution event types of current metadata applier.
  - acceptsSchemaEvolutionType
```
default boolean acceptsSchemaEvolutionType(SchemaChangeEventType schemaChangeEventType)
```
    Checks if this metadata applier should this event type.
  - getSupportedSchemaEvolutionTypes
```
default Set<SchemaChangeEventType> getSupportedSchemaEvolutionTypes()
```
    Checks what kind of schema change events downstream can handle.
  - close
```
default void close()
            throws Exception
```
    Closes the metadata applier and its underlying resources.
    
    Specified by:
    
    close in interface AutoCloseable
    
    Throws:
    
    Exception