Uses of Class org.apache.flink.configuration.ConfigOption (Confluent Flink Table API for Java)

Packages that use ConfigOption

Package

Description

io.confluent.flink.plugin

org.apache.flink.configuration

org.apache.flink.table.api

org.apache.flink.table.api.config

org.apache.flink.table.factories

Uses of ConfigOption in io.confluent.flink.plugin

Fields in io.confluent.flink.plugin declared as ConfigOption

Modifier and Type

Field

Description

static final ConfigOption<Boolean>

ConfluentPluginOptions.CLIENT_ACTION_AWAIT

static final ConfigOption<PluginAction>

ConfluentPluginOptions.CLIENT_ACTION_KIND

static final ConfigOption<Boolean>

ConfluentPluginOptions.CLIENT_ACTION_SKIP_EXIT

static final ConfigOption<String>

ConfluentPluginOptions.CLIENT_APPLICATION_NAME

static final ConfigOption<String>

ConfluentPluginOptions.CLIENT_ARTIFACT_API_KEY

static final ConfigOption<String>

ConfluentPluginOptions.CLIENT_ARTIFACT_API_SECRET

static final ConfigOption<String>

ConfluentPluginOptions.CLIENT_ARTIFACT_ENDPOINT_TEMPLATE

static final ConfigOption<AuthMode>

ConfluentPluginOptions.CLIENT_AUTH_MODE

static final ConfigOption<Duration>

ConfluentPluginOptions.CLIENT_AWAIT_TIMEOUT

static final ConfigOption<Duration>

ConfluentPluginOptions.CLIENT_CATALOG_CACHE

static final ConfigOption<String>

ConfluentPluginOptions.CLIENT_CLOUD

static final ConfigOption<String>

ConfluentPluginOptions.CLIENT_COMPUTE_POOL_ID

static final ConfigOption<String>

ConfluentPluginOptions.CLIENT_ENDPOINT_TEMPLATE

static final ConfigOption<String>

ConfluentPluginOptions.CLIENT_ENVIRONMENT_ID

static final ConfigOption<String>

ConfluentPluginOptions.CLIENT_FLINK_API_KEY

static final ConfigOption<String>

ConfluentPluginOptions.CLIENT_FLINK_API_SECRET

static final ConfigOption<String>

ConfluentPluginOptions.CLIENT_GLOBAL_API_KEY

static final ConfigOption<String>

ConfluentPluginOptions.CLIENT_GLOBAL_API_SECRET

static final ConfigOption<String>

ConfluentPluginOptions.CLIENT_HTTP_USER_AGENT

static final ConfigOption<String>

ConfluentPluginOptions.CLIENT_OAUTH_EXTERNAL_ACCESS_TOKEN

static final ConfigOption<String>

ConfluentPluginOptions.CLIENT_OAUTH_EXTERNAL_CLIENT_ID

static final ConfigOption<String>

ConfluentPluginOptions.CLIENT_OAUTH_EXTERNAL_CLIENT_SECRET

static final ConfigOption<String>

ConfluentPluginOptions.CLIENT_OAUTH_EXTERNAL_TOKEN_SCOPE

static final ConfigOption<String>

ConfluentPluginOptions.CLIENT_OAUTH_EXTERNAL_TOKEN_URL

static final ConfigOption<String>

ConfluentPluginOptions.CLIENT_OAUTH_IDENTITY_POOL_ID

static final ConfigOption<String>

ConfluentPluginOptions.CLIENT_ON_CONFLICT

static final ConfigOption<String>

ConfluentPluginOptions.CLIENT_ORGANIZATION_ID

static final ConfigOption<String>

ConfluentPluginOptions.CLIENT_PRINCIPAL_ID

static final ConfigOption<String>

ConfluentPluginOptions.CLIENT_REGION

static final ConfigOption<String>

ConfluentPluginOptions.CLIENT_REST_ENDPOINT

static final ConfigOption<String>

ConfluentPluginOptions.CLIENT_STATEMENT_NAME

static final ConfigOption<String>

ConfluentPluginOptions.CLIENT_TMP_DIR

Methods in io.confluent.flink.plugin with parameters of type ConfigOption

