Package org.apache.flink.cdc.connectors.fluss.utils

Class FlussConfigUtils

java.lang.Object

org.apache.flink.cdc.connectors.fluss.utils.FlussConfigUtils

public class FlussConfigUtils
extends Object

Utils for parsing fluss yaml sink options.

Method Summary

Modifier and Type	Method	Description
static Map<String,List<String>>	parseBucketKeys(String rawValue)
static Map<String,Integer>	parseBucketNumber(String rawValue)

Methods inherited from class java.lang.Object

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

Method Detail

parseBucketKeys

public static Map<String,List<String>> parseBucketKeys(@Nullable
                                                             String rawValue)
                                                      throws IllegalArgumentException

Throws:

IllegalArgumentException

parseBucketNumber

public static Map<String,Integer> parseBucketNumber(@Nullable
                                                          String rawValue)
                                                   throws IllegalArgumentException

Throws:

IllegalArgumentException