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

Class HudiMetadataApplier

java.lang.Object

org.apache.flink.cdc.connectors.hudi.sink.HudiMetadataApplier

All Implemented Interfaces:

Serializable, AutoCloseable, MetadataApplier

public class HudiMetadataApplier
extends Object
implements MetadataApplier

A MetadataApplier that applies schema changes to Hudi tables.

This applier is responsible for initializing the Hudi table metadata in the file system if it does not already exist.

See Also:

Serialized Form

Constructor Summary

Constructors

Constructor	Description
HudiMetadataApplier(Configuration config)

Method Summary

Modifier and Type	Method	Description
void	applySchemaChange(SchemaChangeEvent schemaChangeEvent)	Apply the given SchemaChangeEvent to external systems.
void	close()	Closes the metadata applier and its underlying resources.

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

acceptsSchemaEvolutionType, getExistingTableSchemaExpansionSupport, getSupportedSchemaEvolutionTypes, setAcceptedSchemaEvolutionTypes

Constructor Detail

HudiMetadataApplier

public HudiMetadataApplier(Configuration config)

Method Detail

applySchemaChange

public void applySchemaChange(SchemaChangeEvent schemaChangeEvent)

Description copied from interface: MetadataApplier

Apply the given SchemaChangeEvent to external systems.

Specified by:

applySchemaChange in interface MetadataApplier

close

public void close()
           throws Exception

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

Throws:

Exception