程序包 org.apache.flink.cdc.connectors.oceanbase.sink

类 OceanBaseDataSink

java.lang.Object

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

所有已实现的接口:

Serializable, org.apache.flink.cdc.common.sink.DataSink

public class OceanBaseDataSink
extends Object
implements org.apache.flink.cdc.common.sink.DataSink, Serializable

A DataSink for "OceanBase" pipeline connector.

另请参阅:

序列化表格

构造器概要

构造器

构造器	说明
OceanBaseDataSink(com.oceanbase.connector.flink.OceanBaseConnectorOptions options, java.time.ZoneId zoneId)

方法概要

修饰符和类型	方法	说明
org.apache.flink.cdc.common.sink.EventSinkProvider	getEventSinkProvider()
org.apache.flink.cdc.common.sink.MetadataApplier	getMetadataApplier()

从类继承的方法 java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

从接口继承的方法 org.apache.flink.cdc.common.sink.DataSink

getDataChangeEventHashFunctionProvider, getDataChangeEventHashFunctionProvider

构造器详细资料

OceanBaseDataSink

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

方法详细资料

getEventSinkProvider

public org.apache.flink.cdc.common.sink.EventSinkProvider getEventSinkProvider()

指定者:

getEventSinkProvider 在接口中 org.apache.flink.cdc.common.sink.DataSink

getMetadataApplier

public org.apache.flink.cdc.common.sink.MetadataApplier getMetadataApplier()

指定者:

getMetadataApplier 在接口中 org.apache.flink.cdc.common.sink.DataSink