Class FlinkWriteOptions

java.lang.Object
org.apache.iceberg.flink.FlinkWriteOptions

public class FlinkWriteOptions extends Object
Flink sink write options
  • 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
    • 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