org.apache.paimon.flink.factories

Class FlinkFactoryUtil.FlinkFactoryHelper<F extends LogStoreTableFactory>

java.lang.Object

org.apache.paimon.flink.factories.FlinkFactoryUtil.FlinkFactoryHelper<F>

Direct Known Subclasses:

FlinkFactoryUtil.FlinkTableFactoryHelper

Enclosing class:

FlinkFactoryUtil

public static class FlinkFactoryUtil.FlinkFactoryHelper<F extends LogStoreTableFactory>
extends Object

Base flink helper utility for validating all options for a LogStoreTableFactory.

Field Summary

Fields

Modifier and Type	Field and Description
protected org.apache.flink.configuration.Configuration	allOptions
protected Set<String>	consumedOptionKeys
protected Set<String>	deprecatedOptionKeys
protected F	factory

Constructor Summary

Constructors

Constructor and Description
FlinkFactoryHelper(F factory, Map<String,String> configuration, org.apache.flink.configuration.ConfigOption<?>... implicitOptions)

Method Summary

Modifier and Type	Method and Description
org.apache.flink.configuration.ReadableConfig	getOptions() Returns all options currently being consumed by the factory.

Methods inherited from class java.lang.Object

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

Field Detail

factory

protected final F extends LogStoreTableFactory factory

allOptions

protected final org.apache.flink.configuration.Configuration allOptions

consumedOptionKeys

protected final Set<String> consumedOptionKeys

deprecatedOptionKeys

protected final Set<String> deprecatedOptionKeys

Constructor Detail

FlinkFactoryHelper

public FlinkFactoryHelper(F factory,
                          Map<String,String> configuration,
                          org.apache.flink.configuration.ConfigOption<?>... implicitOptions)

Method Detail

getOptions

public org.apache.flink.configuration.ReadableConfig getOptions()

Returns all options currently being consumed by the factory.