Package org.apache.iceberg.flink.sink.dynamic

Class FlinkDynamicSinkOptions

java.lang.Object

org.apache.iceberg.flink.sink.dynamic.FlinkDynamicSinkOptions

@Experimental
public class FlinkDynamicSinkOptions
extends Object

Field Summary

Fields

Modifier and Type	Field	Description
static final org.apache.flink.configuration.ConfigOption<Integer>	CACHE_MAX_SIZE
static final org.apache.flink.configuration.ConfigOption<Long>	CACHE_REFRESH_MS
static final org.apache.flink.configuration.ConfigOption<Boolean>	CASE_SENSITIVE
static final org.apache.flink.configuration.ConfigOption<Boolean>	DROP_UNUSED_COLUMNS
static final org.apache.flink.configuration.ConfigOption<Boolean>	IMMEDIATE_TABLE_UPDATE
static final org.apache.flink.configuration.ConfigOption<Integer>	INPUT_SCHEMAS_PER_TABLE_CACHE_MAX_SIZE

Method Summary

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Field Details

CACHE_MAX_SIZE

public static final org.apache.flink.configuration.ConfigOption<Integer> CACHE_MAX_SIZE

IMMEDIATE_TABLE_UPDATE

public static final org.apache.flink.configuration.ConfigOption<Boolean> IMMEDIATE_TABLE_UPDATE

DROP_UNUSED_COLUMNS

public static final org.apache.flink.configuration.ConfigOption<Boolean> DROP_UNUSED_COLUMNS

CACHE_REFRESH_MS

public static final org.apache.flink.configuration.ConfigOption<Long> CACHE_REFRESH_MS

INPUT_SCHEMAS_PER_TABLE_CACHE_MAX_SIZE

public static final org.apache.flink.configuration.ConfigOption<Integer> INPUT_SCHEMAS_PER_TABLE_CACHE_MAX_SIZE

CASE_SENSITIVE

public static final org.apache.flink.configuration.ConfigOption<Boolean> CASE_SENSITIVE