Package org.apache.flink.cdc.connectors.values

Class ValuesDatabase.ErrorOnChangeMetadataApplier

java.lang.Object

org.apache.flink.cdc.connectors.values.ValuesDatabase.ErrorOnChangeMetadataApplier

All Implemented Interfaces:

Serializable, AutoCloseable, MetadataApplier

Enclosing class:

ValuesDatabase

public static class ValuesDatabase.ErrorOnChangeMetadataApplier
extends Object
implements MetadataApplier

apply SchemaChangeEvent to ValuesDatabase and print it out, throw exception if illegal changes occur.

See Also:

Serialized Form

Constructor Summary

Constructors

Constructor	Description
ErrorOnChangeMetadataApplier()

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

ErrorOnChangeMetadataApplier

public ErrorOnChangeMetadataApplier()

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