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

Class IcebergMetadataApplier

java.lang.Object

org.apache.flink.cdc.connectors.iceberg.sink.IcebergMetadataApplier

All Implemented Interfaces:

Serializable, AutoCloseable, MetadataApplier

public class IcebergMetadataApplier
extends Object
implements MetadataApplier

A MetadataApplier for Apache Iceberg.

See Also:

Serialized Form

Constructor Summary

Constructors

Constructor	Description
IcebergMetadataApplier(Map<String,String> catalogOptions)
IcebergMetadataApplier(Map<String,String> catalogOptions, Map<String,String> tableOptions, Map<TableId,List<String>> partitionMaps)
IcebergMetadataApplier(Map<String,String> catalogOptions, Map<String,String> tableOptions, Map<TableId,List<String>> partitionMaps, Map<String,String> hadoopConfOptions)

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.
void	close()	Closes the metadata applier and its underlying resources.
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

getExistingTableSchemaExpansionSupport

Constructor Detail

IcebergMetadataApplier

public IcebergMetadataApplier(Map<String,String> catalogOptions)

IcebergMetadataApplier

public IcebergMetadataApplier(Map<String,String> catalogOptions,
                              Map<String,String> tableOptions,
                              Map<TableId,List<String>> partitionMaps)

IcebergMetadataApplier

public IcebergMetadataApplier(Map<String,String> catalogOptions,
                              Map<String,String> tableOptions,
                              Map<TableId,List<String>> partitionMaps,
                              Map<String,String> hadoopConfOptions)

Method Detail

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

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

close

public void close()

Description copied from interface: MetadataApplier

Closes the metadata applier and its underlying resources.

Specified by:

close in interface AutoCloseable

Specified by:

close in interface MetadataApplier