Class FlinkConfigOptions


  • public class FlinkConfigOptions
    extends java.lang.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 Detail

      • TABLE_EXEC_ICEBERG_INFER_SOURCE_PARALLELISM

        public static final org.apache.flink.configuration.ConfigOption<java.lang.Boolean> TABLE_EXEC_ICEBERG_INFER_SOURCE_PARALLELISM
      • TABLE_EXEC_ICEBERG_INFER_SOURCE_PARALLELISM_MAX

        public static final org.apache.flink.configuration.ConfigOption<java.lang.Integer> TABLE_EXEC_ICEBERG_INFER_SOURCE_PARALLELISM_MAX
      • TABLE_EXEC_ICEBERG_EXPOSE_SPLIT_LOCALITY_INFO

        public static final org.apache.flink.configuration.ConfigOption<java.lang.Boolean> TABLE_EXEC_ICEBERG_EXPOSE_SPLIT_LOCALITY_INFO
      • SOURCE_READER_FETCH_BATCH_RECORD_COUNT

        public static final org.apache.flink.configuration.ConfigOption<java.lang.Integer> SOURCE_READER_FETCH_BATCH_RECORD_COUNT
      • TABLE_EXEC_ICEBERG_WORKER_POOL_SIZE

        public static final org.apache.flink.configuration.ConfigOption<java.lang.Integer> TABLE_EXEC_ICEBERG_WORKER_POOL_SIZE