org.apache.flink.cdc.common.sink

接口 MetadataApplier

所有超级接口:

AutoCloseable, Serializable

@PublicEvolving
public interface MetadataApplier
extends Serializable, AutoCloseable

MetadataApplier is used to apply metadata changes to external systems.

方法概要

限定符和类型	方法和说明
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 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.

方法详细资料

applySchemaChange

void applySchemaChange(SchemaChangeEvent schemaChangeEvent)
                throws SchemaEvolveException

Apply the given SchemaChangeEvent to external systems.

抛出:

SchemaEvolveException

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.

指定者:

close 在接口中 AutoCloseable

抛出:

Exception