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 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