Modifier and Type

Method

Description

ConfluentTableDescriptor.Builder

ConfluentTableDescriptor.Builder.format(ConfigOption<String> formatOption, FormatDescriptor formatDescriptor)

Defines the format to be used for this table.

<T> ConfluentTableDescriptor.Builder

ConfluentTableDescriptor.Builder.option(ConfigOption<T> configOption, T value)

Sets the given option on the table.
Uses of ConfigOption in org.apache.flink.configuration

Fields in org.apache.flink.configuration declared as ConfigOption

Modifier and Type

Field

Description

static final ConfigOption<Boolean>

PipelineOptions.ALLOW_UNALIGNED_SOURCE_SPLITS

Will be removed in future Flink releases.

static final ConfigOption<Boolean>

PipelineOptions.AUTO_GENERATE_UIDS

static final ConfigOption<Duration>

PipelineOptions.AUTO_WATERMARK_INTERVAL

static final ConfigOption<List<String>>

PipelineOptions.CACHED_FILES

static final ConfigOption<List<String>>

PipelineOptions.CLASSPATHS

A list of URLs that are added to the classpath of each user code classloader of the program.

static final ConfigOption<org.apache.flink.api.common.ExecutionConfig.ClosureCleanerLevel>

PipelineOptions.CLOSURE_CLEANER_LEVEL

static final ConfigOption<Boolean>

PipelineOptions.FORCE_AVRO

static final ConfigOption<Boolean>

PipelineOptions.FORCE_KRYO

static final ConfigOption<Boolean>

PipelineOptions.FORCE_KRYO_AVRO

static final ConfigOption<Boolean>

PipelineOptions.GENERIC_TYPES

static final ConfigOption<Map<String,String>>

PipelineOptions.GLOBAL_JOB_PARAMETERS

static final ConfigOption<List<String>>

PipelineOptions.JARS

A list of jar files that contain the user-defined function (UDF) classes and all classes used from within the UDFs.

static final ConfigOption<Integer>

PipelineOptions.MAX_PARALLELISM

static final ConfigOption<String>

PipelineOptions.NAME

The job name used for printing and logging.

static final ConfigOption<Boolean>

PipelineOptions.OBJECT_REUSE

static final ConfigOption<Boolean>

PipelineOptions.OPERATOR_CHAINING

static final ConfigOption<Boolean>

PipelineOptions.OPERATOR_CHAINING_CHAIN_OPERATORS_WITH_DIFFERENT_MAX_PARALLELISM

static final ConfigOption<Map<String,String>>

PipelineOptions.PARALLELISM_OVERRIDES

static final ConfigOption<List<String>>

PipelineOptions.SERIALIZATION_CONFIG

static final ConfigOption<PipelineOptions.VertexDescriptionMode>

PipelineOptions.VERTEX_DESCRIPTION_MODE

static final ConfigOption<Boolean>

PipelineOptions.VERTEX_NAME_INCLUDE_INDEX_PREFIX

static final ConfigOption<Integer>

PipelineOptions.WATERMARK_ALIGNMENT_BUFFER_SIZE

Methods in org.apache.flink.configuration that return ConfigOption

Modifier and Type

Method

Description

ConfigOption<T>

ConfigOptions.TypedConfigOptionBuilder.defaultValue(T value)

Creates a ConfigOption with the given default value.

final ConfigOption<List<E>>

ConfigOptions.ListConfigOptionBuilder.defaultValues(E... values)

Creates a ConfigOption with the given default value.

ConfigOption<List<E>>

ConfigOptions.ListConfigOptionBuilder.noDefaultValue()

Creates a ConfigOption without a default value.

ConfigOption<T>

ConfigOptions.TypedConfigOptionBuilder.noDefaultValue()

Creates a ConfigOption without a default value.

ConfigOption<T>

ConfigOption.withDeprecatedKeys(String... deprecatedKeys)

Creates a new config option, using this option's key and default value, and adding the given deprecated keys.

ConfigOption<T>

ConfigOption.withDescription(String description)

Creates a new config option, using this option's key and default value, and adding the given description.

ConfigOption<T>

