Package org.apache.iceberg.flink

Class FlinkWriteOptions

java.lang.Object

org.apache.iceberg.flink.FlinkWriteOptions

public class FlinkWriteOptions
extends Object

Flink sink write options

Field Summary

Fields

Modifier and Type	Field	Description
static final org.apache.flink.configuration.ConfigOption<String>	BRANCH
static final org.apache.flink.configuration.ConfigOption<String>	COMPRESSION_CODEC
static final org.apache.flink.configuration.ConfigOption<String>	COMPRESSION_LEVEL
static final org.apache.flink.configuration.ConfigOption<String>	COMPRESSION_STRATEGY
static final org.apache.flink.configuration.ConfigOption<String>	DISTRIBUTION_MODE
static final org.apache.flink.configuration.ConfigOption<Boolean>	OVERWRITE_MODE
static final org.apache.flink.configuration.ConfigOption<Double>	RANGE_DISTRIBUTION_SORT_KEY_BASE_WEIGHT
static final org.apache.flink.configuration.ConfigOption<String>	RANGE_DISTRIBUTION_STATISTICS_TYPE
static final org.apache.flink.configuration.ConfigOption<Duration>	TABLE_REFRESH_INTERVAL
static final org.apache.flink.configuration.ConfigOption<Long>	TARGET_FILE_SIZE_BYTES
static final org.apache.flink.configuration.ConfigOption<String>	WRITE_FORMAT
static final org.apache.flink.configuration.ConfigOption<Integer>	WRITE_PARALLELISM
static final org.apache.flink.configuration.ConfigOption<Boolean>	WRITE_UPSERT_ENABLED

Method Summary

Methods inherited from class java.lang.Object

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

Field Details

WRITE_FORMAT

public static final org.apache.flink.configuration.ConfigOption<String> WRITE_FORMAT

TARGET_FILE_SIZE_BYTES

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

COMPRESSION_CODEC

public static final org.apache.flink.configuration.ConfigOption<String> COMPRESSION_CODEC

COMPRESSION_LEVEL

public static final org.apache.flink.configuration.ConfigOption<String> COMPRESSION_LEVEL

COMPRESSION_STRATEGY

public static final org.apache.flink.configuration.ConfigOption<String> COMPRESSION_STRATEGY

WRITE_UPSERT_ENABLED

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

OVERWRITE_MODE

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

DISTRIBUTION_MODE

public static final org.apache.flink.configuration.ConfigOption<String> DISTRIBUTION_MODE

RANGE_DISTRIBUTION_STATISTICS_TYPE

public static final org.apache.flink.configuration.ConfigOption<String> RANGE_DISTRIBUTION_STATISTICS_TYPE

RANGE_DISTRIBUTION_SORT_KEY_BASE_WEIGHT

public static final org.apache.flink.configuration.ConfigOption<Double> RANGE_DISTRIBUTION_SORT_KEY_BASE_WEIGHT

BRANCH

public static final org.apache.flink.configuration.ConfigOption<String> BRANCH

WRITE_PARALLELISM

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

TABLE_REFRESH_INTERVAL

@Experimental
public static final org.apache.flink.configuration.ConfigOption<Duration> TABLE_REFRESH_INTERVAL