Package org.apache.iceberg.actions
Interface ConvertEqualityDeleteStrategy
-
public interface ConvertEqualityDeleteStrategy
A strategy for the action to convert equality delete to position deletes.
-
-
Method Summary
All Methods Instance Methods Abstract Methods Modifier and Type Method Description java.lang.Iterable<DeleteFile>
convertDeleteFiles(java.lang.Iterable<DeleteFile> deleteFilesToConvert)
Define how to convert the deletes.java.lang.String
name()
Returns the name of this convert deletes strategyRewritePositionDeleteStrategy
options(java.util.Map<java.lang.String,java.lang.String> options)
Sets options to be used with this strategyjava.lang.Iterable<java.lang.Iterable<FileScanTask>>
planDeleteFileGroups(java.lang.Iterable<FileScanTask> dataFiles)
Groups delete files into lists which will be processed in a single executable unit.java.lang.Iterable<DeleteFile>
selectDeleteFiles(java.lang.Iterable<DeleteFile> deleteFiles)
Select the delete files to convert.Table
table()
Returns the table being modified by this convert strategyjava.util.Set<java.lang.String>
validOptions()
Returns a set of options which this convert strategy can use.
-
-
-
Method Detail
-
name
java.lang.String name()
Returns the name of this convert deletes strategy
-
table
Table table()
Returns the table being modified by this convert strategy
-
validOptions
java.util.Set<java.lang.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
RewritePositionDeleteStrategy options(java.util.Map<java.lang.String,java.lang.String> options)
Sets options to be used with this strategy
-
selectDeleteFiles
java.lang.Iterable<DeleteFile> selectDeleteFiles(java.lang.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
java.lang.Iterable<java.lang.Iterable<FileScanTask>> planDeleteFileGroups(java.lang.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
java.lang.Iterable<DeleteFile> convertDeleteFiles(java.lang.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.
-
-