ConfigOption.withDescription(Description description)

Creates a new config option, using this option's key and default value, and adding the given description.

ConfigOption<T>

ConfigOption.withFallbackKeys(String... fallbackKeys)

Creates a new config option, using this option's key and default value, and adding the given fallback keys.

Methods in org.apache.flink.configuration with parameters of type ConfigOption

Modifier and Type

Method

Description

boolean

Configuration.contains(ConfigOption<?> configOption)

Checks whether there is an entry for the given config option.

<T> T

Configuration.get(ConfigOption<T> option)

Please check the java doc of Configuration.getRawValueFromOption(ConfigOption).

<T> T

Configuration.get(ConfigOption<T> configOption, T overrideDefault)

Returns the value associated with the given config option as a T.

<T> T

ReadableConfig.get(ConfigOption<T> option)

Reads a value using the metadata included in ConfigOption.

<T extends Enum<T>> T

Configuration.getEnum(Class<T> enumClass, ConfigOption<String> configOption)

Returns the value associated with the given config option as an enum.

<T> Optional<T>

Configuration.getOptional(ConfigOption<T> option)

<T> Optional<T>

ReadableConfig.getOptional(ConfigOption<T> option)

Reads a value using the metadata included in ConfigOption.

String

Configuration.getValue(ConfigOption<?> configOption)

Returns the value associated with the given config option as a string.

<T> boolean

Configuration.removeConfig(ConfigOption<T> configOption)

Removes given config option from the configuration.

<T> Configuration

Configuration.set(ConfigOption<T> option, T value)

<T> WritableConfig

WritableConfig.set(ConfigOption<T> option, T value)

Stores a given value using the metadata included in the ConfigOption.
Uses of ConfigOption in org.apache.flink.table.api

Methods in org.apache.flink.table.api with parameters of type ConfigOption

Modifier and Type

Method

Description

TableDescriptor.Builder

TableDescriptor.Builder.format(ConfigOption<String> formatOption, FormatDescriptor formatDescriptor)

Defines the format to be used for this table.

<T> T

TableConfig.get(ConfigOption<T> option)

Reads a value using the metadata included in ConfigOption.

<T> Optional<T>

TableConfig.getOptional(ConfigOption<T> option)

Reads a value using the metadata included in ConfigOption.

<T> FormatDescriptor.Builder

FormatDescriptor.Builder.option(ConfigOption<T> configOption, T value)

Sets the given option on the format.

<T> ModelDescriptor.Builder

ModelDescriptor.Builder.option(ConfigOption<T> configOption, T value)

Sets the given option on the model.

<T> TableDescriptor.Builder

TableDescriptor.Builder.option(ConfigOption<T> configOption, T value)

Sets the given option on the table.

<T> TableConfig

TableConfig.set(ConfigOption<T> option, T value)

Sets an application-specific value for the given ConfigOption.
Uses of ConfigOption in org.apache.flink.table.api.config

Fields in org.apache.flink.table.api.config declared as ConfigOption

Modifier and Type

Field

Description

static final ConfigOption<Boolean>

MLPredictRuntimeConfigOptions.ASYNC

static final ConfigOption<Integer>

MLPredictRuntimeConfigOptions.ASYNC_MAX_CONCURRENT_OPERATIONS

static final ConfigOption<ExecutionConfigOptions.AsyncOutputMode>

MLPredictRuntimeConfigOptions.ASYNC_OUTPUT_MODE

static final ConfigOption<Duration>

MLPredictRuntimeConfigOptions.ASYNC_TIMEOUT

static final ConfigOption<Integer>

TableConfigOptions.DISPLAY_MAX_COLUMN_WIDTH

static final ConfigOption<Duration>

ExecutionConfigOptions.IDLE_STATE_RETENTION

static final ConfigOption<Boolean>

TableConfigOptions.LEGACY_NESTED_ROW_NULLABILITY

static final ConfigOption<String>

TableConfigOptions.LOCAL_TIME_ZONE

static final ConfigOption<Integer>

TableConfigOptions.MAX_LENGTH_GENERATED_CODE

static final ConfigOption<Integer>

