public class FlinkConfigOptions
extends java.lang.Object
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);
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 |
public static final org.apache.flink.configuration.ConfigOption<java.lang.Boolean> TABLE_EXEC_ICEBERG_INFER_SOURCE_PARALLELISM
public static final org.apache.flink.configuration.ConfigOption<java.lang.Integer> TABLE_EXEC_ICEBERG_INFER_SOURCE_PARALLELISM_MAX
public static final org.apache.flink.configuration.ConfigOption<java.lang.Boolean> TABLE_EXEC_ICEBERG_EXPOSE_SPLIT_LOCALITY_INFO
public static final org.apache.flink.configuration.ConfigOption<java.lang.Integer> SOURCE_READER_FETCH_BATCH_RECORD_COUNT
public static final org.apache.flink.configuration.ConfigOption<java.lang.Integer> TABLE_EXEC_ICEBERG_WORKER_POOL_SIZE
public static final org.apache.flink.configuration.ConfigOption<java.lang.Boolean> TABLE_EXEC_ICEBERG_USE_FLIP27_SOURCE
public static final org.apache.flink.configuration.ConfigOption<SplitAssignerType> TABLE_EXEC_SPLIT_ASSIGNER_TYPE