Package org.apache.iceberg.flink
Class 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 inConfiguration
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 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
-
-
-
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
-
-