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

Class StarRocksMetadataApplier

java.lang.Object

org.apache.flink.cdc.connectors.starrocks.sink.StarRocksMetadataApplier

All Implemented Interfaces:

Serializable, AutoCloseable, MetadataApplier

public class StarRocksMetadataApplier
extends Object
implements MetadataApplier

A MetadataApplier that applies metadata changes to StarRocks.

See Also:

Serialized Form

Constructor Summary

Constructors

Constructor	Description
StarRocksMetadataApplier(StarRocksEnrichedCatalog catalog, TableCreateConfig tableCreateConfig, SchemaChangeConfig schemaChangeConfig)

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

StarRocksMetadataApplier

public StarRocksMetadataApplier(StarRocksEnrichedCatalog catalog,
                                TableCreateConfig tableCreateConfig,
                                SchemaChangeConfig schemaChangeConfig)

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)
                       throws SchemaEvolveException

Description copied from interface: MetadataApplier

Apply the given SchemaChangeEvent to external systems.

Specified by:

applySchemaChange in interface MetadataApplier

Throws:

SchemaEvolveException