Class ExpireSnapshots

java.lang.Object
org.apache.iceberg.flink.maintenance.api.ExpireSnapshots

public class ExpireSnapshots extends Object
Deletes expired snapshots and the corresponding files.
  • Method Details

    • builder

      public static ExpireSnapshots.Builder builder()
      Creates the builder for creating a stream which expires snapshots for the table.