Package org.apache.iceberg.flink

Class FlinkConfigOptions

java.lang.Object

org.apache.iceberg.flink.FlinkConfigOptions

public class FlinkConfigOptions
extends Object

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

Fields

Modifier and Type	Field	Description
static final org.apache.flink.configuration.ConfigOption<Integer>	SOURCE_READER_FETCH_BATCH_RECORD_COUNT
static final org.apache.flink.configuration.ConfigOption<Boolean>	TABLE_EXEC_ICEBERG_EXPOSE_SPLIT_LOCALITY_INFO
static final org.apache.flink.configuration.ConfigOption<Boolean>	TABLE_EXEC_ICEBERG_INFER_SOURCE_PARALLELISM
static final org.apache.flink.configuration.ConfigOption<Integer>	TABLE_EXEC_ICEBERG_INFER_SOURCE_PARALLELISM_MAX
static final org.apache.flink.configuration.ConfigOption<Boolean>	TABLE_EXEC_ICEBERG_USE_FLIP27_SOURCE
static final org.apache.flink.configuration.ConfigOption<Boolean>	TABLE_EXEC_ICEBERG_USE_V2_SINK
static final org.apache.flink.configuration.ConfigOption<Integer>	TABLE_EXEC_ICEBERG_WORKER_POOL_SIZE
static final org.apache.flink.configuration.ConfigOption<SplitAssignerType>	TABLE_EXEC_SPLIT_ASSIGNER_TYPE

Method Summary

Methods inherited from class java.lang.Object

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

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_ICEBERG_USE_V2_SINK

public static final org.apache.flink.configuration.ConfigOption<Boolean> TABLE_EXEC_ICEBERG_USE_V2_SINK

TABLE_EXEC_SPLIT_ASSIGNER_TYPE

public static final org.apache.flink.configuration.ConfigOption<SplitAssignerType> TABLE_EXEC_SPLIT_ASSIGNER_TYPE