Package org.apache.iceberg.actions
Class SizeBasedPositionDeletesRewriter
- java.lang.Object
-
- org.apache.iceberg.actions.SizeBasedFileRewriter<PositionDeletesScanTask,DeleteFile>
-
- org.apache.iceberg.actions.SizeBasedPositionDeletesRewriter
-
- All Implemented Interfaces:
FileRewriter<PositionDeletesScanTask,DeleteFile>
public abstract class SizeBasedPositionDeletesRewriter extends SizeBasedFileRewriter<PositionDeletesScanTask,DeleteFile>
-
-
Field Summary
-
Fields inherited from class org.apache.iceberg.actions.SizeBasedFileRewriter
MAX_FILE_GROUP_SIZE_BYTES, MAX_FILE_GROUP_SIZE_BYTES_DEFAULT, MAX_FILE_SIZE_BYTES, MAX_FILE_SIZE_DEFAULT_RATIO, MIN_FILE_SIZE_BYTES, MIN_FILE_SIZE_DEFAULT_RATIO, MIN_INPUT_FILES, MIN_INPUT_FILES_DEFAULT, REWRITE_ALL, REWRITE_ALL_DEFAULT, TARGET_FILE_SIZE_BYTES
-
-
Constructor Summary
Constructors Modifier Constructor Description protected
SizeBasedPositionDeletesRewriter(Table table)
-
Method Summary
All Methods Instance Methods Concrete Methods Modifier and Type Method Description protected long
defaultTargetFileSize()
protected java.lang.Iterable<java.util.List<PositionDeletesScanTask>>
filterFileGroups(java.util.List<java.util.List<PositionDeletesScanTask>> groups)
protected java.lang.Iterable<PositionDeletesScanTask>
filterFiles(java.lang.Iterable<PositionDeletesScanTask> tasks)
-
Methods inherited from class org.apache.iceberg.actions.SizeBasedFileRewriter
enoughContent, enoughInputFiles, init, inputSize, numOutputFiles, outputSpec, outputSpecId, planFileGroups, splitSize, table, tooMuchContent, validOptions, writeMaxFileSize, wronglySized
-
Methods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
-
Methods inherited from interface org.apache.iceberg.actions.FileRewriter
description, rewrite
-
-
-
-
Constructor Detail
-
SizeBasedPositionDeletesRewriter
protected SizeBasedPositionDeletesRewriter(Table table)
-
-
Method Detail
-
filterFiles
protected java.lang.Iterable<PositionDeletesScanTask> filterFiles(java.lang.Iterable<PositionDeletesScanTask> tasks)
- Specified by:
filterFiles
in classSizeBasedFileRewriter<PositionDeletesScanTask,DeleteFile>
-
filterFileGroups
protected java.lang.Iterable<java.util.List<PositionDeletesScanTask>> filterFileGroups(java.util.List<java.util.List<PositionDeletesScanTask>> groups)
- Specified by:
filterFileGroups
in classSizeBasedFileRewriter<PositionDeletesScanTask,DeleteFile>
-
defaultTargetFileSize
protected long defaultTargetFileSize()
- Specified by:
defaultTargetFileSize
in classSizeBasedFileRewriter<PositionDeletesScanTask,DeleteFile>
-
-