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

Class HudiDataSink

java.lang.Object

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

All Implemented Interfaces:

Serializable, DataSink

public class HudiDataSink
extends Object
implements DataSink, Serializable

A DataSink for Apache Hudi that provides the main entry point for the Flink CDC framework.

See Also:

Serialized Form

Constructor Summary

Constructors

Constructor	Description
HudiDataSink(Configuration config, String schemaOperatorUid)

Method Summary

Modifier and Type	Method	Description
EventSinkProvider	getEventSinkProvider()	Provides the core sink implementation that handles the data flow of events.
MetadataApplier	getMetadataApplier()	Provides the 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.DataSink

getDataChangeEventHashFunctionProvider, getDataChangeEventHashFunctionProvider

Constructor Detail

HudiDataSink

public HudiDataSink(Configuration config,
                    String schemaOperatorUid)

Method Detail

getEventSinkProvider

public EventSinkProvider getEventSinkProvider()

Provides the core sink implementation that handles the data flow of events.

Specified by:

getEventSinkProvider in interface DataSink

getMetadataApplier

public MetadataApplier getMetadataApplier()

Provides the metadata applier. In our design, this has a passive role (e.g., logging), as transactional metadata operations are handled by the HudiCommitter.

Specified by:

getMetadataApplier in interface DataSink