ExpireSnapshots.Builder

java.lang.Object

org.apache.iceberg.flink.maintenance.api.MaintenanceTaskBuilder<ExpireSnapshots.Builder>

org.apache.iceberg.flink.maintenance.api.ExpireSnapshots.Builder

Enclosing class:: ExpireSnapshots

public static class ExpireSnapshots.Builder extends MaintenanceTaskBuilder<ExpireSnapshots.Builder>

Constructor Summary

Constructors

Constructor

Description

Builder()
Method Summary

Modifier and Type

Method

Description

ExpireSnapshots.Builder

deleteBatchSize(int newDeleteBatchSize)

Size of the batch used to deleting the files.

ExpireSnapshots.Builder

maxSnapshotAge(Duration newMaxSnapshotAge)

The snapshots older than this age will be removed.

ExpireSnapshots.Builder

planningWorkerPoolSize(int newPlanningWorkerPoolSize)

The worker pool size used to calculate the files to delete.

ExpireSnapshots.Builder

retainLast(int newNumSnapshots)

The minimum number of Snapshots to retain.

Methods inherited from class org.apache.iceberg.flink.maintenance.api.MaintenanceTaskBuilder
index, operatorName, parallelism, parallelism, scheduleOnCommitCount, scheduleOnDataFileCount, scheduleOnDataFileSize, scheduleOnEqDeleteFileCount, scheduleOnEqDeleteRecordCount, scheduleOnInterval, scheduleOnPosDeleteFileCount, scheduleOnPosDeleteRecordCount, slotSharingGroup, slotSharingGroup, tableLoader, tableName, taskName, uidSuffix, uidSuffix

Methods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Details
- Builder
  
  public Builder()
Method Details
- maxSnapshotAge
  
  public ExpireSnapshots.Builder maxSnapshotAge(Duration newMaxSnapshotAge)
  
  The snapshots older than this age will be removed.
  
  Parameters:
  
  newMaxSnapshotAge - of the snapshots to be removed
- retainLast
  
  public ExpireSnapshots.Builder retainLast(int newNumSnapshots)
  
  The minimum number of Snapshots to retain. For more details description see ExpireSnapshots.retainLast(int).
  
  Parameters:
  
  newNumSnapshots - number of snapshots to retain
- planningWorkerPoolSize
  
  public ExpireSnapshots.Builder planningWorkerPoolSize(int newPlanningWorkerPoolSize)
  
  The worker pool size used to calculate the files to delete. If not set, the shared worker pool is used.
  
  Parameters:
  
  newPlanningWorkerPoolSize - for planning files to delete
- deleteBatchSize
  
  public ExpireSnapshots.Builder deleteBatchSize(int newDeleteBatchSize)
  
  Size of the batch used to deleting the files.
  
  Parameters:
  
  newDeleteBatchSize - used for deleting