Package org.apache.flink.cdc.connectors.maxcompute

Class MaxComputeDataSink

java.lang.Object

org.apache.flink.cdc.connectors.maxcompute.MaxComputeDataSink

All Implemented Interfaces:

DataSink

public class MaxComputeDataSink
extends Object
implements DataSink

A DataSink for "MaxCompute" connector.

Constructor Summary

Constructors

Constructor	Description
MaxComputeDataSink(MaxComputeOptions options, MaxComputeWriteOptions writeOptions)

Method Summary

Modifier and Type	Method	Description
HashFunctionProvider<DataChangeEvent>	getDataChangeEventHashFunctionProvider()	Get the HashFunctionProvider<DataChangeEvent> for calculating hash value if you need to partition by data change event before Sink.
EventSinkProvider	getEventSinkProvider()	Get the EventSinkProvider for writing changed data to external systems.
MetadataApplier	getMetadataApplier()	Get the MetadataApplier for applying metadata changes to external systems.

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

Constructor Detail

MaxComputeDataSink

public MaxComputeDataSink(MaxComputeOptions options,
                          MaxComputeWriteOptions writeOptions)

Method Detail

getEventSinkProvider

public EventSinkProvider getEventSinkProvider()

Description copied from interface: DataSink

Get the EventSinkProvider for writing changed data to external systems.

Specified by:

getEventSinkProvider in interface DataSink

getMetadataApplier

public MetadataApplier getMetadataApplier()

Description copied from interface: DataSink

Get the MetadataApplier for applying metadata changes to external systems.

Specified by:

getMetadataApplier in interface DataSink

getDataChangeEventHashFunctionProvider

public HashFunctionProvider<DataChangeEvent> getDataChangeEventHashFunctionProvider()

Description copied from interface: DataSink

Get the HashFunctionProvider<DataChangeEvent> for calculating hash value if you need to partition by data change event before Sink.

Specified by:

getDataChangeEventHashFunctionProvider in interface DataSink