org.apache.flink.cdc.common.factories

类 FactoryHelper

java.lang.Object

org.apache.flink.cdc.common.factories.FactoryHelper

@PublicEvolving
public class FactoryHelper
extends Object

A helper for working with Factory.

嵌套类概要

嵌套类

限定符和类型	类和说明
static class	FactoryHelper.DefaultContext Default implementation of Factory.Context.

方法概要

限定符和类型	方法和说明
static FactoryHelper	createFactoryHelper(Factory factory, Factory.Context context)
void	validate() Validates the options of the factory.
void	validateExcept(String... prefixesToSkip) Validates the options of the factory.
static void	validateFactoryOptions(Factory factory, Configuration configuration) Validates the required and optional ConfigOptions of a factory.
static void	validateFactoryOptions(Set<ConfigOption<?>> requiredOptions, Set<ConfigOption<?>> optionalOptions, Configuration configuration) Validates the required options and optional options.
static void	validateUnconsumedKeys(String factoryIdentifier, Set<String> allOptionKeys, Set<String> consumedOptionKeys) Validates unconsumed option keys.

从类继承的方法 java.lang.Object

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

方法详细资料

createFactoryHelper

public static FactoryHelper createFactoryHelper(Factory factory,
                                                Factory.Context context)

validateFactoryOptions

public static void validateFactoryOptions(Factory factory,
                                          Configuration configuration)

Validates the required and optional ConfigOptions of a factory.

Note: It does not check for left-over options.

validateFactoryOptions

public static void validateFactoryOptions(Set<ConfigOption<?>> requiredOptions,
                                          Set<ConfigOption<?>> optionalOptions,
                                          Configuration configuration)

Validates the required options and optional options.

Note: It does not check for left-over options.

validateUnconsumedKeys

public static void validateUnconsumedKeys(String factoryIdentifier,
                                          Set<String> allOptionKeys,
                                          Set<String> consumedOptionKeys)

Validates unconsumed option keys.

validate

public void validate()

Validates the options of the factory. It checks for unconsumed option keys.

validateExcept

public void validateExcept(String... prefixesToSkip)

Validates the options of the factory. It checks for unconsumed option keys while ignoring the options with given prefixes.

The option keys that have given prefix prefixToSkip would just be skipped for validation.

参数:

prefixesToSkip - Set of option key prefixes to skip validation