TableConfigOptions.MAX_MEMBERS_GENERATED_CODE

static final ConfigOption<TableConfigOptions.CatalogPlanCompilation>

TableConfigOptions.PLAN_COMPILE_CATALOG_OBJECTS

static final ConfigOption<Boolean>

TableConfigOptions.PLAN_FORCE_RECOMPILE

static final ConfigOption<TableConfigOptions.CatalogPlanRestore>

TableConfigOptions.PLAN_RESTORE_CATALOG_OBJECTS

static final ConfigOption<String>

TableConfigOptions.RESOURCES_DOWNLOAD_DIR

static final ConfigOption<List<String>>

TableConfigOptions.TABLE_CATALOG_MODIFICATION_LISTENERS

static final ConfigOption<String>

TableConfigOptions.TABLE_CATALOG_NAME

static final ConfigOption<List<TableConfigOptions.ColumnExpansionStrategy>>

TableConfigOptions.TABLE_COLUMN_EXPANSION_STRATEGY

static final ConfigOption<String>

TableConfigOptions.TABLE_DATABASE_NAME

static final ConfigOption<Boolean>

TableConfigOptions.TABLE_DML_SYNC

static final ConfigOption<Boolean>

TableConfigOptions.TABLE_DYNAMIC_TABLE_OPTIONS_ENABLED

static final ConfigOption<Integer>

ExecutionConfigOptions.TABLE_EXEC_ASYNC_LOOKUP_BUFFER_CAPACITY

static final ConfigOption<Boolean>

ExecutionConfigOptions.TABLE_EXEC_ASYNC_LOOKUP_KEY_ORDERED

static final ConfigOption<ExecutionConfigOptions.AsyncOutputMode>

ExecutionConfigOptions.TABLE_EXEC_ASYNC_LOOKUP_OUTPUT_MODE

static final ConfigOption<Duration>

ExecutionConfigOptions.TABLE_EXEC_ASYNC_LOOKUP_TIMEOUT

static final ConfigOption<Integer>

ExecutionConfigOptions.TABLE_EXEC_ASYNC_ML_PREDICT_MAX_CONCURRENT_OPERATIONS

static final ConfigOption<ExecutionConfigOptions.AsyncOutputMode>

ExecutionConfigOptions.TABLE_EXEC_ASYNC_ML_PREDICT_OUTPUT_MODE

static final ConfigOption<Duration>

ExecutionConfigOptions.TABLE_EXEC_ASYNC_ML_PREDICT_TIMEOUT

static final ConfigOption<Integer>

ExecutionConfigOptions.TABLE_EXEC_ASYNC_SCALAR_MAX_ATTEMPTS

static final ConfigOption<Integer>

ExecutionConfigOptions.TABLE_EXEC_ASYNC_SCALAR_MAX_CONCURRENT_OPERATIONS

static final ConfigOption<Duration>

ExecutionConfigOptions.TABLE_EXEC_ASYNC_SCALAR_RETRY_DELAY

static final ConfigOption<ExecutionConfigOptions.RetryStrategy>

ExecutionConfigOptions.TABLE_EXEC_ASYNC_SCALAR_RETRY_STRATEGY

static final ConfigOption<Duration>

ExecutionConfigOptions.TABLE_EXEC_ASYNC_SCALAR_TIMEOUT

static final ConfigOption<Boolean>

ExecutionConfigOptions.TABLE_EXEC_ASYNC_STATE_ENABLED

static final ConfigOption<Integer>

ExecutionConfigOptions.TABLE_EXEC_ASYNC_TABLE_MAX_CONCURRENT_OPERATIONS

static final ConfigOption<Integer>

ExecutionConfigOptions.TABLE_EXEC_ASYNC_TABLE_MAX_RETRIES

static final ConfigOption<Duration>

ExecutionConfigOptions.TABLE_EXEC_ASYNC_TABLE_RETRY_DELAY

static final ConfigOption<ExecutionConfigOptions.RetryStrategy>

ExecutionConfigOptions.TABLE_EXEC_ASYNC_TABLE_RETRY_STRATEGY

static final ConfigOption<Duration>

