Package org.apache.iceberg.flink

Class FlinkWriteOptions

java.lang.Object

org.apache.iceberg.flink.FlinkWriteOptions

public class FlinkWriteOptions
extends java.lang.Object

Flink sink write options

Field Summary

Fields

Modifier and Type	Field	Description
static org.apache.flink.configuration.ConfigOption<java.lang.String>	BRANCH
static org.apache.flink.configuration.ConfigOption<java.lang.String>	COMPRESSION_CODEC
static org.apache.flink.configuration.ConfigOption<java.lang.String>	COMPRESSION_LEVEL
static org.apache.flink.configuration.ConfigOption<java.lang.String>	COMPRESSION_STRATEGY
static org.apache.flink.configuration.ConfigOption<java.lang.String>	DISTRIBUTION_MODE
static org.apache.flink.configuration.ConfigOption<java.lang.Boolean>	OVERWRITE_MODE
static org.apache.flink.configuration.ConfigOption<java.lang.Double>	RANGE_DISTRIBUTION_SORT_KEY_BASE_WEIGHT
static org.apache.flink.configuration.ConfigOption<java.lang.String>	RANGE_DISTRIBUTION_STATISTICS_TYPE
static org.apache.flink.configuration.ConfigOption<java.time.Duration>	TABLE_REFRESH_INTERVAL
static org.apache.flink.configuration.ConfigOption<java.lang.Long>	TARGET_FILE_SIZE_BYTES
static org.apache.flink.configuration.ConfigOption<java.lang.String>	WRITE_FORMAT
static org.apache.flink.configuration.ConfigOption<java.lang.Integer>	WRITE_PARALLELISM
static org.apache.flink.configuration.ConfigOption<java.lang.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 Detail

WRITE_FORMAT

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

TARGET_FILE_SIZE_BYTES

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

COMPRESSION_CODEC

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

COMPRESSION_LEVEL

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

COMPRESSION_STRATEGY

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

WRITE_UPSERT_ENABLED

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

OVERWRITE_MODE

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

DISTRIBUTION_MODE

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

RANGE_DISTRIBUTION_STATISTICS_TYPE

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

RANGE_DISTRIBUTION_SORT_KEY_BASE_WEIGHT

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

BRANCH

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

WRITE_PARALLELISM

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

TABLE_REFRESH_INTERVAL

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