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

Class HudiConfig

java.lang.Object

org.apache.flink.cdc.connectors.hudi.sink.HudiConfig

public class HudiConfig
extends Object

A utility class that holds all the configuration options for the Hudi sink. It wraps Hudi's FlinkOptions to provide a consistent interface within the CDC framework, using helper methods to reduce boilerplate.

Field Summary

Fields

Modifier and Type	Field	Description
static ConfigOption<String>	INDEX_TYPE
static ConfigOption<String>	ORDERING_FIELDS
static ConfigOption<String>	PATH
static ConfigOption<String>	TABLE_TYPE
static ConfigOption<Integer>	WRITE_TASKS

Constructor Summary

Constructors

Constructor	Description
HudiConfig()

Method Summary

Methods inherited from class java.lang.Object

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

Field Detail

PATH

public static final ConfigOption<String> PATH

TABLE_TYPE

public static final ConfigOption<String> TABLE_TYPE

ORDERING_FIELDS

public static final ConfigOption<String> ORDERING_FIELDS

INDEX_TYPE

public static final ConfigOption<String> INDEX_TYPE

WRITE_TASKS

public static final ConfigOption<Integer> WRITE_TASKS

Constructor Detail

HudiConfig

public HudiConfig()