Uses of Interface
org.apache.flink.configuration.ReadableConfig
Packages that use ReadableConfig
Package
Description
-
Uses of ReadableConfig in org.apache.flink.configuration
Classes in org.apache.flink.configuration that implement ReadableConfigModifier and TypeClassDescriptionclassLightweight configuration object which stores key/value pairs. -
Uses of ReadableConfig in org.apache.flink.table.api
Classes in org.apache.flink.table.api that implement ReadableConfigModifier and TypeClassDescriptionfinal classConfiguration for the currentTableEnvironmentsession to adjust Table & SQL API programs.Methods in org.apache.flink.table.api that return ReadableConfigModifier and TypeMethodDescriptionTableConfig.getRootConfiguration()Gives direct access to the underlying environment-specific key-value map for advanced configuration.Methods in org.apache.flink.table.api with parameters of type ReadableConfigModifier and TypeMethodDescriptionvoidTableConfig.setRootConfiguration(ReadableConfig rootConfiguration) Sets the given configuration asTableConfig.rootConfiguration, which contains any configuration set in the execution context. -
Uses of ReadableConfig in org.apache.flink.table.factories
Methods in org.apache.flink.table.factories that return ReadableConfigModifier and TypeMethodDescriptionFactoryUtil.DefaultCatalogContext.getConfiguration()FactoryUtil.DefaultCatalogStoreContext.getConfiguration()FactoryUtil.DefaultDynamicTableContext.getConfiguration()FactoryUtil.DefaultModelProviderContext.getConfiguration()FactoryUtil.DefaultModuleContext.getConfiguration()FactoryUtil.DefaultSecretStoreContext.getConfiguration()FactoryUtil.FactoryHelper.getOptions()Returns all options currently being consumed by the factory.FactoryUtil.TableFactoryHelper.getOptions()Returns all options currently being consumed by the factory.Methods in org.apache.flink.table.factories with parameters of type ReadableConfigModifier and TypeMethodDescriptionFactoryUtil.checkWatermarkOptions(ReadableConfig conf) Check watermark-related options and return error messages.static CatalogFactoryUtil.createCatalog(String catalogName, Map<String, String> options, ReadableConfig configuration, ClassLoader classLoader) Attempts to discover an appropriate catalog factory and creates an instance of the catalog.static DynamicTableSinkFactoryUtil.createDynamicTableSink(org.apache.flink.table.factories.DynamicTableSinkFactory preferredFactory, ObjectIdentifier objectIdentifier, org.apache.flink.table.catalog.ResolvedCatalogTable catalogTable, Map<String, String> enrichmentOptions, ReadableConfig configuration, ClassLoader classLoader, boolean isTemporary) Creates aDynamicTableSinkfrom aCatalogTable.static DynamicTableSourceFactoryUtil.createDynamicTableSource(org.apache.flink.table.factories.DynamicTableSourceFactory preferredFactory, ObjectIdentifier objectIdentifier, org.apache.flink.table.catalog.ResolvedCatalogTable catalogTable, Map<String, String> enrichmentOptions, ReadableConfig configuration, ClassLoader classLoader, boolean isTemporary) Creates aDynamicTableSourcefrom aCatalogTable.static org.apache.flink.table.ml.ModelProviderFactoryUtil.createModelProvider(org.apache.flink.table.factories.ModelProviderFactory preferredFactory, ObjectIdentifier objectIdentifier, org.apache.flink.table.catalog.ResolvedCatalogModel catalogModel, ReadableConfig configuration, ClassLoader classLoader, boolean isTemporary) Creates aModelProviderfrom aResolvedCatalogModel.static ModuleFactoryUtil.createModule(String moduleName, Map<String, String> options, ReadableConfig configuration, ClassLoader classLoader) Discovers a matching module factory and creates an instance of it.static voidFactoryUtil.validateFactoryOptions(Set<ConfigOption<?>> requiredOptions, Set<ConfigOption<?>> optionalOptions, ReadableConfig options) Validates the required options and optional options.static voidFactoryUtil.validateFactoryOptions(org.apache.flink.table.factories.Factory factory, ReadableConfig options) Validates the required and optionalConfigOptions of a factory.static voidFactoryUtil.validateWatermarkOptions(String factoryIdentifier, ReadableConfig conf) Validate watermark options from table options.Constructors in org.apache.flink.table.factories with parameters of type ReadableConfigModifierConstructorDescriptionDefaultCatalogContext(String name, Map<String, String> options, ReadableConfig configuration, ClassLoader classLoader) DefaultCatalogStoreContext(Map<String, String> options, ReadableConfig configuration, ClassLoader classLoader) DefaultDynamicTableContext(ObjectIdentifier objectIdentifier, org.apache.flink.table.catalog.ResolvedCatalogTable catalogTable, Map<String, String> enrichmentOptions, ReadableConfig configuration, ClassLoader classLoader, boolean isTemporary) DefaultModelProviderContext(ObjectIdentifier objectIdentifier, org.apache.flink.table.catalog.ResolvedCatalogModel catalogModel, ReadableConfig configuration, ClassLoader classLoader, boolean isTemporary) DefaultModuleContext(Map<String, String> options, ReadableConfig configuration, ClassLoader classLoader) DefaultSecretStoreContext(Map<String, String> options, ReadableConfig configuration, ClassLoader classLoader)