Package org.apache.iceberg.actions

Interface ConvertEqualityDeleteStrategy

public interface ConvertEqualityDeleteStrategy
A strategy for the action to convert equality delete to position deletes.

  • Method Details

    • name

      String name()
      Returns the name of this convert deletes strategy

    • table

      Table table()
      Returns the table being modified by this convert strategy

    • validOptions

      Set<String> validOptions()
      Returns a set of options which this convert strategy can use. This is an allowed-list and any options not specified here will be rejected at runtime.

    • options

      ConvertEqualityDeleteStrategy options(Map<String,String> options)
      Sets options to be used with this strategy

    • selectDeleteFiles

      Iterable<DeleteFile> selectDeleteFiles(Iterable<DeleteFile> deleteFiles)
      Select the delete files to convert.
      Parameters:
      deleteFiles - iterable of delete files in a group.
      Returns:
      iterable of original delete file to be converted.

    • planDeleteFileGroups

      Iterable<Iterable<FileScanTask>> planDeleteFileGroups(Iterable<FileScanTask> dataFiles)
      Groups delete files into lists which will be processed in a single executable unit. Each group will end up being committed as an independent set of changes. This creates the jobs which will eventually be run as by the underlying Action.
      Parameters:
      dataFiles - iterable of data files that contain the DeleteFile to be converted
      Returns:
      iterable of lists of FileScanTasks which will be processed together

    • convertDeleteFiles

      Iterable<DeleteFile> convertDeleteFiles(Iterable<DeleteFile> deleteFilesToConvert)
      Define how to convert the deletes.
      Parameters:
      deleteFilesToConvert - a group of files to be converted together
      Returns:
      iterable of delete files used to replace the original delete files.