ExecutionConfigOptions.TABLE_EXEC_ASYNC_TABLE_TIMEOUT

static final ConfigOption<Integer>

ExecutionConfigOptions.TABLE_EXEC_ASYNC_VECTOR_SEARCH_MAX_CONCURRENT_OPERATIONS

static final ConfigOption<ExecutionConfigOptions.AsyncOutputMode>

ExecutionConfigOptions.TABLE_EXEC_ASYNC_VECTOR_SEARCH_OUTPUT_MODE

static final ConfigOption<Duration>

ExecutionConfigOptions.TABLE_EXEC_ASYNC_VECTOR_SEARCH_TIMEOUT

static final ConfigOption<Boolean>

ExecutionConfigOptions.TABLE_EXEC_DEDUPLICATE_INSERT_UPDATE_AFTER_SENSITIVE_ENABLED

static final ConfigOption<Boolean>

ExecutionConfigOptions.TABLE_EXEC_DEDUPLICATE_MINIBATCH_COMPACT_CHANGES_ENABLED

static final ConfigOption<Boolean>

ExecutionConfigOptions.TABLE_EXEC_DELTA_JOIN_CACHE_ENABLED

static final ConfigOption<Long>

ExecutionConfigOptions.TABLE_EXEC_DELTA_JOIN_LEFT_CACHE_SIZE

static final ConfigOption<Long>

ExecutionConfigOptions.TABLE_EXEC_DELTA_JOIN_RIGHT_CACHE_SIZE

static final ConfigOption<String>

ExecutionConfigOptions.TABLE_EXEC_DISABLED_OPERATORS

static final ConfigOption<Duration>

ExecutionConfigOptions.TABLE_EXEC_INTERVAL_JOIN_MIN_CLEAN_UP_INTERVAL

static final ConfigOption<ExecutionConfigOptions.LegacyCastBehaviour>

ExecutionConfigOptions.TABLE_EXEC_LEGACY_CAST_BEHAVIOUR

static final ConfigOption<Double>

ExecutionConfigOptions.TABLE_EXEC_LOCAL_HASH_AGG_ADAPTIVE_DISTINCT_VALUE_RATE_THRESHOLD

static final ConfigOption<Boolean>

ExecutionConfigOptions.TABLE_EXEC_LOCAL_HASH_AGG_ADAPTIVE_ENABLED

static final ConfigOption<Long>

ExecutionConfigOptions.TABLE_EXEC_LOCAL_HASH_AGG_ADAPTIVE_SAMPLING_THRESHOLD

static final ConfigOption<Duration>

ExecutionConfigOptions.TABLE_EXEC_MINIBATCH_ALLOW_LATENCY

static final ConfigOption<Boolean>

ExecutionConfigOptions.TABLE_EXEC_MINIBATCH_ENABLED

static final ConfigOption<Long>

ExecutionConfigOptions.TABLE_EXEC_MINIBATCH_SIZE

static final ConfigOption<Boolean>

ExecutionConfigOptions.TABLE_EXEC_OPERATOR_FUSION_CODEGEN_ENABLED

static final ConfigOption<Long>

ExecutionConfigOptions.TABLE_EXEC_RANK_TOPN_CACHE_SIZE

static final ConfigOption<Integer>

ExecutionConfigOptions.TABLE_EXEC_RESOURCE_DEFAULT_PARALLELISM

static final ConfigOption<MemorySize>

ExecutionConfigOptions.TABLE_EXEC_RESOURCE_EXTERNAL_BUFFER_MEMORY

static final ConfigOption<MemorySize>

ExecutionConfigOptions.TABLE_EXEC_RESOURCE_HASH_AGG_MEMORY

static final ConfigOption<MemorySize>

ExecutionConfigOptions.TABLE_EXEC_RESOURCE_HASH_JOIN_MEMORY

static final ConfigOption<MemorySize>

ExecutionConfigOptions.TABLE_EXEC_RESOURCE_SORT_MEMORY

static final ConfigOption<Boolean>

ExecutionConfigOptions.TABLE_EXEC_SIMPLIFY_OPERATOR_NAME_ENABLED

static final ConfigOption<ExecutionConfigOptions.SinkKeyedShuffle>

