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.Long>
TARGET_FILE_SIZE_BYTES
static org.apache.flink.configuration.ConfigOption<java.lang.String>
WRITE_FORMAT
static org.apache.flink.configuration.ConfigOption<java.lang.Boolean>
WRITE_UPSERT_ENABLED
-
-
-
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
-
BRANCH
public static final org.apache.flink.configuration.ConfigOption<java.lang.String> BRANCH
-
-