IcebergDataSinkFactory (flink-cdc-parent 3.8-SNAPSHOT API)

java.lang.Object
- org.apache.flink.cdc.connectors.iceberg.sink.IcebergDataSinkFactory

All Implemented Interfaces:

DataSinkFactory, Factory
```
public class IcebergDataSinkFactory
extends Object
implements DataSinkFactory
```
A DataSinkFactory for Apache Iceberg.

Nested Class Summary
- Nested classes/interfaces inherited from interface org.apache.flink.cdc.common.factories.Factory
  Factory.Context

Field Summary

Fields
Modifier and Type Field Description

static String IDENTIFIER

Constructor Summary

Constructors
Constructor Description

IcebergDataSinkFactory()

Method Summary

All Methods Instance Methods Concrete Methods
Modifier and Type	Method	Description
`DataSink`	`createDataSink(Factory.Context context)`	Creates a `DataSink` instance.
`String`	`identifier()`	Returns a unique identifier among same factory interfaces.
`Set<ConfigOption<?>>`	`optionalOptions()`	Returns a set of `ConfigOption` that an implementation of this factory consumes in addition to `Factory.requiredOptions()`.
`Set<ConfigOption<?>>`	`requiredOptions()`	Returns a set of `ConfigOption` that an implementation of this factory requires in addition to `Factory.optionalOptions()`.

Methods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

- Field Detail
  - IDENTIFIER
```
public static final String IDENTIFIER
```
    See Also:
    
    Constant Field Values
- Constructor Detail
  - IcebergDataSinkFactory
```
public IcebergDataSinkFactory()
```
- Method Detail
  - createDataSink
```
public DataSink createDataSink(Factory.Context context)
```
    Description copied from interface: DataSinkFactory
    
    Creates a DataSink instance.
    
    Specified by:
    
    createDataSink in interface DataSinkFactory
  - identifier
```
public String identifier()
```
    Description copied from interface: Factory
    
    Returns a unique identifier among same factory interfaces.
    
    Specified by:
    
    identifier in interface Factory
  - requiredOptions
```
public Set<ConfigOption<?>> requiredOptions()
```
    Description copied from interface: Factory
    
    Returns a set of ConfigOption that an implementation of this factory requires in addition to Factory.optionalOptions().
    
    Specified by:
    
    requiredOptions in interface Factory
  - optionalOptions
```
public Set<ConfigOption<?>> optionalOptions()
```
    Description copied from interface: Factory
    
    Returns a set of ConfigOption that an implementation of this factory consumes in addition to Factory.requiredOptions().
    
    Specified by:
    
    optionalOptions in interface Factory