Package org.apache.flink.table.factories

Class FactoryUtil.FactoryHelper<F extends org.apache.flink.table.factories.Factory>

java.lang.Object

org.apache.flink.table.factories.FactoryUtil.FactoryHelper<F>

Direct Known Subclasses:

FactoryUtil.CatalogFactoryHelper, FactoryUtil.CatalogStoreFactoryHelper, FactoryUtil.ModelProviderFactoryHelper, FactoryUtil.ModuleFactoryHelper, FactoryUtil.TableFactoryHelper

Enclosing class:

FactoryUtil

@PublicEvolving
public static class FactoryUtil.FactoryHelper<F extends org.apache.flink.table.factories.Factory>
extends Object

Base helper utility for validating all options for a Factory.

Field Summary

Fields

Modifier and Type	Field	Description
protected final Configuration	allOptions
protected final Set<String>	consumedOptionKeys
protected final Set<String>	deprecatedOptionKeys
protected final F	factory

Constructor Summary

Constructors

Constructor	Description
FactoryHelper(F factory, Map<String,String> configuration, ConfigOption<?>... implicitOptions)

Method Summary

Modifier and Type	Method	Description
ReadableConfig	getOptions()	Returns all options currently being consumed by the factory.
void	validate()	Validates the options of the factory.
void	validateExcept(String... prefixesToSkip)	Validates the options of the factory.

Methods inherited from class java.lang.Object

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

Field Details

factory

protected final F extends org.apache.flink.table.factories.Factory factory

allOptions

protected final Configuration allOptions

consumedOptionKeys

protected final Set<String> consumedOptionKeys

deprecatedOptionKeys

protected final Set<String> deprecatedOptionKeys

Constructor Details

FactoryHelper

public FactoryHelper(F factory,
 Map<String,String> configuration,
 ConfigOption<?>... implicitOptions)

Method Details

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.

Parameters:

prefixesToSkip - Set of option key prefixes to skip validation

getOptions

public ReadableConfig getOptions()

Returns all options currently being consumed by the factory.