ExecutionConfigOptions.TABLE_EXEC_SINK_KEYED_SHUFFLE

static final ConfigOption<ExecutionConfigOptions.NestedEnforcer>

ExecutionConfigOptions.TABLE_EXEC_SINK_NESTED_CONSTRAINT_ENFORCER

static final ConfigOption<ExecutionConfigOptions.NotNullEnforcer>

ExecutionConfigOptions.TABLE_EXEC_SINK_NOT_NULL_ENFORCER

static final ConfigOption<Boolean>

ExecutionConfigOptions.TABLE_EXEC_SINK_REQUIRE_ON_CONFLICT

static final ConfigOption<ExecutionConfigOptions.RowtimeInserter>

ExecutionConfigOptions.TABLE_EXEC_SINK_ROWTIME_INSERTER

static final ConfigOption<ExecutionConfigOptions.TypeLengthEnforcer>

ExecutionConfigOptions.TABLE_EXEC_SINK_TYPE_LENGTH_ENFORCER

static final ConfigOption<ExecutionConfigOptions.UpsertMaterialize>

ExecutionConfigOptions.TABLE_EXEC_SINK_UPSERT_MATERIALIZE

static final ConfigOption<Long>

ExecutionConfigOptions.TABLE_EXEC_SINK_UPSERT_MATERIALIZE_ADAPTIVE_THRESHOLD_HIGH

static final ConfigOption<Long>

ExecutionConfigOptions.TABLE_EXEC_SINK_UPSERT_MATERIALIZE_ADAPTIVE_THRESHOLD_LOW

static final ConfigOption<ExecutionConfigOptions.SinkUpsertMaterializeStrategy>

ExecutionConfigOptions.TABLE_EXEC_SINK_UPSERT_MATERIALIZE_STRATEGY

static final ConfigOption<Boolean>

ExecutionConfigOptions.TABLE_EXEC_SORT_ASYNC_MERGE_ENABLED

static final ConfigOption<Integer>

ExecutionConfigOptions.TABLE_EXEC_SORT_DEFAULT_LIMIT

static final ConfigOption<Integer>

ExecutionConfigOptions.TABLE_EXEC_SORT_MAX_NUM_FILE_HANDLES

static final ConfigOption<Boolean>

ExecutionConfigOptions.TABLE_EXEC_SOURCE_CDC_EVENTS_DUPLICATE

static final ConfigOption<Duration>

ExecutionConfigOptions.TABLE_EXEC_SOURCE_IDLE_TIMEOUT

static final ConfigOption<MemorySize>

ExecutionConfigOptions.TABLE_EXEC_SPILL_COMPRESSION_BLOCK_SIZE

static final ConfigOption<Boolean>

ExecutionConfigOptions.TABLE_EXEC_SPILL_COMPRESSION_ENABLED

static final ConfigOption<String>

ExecutionConfigOptions.TABLE_EXEC_UID_FORMAT

static final ConfigOption<ExecutionConfigOptions.UidGeneration>

ExecutionConfigOptions.TABLE_EXEC_UID_GENERATION

static final ConfigOption<Integer>

ExecutionConfigOptions.TABLE_EXEC_WINDOW_AGG_BUFFER_SIZE_LIMIT

See org.apache.flink.table.runtime.operators.window.grouping.HeapWindowsGrouping.

static final ConfigOption<OptimizerConfigOptions.AdaptiveBroadcastJoinStrategy>

OptimizerConfigOptions.TABLE_OPTIMIZER_ADAPTIVE_BROADCAST_JOIN_STRATEGY

static final ConfigOption<Double>

OptimizerConfigOptions.TABLE_OPTIMIZER_ADAPTIVE_SKEWED_JOIN_OPTIMIZATION_SKEWED_FACTOR

static final ConfigOption<MemorySize>

OptimizerConfigOptions.TABLE_OPTIMIZER_ADAPTIVE_SKEWED_JOIN_OPTIMIZATION_SKEWED_THRESHOLD

static final ConfigOption<OptimizerConfigOptions.AdaptiveSkewedJoinOptimizationStrategy>

