org.apache.paimon.flink.factories

Class FlinkFactoryUtil.FlinkTableFactoryHelper

java.lang.Object

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

org.apache.paimon.flink.factories.FlinkFactoryUtil.FlinkTableFactoryHelper

Enclosing class:

FlinkFactoryUtil

public static class FlinkFactoryUtil.FlinkTableFactoryHelper
extends FlinkFactoryUtil.FlinkFactoryHelper<LogStoreTableFactory>

Helper utility for discovering formats and validating all options for a DynamicTableFactory.

See Also:

#createFlinkTableFactoryHelper(LogStoreTableFactory, Context)

Field Summary

Fields inherited from class org.apache.paimon.flink.factories.FlinkFactoryUtil.FlinkFactoryHelper

allOptions, consumedOptionKeys, deprecatedOptionKeys, factory

Method Summary

Modifier and Type	Method and Description
<I,F extends org.apache.flink.table.factories.DecodingFormatFactory<I>> org.apache.flink.table.connector.format.DecodingFormat<I>	discoverDecodingFormat(Class<F> formatFactoryClass, org.apache.flink.configuration.ConfigOption<String> formatOption) Discovers a DecodingFormat of the given type using the given option as factory identifier.
<I,F extends org.apache.flink.table.factories.EncodingFormatFactory<I>> org.apache.flink.table.connector.format.EncodingFormat<I>	discoverEncodingFormat(Class<F> formatFactoryClass, org.apache.flink.configuration.ConfigOption<String> formatOption) Discovers a EncodingFormat of the given type using the given option as factory identifier.
<I,F extends org.apache.flink.table.factories.DecodingFormatFactory<I>> Optional<org.apache.flink.table.connector.format.DecodingFormat<I>>	discoverOptionalDecodingFormat(Class<F> formatFactoryClass, org.apache.flink.configuration.ConfigOption<String> formatOption) Discovers a DecodingFormat of the given type using the given option (if present) as factory identifier.
<I,F extends org.apache.flink.table.factories.EncodingFormatFactory<I>> Optional<org.apache.flink.table.connector.format.EncodingFormat<I>>	discoverOptionalEncodingFormat(Class<F> formatFactoryClass, org.apache.flink.configuration.ConfigOption<String> formatOption) Discovers a EncodingFormat of the given type using the given option (if present) as factory identifier.
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

Method Detail

getOptions

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

Returns all options currently being consumed by the factory. This method returns the options already merged with DynamicTableFactory.Context.getEnrichmentOptions(), using DynamicTableFactory.forwardOptions() as reference of mergeable options.

Overrides:

getOptions in class FlinkFactoryUtil.FlinkFactoryHelper<LogStoreTableFactory>

discoverDecodingFormat

public <I,F extends org.apache.flink.table.factories.DecodingFormatFactory<I>> org.apache.flink.table.connector.format.DecodingFormat<I> discoverDecodingFormat(Class<F> formatFactoryClass,
                                                                                                                                                                org.apache.flink.configuration.ConfigOption<String> formatOption)

Discovers a DecodingFormat of the given type using the given option as factory identifier.

discoverOptionalDecodingFormat

public <I,F extends org.apache.flink.table.factories.DecodingFormatFactory<I>> Optional<org.apache.flink.table.connector.format.DecodingFormat<I>> discoverOptionalDecodingFormat(Class<F> formatFactoryClass,
                                                                                                                                                                                  org.apache.flink.configuration.ConfigOption<String> formatOption)

Discovers a DecodingFormat of the given type using the given option (if present) as factory identifier.

discoverEncodingFormat

public <I,F extends org.apache.flink.table.factories.EncodingFormatFactory<I>> org.apache.flink.table.connector.format.EncodingFormat<I> discoverEncodingFormat(Class<F> formatFactoryClass,
                                                                                                                                                                org.apache.flink.configuration.ConfigOption<String> formatOption)

Discovers a EncodingFormat of the given type using the given option as factory identifier.

discoverOptionalEncodingFormat

public <I,F extends org.apache.flink.table.factories.EncodingFormatFactory<I>> Optional<org.apache.flink.table.connector.format.EncodingFormat<I>> discoverOptionalEncodingFormat(Class<F> formatFactoryClass,
                                                                                                                                                                                  org.apache.flink.configuration.ConfigOption<String> formatOption)

Discovers a EncodingFormat of the given type using the given option (if present) as factory identifier.