Package org.apache.flink.cdc.connectors.kafka.sink

Class KafkaMetaDataApplier

java.lang.Object

org.apache.flink.cdc.connectors.kafka.sink.KafkaMetaDataApplier

All Implemented Interfaces:

Serializable, AutoCloseable, MetadataApplier

public class KafkaMetaDataApplier
extends Object
implements MetadataApplier

Supports KafkaDataSink to schema evolution.

See Also:

Serialized Form

Constructor Summary

Constructors

Constructor	Description
KafkaMetaDataApplier()

Method Summary

Modifier and Type	Method	Description
boolean	acceptsSchemaEvolutionType(SchemaChangeEventType schemaChangeEventType)	Checks if this metadata applier should this event type.
void	applySchemaChange(SchemaChangeEvent schemaChangeEvent)	Apply the given SchemaChangeEvent to external systems.
Set<SchemaChangeEventType>	getSupportedSchemaEvolutionTypes()	Checks what kind of schema change events downstream can handle.
MetadataApplier	setAcceptedSchemaEvolutionTypes(Set<SchemaChangeEventType> schemaEvolutionTypes)	Sets enabled schema evolution event types of current metadata applier.

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Methods inherited from interface org.apache.flink.cdc.common.sink.MetadataApplier

close, getExistingTableSchemaExpansionSupport

Constructor Detail

KafkaMetaDataApplier

public KafkaMetaDataApplier()

Method Detail

setAcceptedSchemaEvolutionTypes

public MetadataApplier setAcceptedSchemaEvolutionTypes(Set<SchemaChangeEventType> schemaEvolutionTypes)

Description copied from interface: MetadataApplier

Sets enabled schema evolution event types of current metadata applier.

Specified by:

setAcceptedSchemaEvolutionTypes in interface MetadataApplier

acceptsSchemaEvolutionType

public boolean acceptsSchemaEvolutionType(SchemaChangeEventType schemaChangeEventType)

Description copied from interface: MetadataApplier

Checks if this metadata applier should this event type.

Specified by:

acceptsSchemaEvolutionType in interface MetadataApplier

getSupportedSchemaEvolutionTypes

public Set<SchemaChangeEventType> getSupportedSchemaEvolutionTypes()

Description copied from interface: MetadataApplier

Checks what kind of schema change events downstream can handle.

Specified by:

getSupportedSchemaEvolutionTypes in interface MetadataApplier

applySchemaChange

public void applySchemaChange(SchemaChangeEvent schemaChangeEvent)

Description copied from interface: MetadataApplier

Apply the given SchemaChangeEvent to external systems.

Specified by:

applySchemaChange in interface MetadataApplier