Package org.apache.iceberg.flink
Class FlinkWriteOptions
java.lang.Object
org.apache.iceberg.flink.FlinkWriteOptions
Flink sink write options
-
Field Summary
Modifier and TypeFieldDescriptionstatic final org.apache.flink.configuration.ConfigOption<String>
static final org.apache.flink.configuration.ConfigOption<String>
static final org.apache.flink.configuration.ConfigOption<String>
static final org.apache.flink.configuration.ConfigOption<String>
static final org.apache.flink.configuration.ConfigOption<String>
static final org.apache.flink.configuration.ConfigOption<Boolean>
static final org.apache.flink.configuration.ConfigOption<Duration>
static final org.apache.flink.configuration.ConfigOption<Long>
static final org.apache.flink.configuration.ConfigOption<String>
static final org.apache.flink.configuration.ConfigOption<Integer>
static final org.apache.flink.configuration.ConfigOption<Boolean>
-
Method Summary
-
Field Details
-
WRITE_FORMAT
-
TARGET_FILE_SIZE_BYTES
-
COMPRESSION_CODEC
-
COMPRESSION_LEVEL
-
COMPRESSION_STRATEGY
-
WRITE_UPSERT_ENABLED
-
OVERWRITE_MODE
-
DISTRIBUTION_MODE
-
BRANCH
-
WRITE_PARALLELISM
-
TABLE_REFRESH_INTERVAL
@Experimental public static final org.apache.flink.configuration.ConfigOption<Duration> TABLE_REFRESH_INTERVAL
-