Package org.apache.iceberg.flink.maintenance.api

Class ConvertEqualityDeletesConfig

java.lang.Object
org.apache.iceberg.flink.maintenance.api.ConvertEqualityDeletesConfig
public class ConvertEqualityDeletesConfig extends Object

  • Field Details

    • PREFIX

      public static final String PREFIX
      See Also:

    • TARGET_BRANCH

      public static final String TARGET_BRANCH
      See Also:

    • TARGET_BRANCH_OPTION

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

    • SCHEDULE_ON_COMMIT_COUNT

      public static final String SCHEDULE_ON_COMMIT_COUNT
      See Also:

    • SCHEDULE_ON_COMMIT_COUNT_OPTION

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

    • SCHEDULE_ON_INTERVAL_SECOND

      public static final String SCHEDULE_ON_INTERVAL_SECOND
      See Also:

    • SCHEDULE_ON_INTERVAL_SECOND_OPTION

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

  • Constructor Details

    • ConvertEqualityDeletesConfig

      public ConvertEqualityDeletesConfig(Table table, Map<String,String> writeOptions, org.apache.flink.configuration.ReadableConfig readableConfig)

  • Method Details

    • targetBranch

      public String targetBranch()
      Gets the target branch, or null to convert in place on the sink's write branch.

    • scheduleOnCommitCount

      public int scheduleOnCommitCount()
      Gets the number of commits that trigger a conversion.

    • scheduleOnIntervalSecond

      public Long scheduleOnIntervalSecond()
      Gets the time interval (in seconds) between conversions, or null when not set.