public class FlinkWriteOptions
extends java.lang.Object
Modifier and Type | Field and 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.Integer> |
WRITE_PARALLELISM |
static org.apache.flink.configuration.ConfigOption<java.lang.Boolean> |
WRITE_UPSERT_ENABLED |
public static final org.apache.flink.configuration.ConfigOption<java.lang.String> WRITE_FORMAT
public static final org.apache.flink.configuration.ConfigOption<java.lang.Long> TARGET_FILE_SIZE_BYTES
public static final org.apache.flink.configuration.ConfigOption<java.lang.String> COMPRESSION_CODEC
public static final org.apache.flink.configuration.ConfigOption<java.lang.String> COMPRESSION_LEVEL
public static final org.apache.flink.configuration.ConfigOption<java.lang.String> COMPRESSION_STRATEGY
public static final org.apache.flink.configuration.ConfigOption<java.lang.Boolean> WRITE_UPSERT_ENABLED
public static final org.apache.flink.configuration.ConfigOption<java.lang.Boolean> OVERWRITE_MODE
public static final org.apache.flink.configuration.ConfigOption<java.lang.String> DISTRIBUTION_MODE
public static final org.apache.flink.configuration.ConfigOption<java.lang.String> BRANCH
public static final org.apache.flink.configuration.ConfigOption<java.lang.Integer> WRITE_PARALLELISM