Package org.apache.flink.cdc.runtime.operators.schema.common

Class ExistingTableSchemaExpander

java.lang.Object

org.apache.flink.cdc.runtime.operators.schema.common.ExistingTableSchemaExpander

@Internal
public class ExistingTableSchemaExpander
extends Object

Handles the initial CreateTableEvent for an existing target table according to the configured ExistingTableSchemaExpansionMode.

Constructor Summary

Constructors

Constructor	Description
ExistingTableSchemaExpander(MetadataApplier metadataApplier, ExistingTableSchemaExpansionSupport expansionSupport, SchemaChangeBehavior schemaChangeBehavior)
ExistingTableSchemaExpander(MetadataApplier metadataApplier, ExistingTableSchemaExpansionSupport expansionSupport, SchemaChangeBehavior schemaChangeBehavior, ExistingTableSchemaExpansionMode mode)

Method Summary

Modifier and Type	Method	Description
boolean	handleExistingTableCreation(CreateTableEvent createTableEvent)	Handles the initial CreateTableEvent for an existing target table.

Methods inherited from class java.lang.Object

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

Constructor Detail

ExistingTableSchemaExpander

public ExistingTableSchemaExpander(MetadataApplier metadataApplier,
                                   ExistingTableSchemaExpansionSupport expansionSupport,
                                   SchemaChangeBehavior schemaChangeBehavior)

ExistingTableSchemaExpander

public ExistingTableSchemaExpander(MetadataApplier metadataApplier,
                                   ExistingTableSchemaExpansionSupport expansionSupport,
                                   SchemaChangeBehavior schemaChangeBehavior,
                                   ExistingTableSchemaExpansionMode mode)

Method Detail

handleExistingTableCreation

public boolean handleExistingTableCreation(CreateTableEvent createTableEvent)

Handles the initial CreateTableEvent for an existing target table.

This is a two-phase contract: the expander first tries to check/expand the existing target table, then signals whether the sink should still apply the original CreateTableEvent.

Returns:

true if the caller should proceed to apply the original CreateTableEvent to the sink; false means the framework has fully handled this event and the original CreateTableEvent must not be applied. CHECK mode returns false after a successful check so that no external DDL is issued by the pipeline.