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

Class OceanBaseDataSink

java.lang.Object

org.apache.flink.cdc.connectors.oceanbase.sink.OceanBaseDataSink

All Implemented Interfaces:

Serializable, DataSink

public class OceanBaseDataSink
extends Object
implements DataSink, Serializable

A DataSink for "OceanBase" pipeline connector.

See Also:

Serialized Form

Constructor Summary

Constructors

Constructor	Description
OceanBaseDataSink(com.oceanbase.connector.flink.OceanBaseConnectorOptions options, java.time.ZoneId zoneId)

Method Summary

Modifier and Type	Method	Description
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, getDataChangeEventHashFunctionProvider

Constructor Detail

OceanBaseDataSink

public OceanBaseDataSink(com.oceanbase.connector.flink.OceanBaseConnectorOptions options,
                         java.time.ZoneId zoneId)

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