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

Class DeleteOrphanFilesConfig

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

  • Field Details

    • PREFIX

      public static final String PREFIX
      See Also:

    • 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

    • MIN_AGE_SECONDS

      public static final String MIN_AGE_SECONDS
      See Also:

    • MIN_AGE_SECONDS_OPTION

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

    • DELETE_BATCH_SIZE

      public static final String DELETE_BATCH_SIZE
      See Also:

    • DELETE_BATCH_SIZE_OPTION

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

    • LOCATION

      public static final String LOCATION
      See Also:

    • LOCATION_OPTION

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

    • USE_PREFIX_LISTING

      public static final String USE_PREFIX_LISTING
      See Also:

    • USE_PREFIX_LISTING_OPTION

      public static final org.apache.flink.configuration.ConfigOption<Boolean> USE_PREFIX_LISTING_OPTION

    • PLANNING_WORKER_POOL_SIZE

      public static final String PLANNING_WORKER_POOL_SIZE
      See Also:

    • PLANNING_WORKER_POOL_SIZE_OPTION

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

    • EQUAL_SCHEMES

      public static final String EQUAL_SCHEMES
      See Also:

    • EQUAL_SCHEMES_OPTION

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

    • EQUAL_AUTHORITIES

      public static final String EQUAL_AUTHORITIES
      See Also:

    • EQUAL_AUTHORITIES_OPTION

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

    • PREFIX_MISMATCH_MODE

      public static final String PREFIX_MISMATCH_MODE
      See Also:

    • PREFIX_MISMATCH_MODE_OPTION

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

  • Constructor Details

    • DeleteOrphanFilesConfig

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

  • Method Details

    • scheduleOnIntervalSecond

      public long scheduleOnIntervalSecond()

    • minAgeSeconds

      public long minAgeSeconds()

    • deleteBatchSize

      public int deleteBatchSize()

    • location

      public String location()

    • usePrefixListing

      public boolean usePrefixListing()

    • planningWorkerPoolSize

      public Integer planningWorkerPoolSize()

    • equalSchemes

      public Map<String,String> equalSchemes()

    • equalAuthorities

      public Map<String,String> equalAuthorities()

    • prefixMismatchMode

      public DeleteOrphanFiles.PrefixMismatchMode prefixMismatchMode()