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

java.lang.Object
- org.apache.flink.cdc.connectors.hudi.sink.HudiDataSinkFactory

All Implemented Interfaces:

DataSinkFactory, Factory
```
public class HudiDataSinkFactory
extends Object
implements DataSinkFactory
```
Factory for creating HudiDataSink. This class defines the configuration options and instantiates the sink by delegating option definitions to HudiConfig.

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

HudiDataSinkFactory()

Method Summary

All Methods Instance Methods Concrete Methods
Modifier and Type	Method	Description
`HudiDataSink`	`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
  - HudiDataSinkFactory
```
public HudiDataSinkFactory()
```
- Method Detail
  - identifier
```
public String identifier()
```
    Description copied from interface: Factory
    
    Returns a unique identifier among same factory interfaces.
    
    Specified by:
    
    identifier in interface Factory
  - createDataSink
```
public HudiDataSink createDataSink(Factory.Context context)
```
    Description copied from interface: DataSinkFactory
    
    Creates a DataSink instance.
    
    Specified by:
    
    createDataSink in interface DataSinkFactory
  - 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