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

Class ConfigUtils

java.lang.Object

org.apache.flink.cdc.connectors.hudi.sink.util.ConfigUtils

public class ConfigUtils
extends Object

Utils for writer configurations.

Constructor Summary

Constructors

Constructor	Description
ConfigUtils()

Method Summary

Modifier and Type	Method	Description
static org.apache.flink.configuration.Configuration	createTableConfig(org.apache.flink.configuration.Configuration baseConfig, Schema cdcSchema, TableId tableId)
static void	setupHoodieKeyOptions(Map<String,String> tableOptions, Schema schema)	Sets up the hoodie key options (e.g.

Methods inherited from class java.lang.Object

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

Constructor Detail

ConfigUtils

public ConfigUtils()

Method Detail

createTableConfig

public static org.apache.flink.configuration.Configuration createTableConfig(org.apache.flink.configuration.Configuration baseConfig,
                                                                             Schema cdcSchema,
                                                                             TableId tableId)

setupHoodieKeyOptions

public static void setupHoodieKeyOptions(Map<String,String> tableOptions,
                                         Schema schema)

Sets up the hoodie key options (e.g. record key and partition key) from the table definition.