OptimizerConfigOptions.TABLE_OPTIMIZER_ADAPTIVE_SKEWED_JOIN_OPTIMIZATION_STRATEGY

static final ConfigOption<AggregatePhaseStrategy>

OptimizerConfigOptions.TABLE_OPTIMIZER_AGG_PHASE_STRATEGY

static final ConfigOption<Long>

OptimizerConfigOptions.TABLE_OPTIMIZER_BROADCAST_JOIN_THRESHOLD

static final ConfigOption<Integer>

OptimizerConfigOptions.TABLE_OPTIMIZER_BUSHY_JOIN_REORDER_THRESHOLD

static final ConfigOption<OptimizerConfigOptions.DeltaJoinStrategy>

OptimizerConfigOptions.TABLE_OPTIMIZER_DELTA_JOIN_STRATEGY

static final ConfigOption<Integer>

OptimizerConfigOptions.TABLE_OPTIMIZER_DISTINCT_AGG_SPLIT_BUCKET_NUM

static final ConfigOption<Boolean>

OptimizerConfigOptions.TABLE_OPTIMIZER_DISTINCT_AGG_SPLIT_ENABLED

static final ConfigOption<Boolean>

OptimizerConfigOptions.TABLE_OPTIMIZER_DYNAMIC_FILTERING_ENABLED

static final ConfigOption<Boolean>

OptimizerConfigOptions.TABLE_OPTIMIZER_INCREMENTAL_AGG_ENABLED

static final ConfigOption<Boolean>

OptimizerConfigOptions.TABLE_OPTIMIZER_JOIN_REORDER_ENABLED

static final ConfigOption<Boolean>

OptimizerConfigOptions.TABLE_OPTIMIZER_MULTI_JOIN_ENABLED

static final ConfigOption<Boolean>

OptimizerConfigOptions.TABLE_OPTIMIZER_MULTIPLE_INPUT_ENABLED

static final ConfigOption<OptimizerConfigOptions.NonDeterministicUpdateStrategy>

OptimizerConfigOptions.TABLE_OPTIMIZER_NONDETERMINISTIC_UPDATE_STRATEGY

static final ConfigOption<Integer>

OptimizerConfigOptions.TABLE_OPTIMIZER_PTF_MAX_TABLES

static final ConfigOption<Boolean>

OptimizerConfigOptions.TABLE_OPTIMIZER_REUSE_OPTIMIZE_BLOCK_WITH_DIGEST_ENABLED

static final ConfigOption<Boolean>

OptimizerConfigOptions.TABLE_OPTIMIZER_REUSE_SINK_ENABLED

static final ConfigOption<Boolean>

OptimizerConfigOptions.TABLE_OPTIMIZER_REUSE_SOURCE_ENABLED

static final ConfigOption<Boolean>

OptimizerConfigOptions.TABLE_OPTIMIZER_REUSE_SUB_PLAN_ENABLED

static final ConfigOption<Boolean>

OptimizerConfigOptions.TABLE_OPTIMIZER_RUNTIME_FILTER_ENABLED

static final ConfigOption<MemorySize>

OptimizerConfigOptions.TABLE_OPTIMIZER_RUNTIME_FILTER_MAX_BUILD_DATA_SIZE

The data volume of build side needs to be under this value.

static final ConfigOption<Double>

OptimizerConfigOptions.TABLE_OPTIMIZER_RUNTIME_FILTER_MIN_FILTER_RATIO

The filtering ratio of runtime filter needs to be over this value.

static final ConfigOption<MemorySize>

OptimizerConfigOptions.TABLE_OPTIMIZER_RUNTIME_FILTER_MIN_PROBE_DATA_SIZE

The data volume of probe side needs to be over this value.

static final ConfigOption<Boolean>

OptimizerConfigOptions.TABLE_OPTIMIZER_SOURCE_REPORT_STATISTICS_ENABLED

static final ConfigOption<Boolean>

OptimizerConfigOptions.TABLE_OPTIMIZER_SQL2REL_PROJECT_MERGE_ENABLED

static final ConfigOption<Boolean>

OptimizerConfigOptions.TABLE_OPTIMIZER_UNIONALL_AS_BREAKPOINT_ENABLED

