FlinkConfigOptions

java.lang.Object
- org.apache.iceberg.flink.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 Summary

Fields
Modifier and Type	Field and Description
`static org.apache.flink.configuration.ConfigOption<java.lang.Integer>`	`SOURCE_READER_FETCH_BATCH_RECORD_COUNT`
`static org.apache.flink.configuration.ConfigOption<java.lang.Boolean>`	`TABLE_EXEC_ICEBERG_EXPOSE_SPLIT_LOCALITY_INFO`
`static org.apache.flink.configuration.ConfigOption<java.lang.Boolean>`	`TABLE_EXEC_ICEBERG_INFER_SOURCE_PARALLELISM`
`static org.apache.flink.configuration.ConfigOption<java.lang.Integer>`	`TABLE_EXEC_ICEBERG_INFER_SOURCE_PARALLELISM_MAX`
`static org.apache.flink.configuration.ConfigOption<java.lang.Boolean>`	`TABLE_EXEC_ICEBERG_USE_FLIP27_SOURCE`
`static org.apache.flink.configuration.ConfigOption<java.lang.Integer>`	`TABLE_EXEC_ICEBERG_WORKER_POOL_SIZE`
`static 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 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

TABLE_EXEC_ICEBERG_USE_FLIP27_SOURCE

public static final org.apache.flink.configuration.ConfigOption<java.lang.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

Class FlinkConfigOptions