OceanBaseDataSinkFactory (flink-cdc-pipeline-connector-oceanbase 3.6.0-2.2 API)

java.lang.Object
- org.apache.flink.cdc.connectors.oceanbase.factory.OceanBaseDataSinkFactory

所有已实现的接口:

org.apache.flink.cdc.common.factories.DataSinkFactory, org.apache.flink.cdc.common.factories.Factory
```
@Internal
public class OceanBaseDataSinkFactory
extends Object
implements org.apache.flink.cdc.common.factories.DataSinkFactory
```
A DataSinkFactory to create OceanBaseDataSink.

嵌套类概要
- 从接口继承的嵌套类/接口 org.apache.flink.cdc.common.factories.Factory
  org.apache.flink.cdc.common.factories.Factory.Context

构造器概要

构造器
构造器说明

OceanBaseDataSinkFactory()

方法概要

所有方法实例方法具体方法
修饰符和类型	方法	说明
`org.apache.flink.cdc.common.sink.DataSink`	`createDataSink(org.apache.flink.cdc.common.factories.Factory.Context context)`
`String`	`identifier()`
`Set<org.apache.flink.cdc.common.configuration.ConfigOption<?>>`	`optionalOptions()`
`Set<org.apache.flink.cdc.common.configuration.ConfigOption<?>>`	`requiredOptions()`

从类继承的方法 java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

- 构造器详细资料
  - OceanBaseDataSinkFactory
```
public OceanBaseDataSinkFactory()
```
- 方法详细资料
  - createDataSink
```
public org.apache.flink.cdc.common.sink.DataSink createDataSink(org.apache.flink.cdc.common.factories.Factory.Context context)
```
    指定者:
    
    createDataSink 在接口中 org.apache.flink.cdc.common.factories.DataSinkFactory
  - identifier
```
public String identifier()
```
    指定者:
    
    identifier 在接口中 org.apache.flink.cdc.common.factories.Factory
  - requiredOptions
```
public Set<org.apache.flink.cdc.common.configuration.ConfigOption<?>> requiredOptions()
```
    指定者:
    
    requiredOptions 在接口中 org.apache.flink.cdc.common.factories.Factory
  - optionalOptions
```
public Set<org.apache.flink.cdc.common.configuration.ConfigOption<?>> optionalOptions()
```
    指定者:
    
    optionalOptions 在接口中 org.apache.flink.cdc.common.factories.Factory