Package org.apache.iceberg.flink
Class FlinkConfigOptions
java.lang.Object
org.apache.iceberg.flink.FlinkConfigOptions
When constructing Flink Iceberg source via Java API, configs can be set in
Configuration
passed to source builder. E.g.
configuration.setBoolean(FlinkConfigOptions.TABLE_EXEC_ICEBERG_INFER_SOURCE_PARALLELISM, true); FlinkSource.forRowData() .flinkConf(configuration) ...
When using Flink SQL/table API, connector options can be set in Flink's TableEnvironment
.
TableEnvironment tEnv = createTableEnv(); tEnv.getConfig() .getConfiguration() .setBoolean(FlinkConfigOptions.TABLE_EXEC_ICEBERG_INFER_SOURCE_PARALLELISM, true);
-
Field Summary
Modifier and TypeFieldDescriptionstatic final org.apache.flink.configuration.ConfigOption<Integer>
static final org.apache.flink.configuration.ConfigOption<Boolean>
static final org.apache.flink.configuration.ConfigOption<Boolean>
static final org.apache.flink.configuration.ConfigOption<Integer>
static final org.apache.flink.configuration.ConfigOption<Boolean>
static final org.apache.flink.configuration.ConfigOption<Integer>
static final org.apache.flink.configuration.ConfigOption<SplitAssignerType>
-
Method Summary
-
Field Details
-
TABLE_EXEC_ICEBERG_INFER_SOURCE_PARALLELISM
public static final org.apache.flink.configuration.ConfigOption<Boolean> TABLE_EXEC_ICEBERG_INFER_SOURCE_PARALLELISM -
TABLE_EXEC_ICEBERG_INFER_SOURCE_PARALLELISM_MAX
public static final org.apache.flink.configuration.ConfigOption<Integer> TABLE_EXEC_ICEBERG_INFER_SOURCE_PARALLELISM_MAX -
TABLE_EXEC_ICEBERG_EXPOSE_SPLIT_LOCALITY_INFO
public static final org.apache.flink.configuration.ConfigOption<Boolean> TABLE_EXEC_ICEBERG_EXPOSE_SPLIT_LOCALITY_INFO -
SOURCE_READER_FETCH_BATCH_RECORD_COUNT
public static final org.apache.flink.configuration.ConfigOption<Integer> SOURCE_READER_FETCH_BATCH_RECORD_COUNT -
TABLE_EXEC_ICEBERG_WORKER_POOL_SIZE
public static final org.apache.flink.configuration.ConfigOption<Integer> TABLE_EXEC_ICEBERG_WORKER_POOL_SIZE -
TABLE_EXEC_ICEBERG_USE_FLIP27_SOURCE
public static final org.apache.flink.configuration.ConfigOption<Boolean> TABLE_EXEC_ICEBERG_USE_FLIP27_SOURCE -
TABLE_EXEC_SPLIT_ASSIGNER_TYPE
public static final org.apache.flink.configuration.ConfigOption<SplitAssignerType> TABLE_EXEC_SPLIT_ASSIGNER_TYPE
-