static final ConfigOption<Boolean>

TableConfigOptions.TABLE_RTAS_CTAS_ATOMICITY_ENABLED

static final ConfigOption<String>

TableConfigOptions.TABLE_SQL_DIALECT

static final ConfigOption<Integer>

ExecutionConfigOptions.UNBOUNDED_OVER_VERSION

Methods in org.apache.flink.table.api.config that return types with arguments of type ConfigOption

Modifier and Type

Method

Description

static org.apache.flink.shaded.guava33.com.google.common.collect.ImmutableSet<ConfigOption>

MLPredictRuntimeConfigOptions.getSupportedOptions()
Uses of ConfigOption in org.apache.flink.table.factories

Fields in org.apache.flink.table.factories declared as ConfigOption

Modifier and Type

Field

Description

static final ConfigOption<String>

FactoryUtil.CONNECTOR

static final ConfigOption<String>

FactoryUtil.FORMAT

static final ConfigOption<Integer>

FactoryUtil.PROPERTY_VERSION

Describes the property version.

static final ConfigOption<String>

FactoryUtil.PROVIDER

static final ConfigOption<Integer>

FactoryUtil.SINK_PARALLELISM

static final ConfigOption<Duration>

FactoryUtil.SOURCE_IDLE_TIMEOUT

static final ConfigOption<Integer>

FactoryUtil.SOURCE_PARALLELISM

static final ConfigOption<List<String>>

FactoryUtil.SQL_GATEWAY_ENDPOINT_TYPE

static final ConfigOption<String>

FactoryUtil.WATERMARK_ALIGNMENT_GROUP

static final ConfigOption<Duration>

FactoryUtil.WATERMARK_ALIGNMENT_MAX_DRIFT

static final ConfigOption<Duration>

FactoryUtil.WATERMARK_ALIGNMENT_UPDATE_INTERVAL

static final ConfigOption<org.apache.flink.table.watermark.WatermarkEmitStrategy>

FactoryUtil.WATERMARK_EMIT_STRATEGY

static final ConfigOption<String>

FactoryUtil.WORKFLOW_SCHEDULER_TYPE

Methods in org.apache.flink.table.factories with parameters of type ConfigOption

Modifier and Type

Method

Description

<I, F extends org.apache.flink.table.factories.DecodingFormatFactory> org.apache.flink.table.connector.format.DecodingFormat

FactoryUtil.TableFactoryHelper.discoverDecodingFormat(Class<F> formatFactoryClass, 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> org.apache.flink.table.connector.format.EncodingFormat

FactoryUtil.TableFactoryHelper.discoverEncodingFormat(Class<F> formatFactoryClass, 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> Optional<org.apache.flink.table.connector.format.DecodingFormat>

FactoryUtil.TableFactoryHelper.discoverOptionalDecodingFormat(Class<F> formatFactoryClass, 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> Optional<org.apache.flink.table.connector.format.EncodingFormat>

FactoryUtil.TableFactoryHelper.discoverOptionalEncodingFormat(Class<F> formatFactoryClass, ConfigOption<String> formatOption)

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

static String

FactoryUtil.getFormatPrefix(ConfigOption<String> formatOption, String formatIdentifier)

Returns the required option prefix for options of the given format.

Method parameters in org.apache.flink.table.factories with type arguments of type ConfigOption

Modifier and Type

Method

Description

static void

FactoryUtil.validateFactoryOptions(Set<ConfigOption<?>> requiredOptions, Set<ConfigOption<?>> optionalOptions, ReadableConfig options)

Validates the required options and optional options.

Constructors in org.apache.flink.table.factories with parameters of type ConfigOption

Modifier

Constructor

Description

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

Uses of Classorg.apache.flink.configuration.ConfigOption

Uses of ConfigOption in io.confluent.flink.plugin

Uses of ConfigOption in org.apache.flink.configuration

Uses of ConfigOption in org.apache.flink.table.api

Uses of ConfigOption in org.apache.flink.table.api.config

Uses of ConfigOption in org.apache.flink.table.factories

Uses of Class
org.apache.flink.configuration.ConfigOption