org.apache.flink.connector.base.table.util

Class ConfigurationValidatorUtil

java.lang.Object

org.apache.flink.connector.base.table.util.ConfigurationValidatorUtil

@PublicEvolving
public class ConfigurationValidatorUtil
extends Object

Class containing validation utils needed by ConfigurationValidator.

Constructor Summary

Constructors

Constructor and Description
ConfigurationValidatorUtil()

Method Summary

Modifier and Type	Method and Description
static void	validateOptionalBooleanProperty(Properties config, String key, String message)
static void	validateOptionalDateProperty(Properties config, String timestampKey, String format, String message)
static void	validateOptionalPositiveDoubleProperty(Properties config, String key, String message)
static void	validateOptionalPositiveIntProperty(Properties config, String key, String message)
static void	validateOptionalPositiveLongProperty(Properties config, String key, String message)

Methods inherited from class java.lang.Object

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

Constructor Detail

ConfigurationValidatorUtil

public ConfigurationValidatorUtil()

Method Detail

validateOptionalBooleanProperty

public static void validateOptionalBooleanProperty(Properties config,
                                                   String key,
                                                   String message)

validateOptionalPositiveIntProperty

public static void validateOptionalPositiveIntProperty(Properties config,
                                                       String key,
                                                       String message)

validateOptionalPositiveLongProperty

public static void validateOptionalPositiveLongProperty(Properties config,
                                                        String key,
                                                        String message)

validateOptionalPositiveDoubleProperty

public static void validateOptionalPositiveDoubleProperty(Properties config,
                                                          String key,
                                                          String message)

validateOptionalDateProperty

public static void validateOptionalDateProperty(Properties config,
                                                String timestampKey,
                                                String format,
                                                String message)