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 and Description
protected	SizeBasedPositionDeletesRewriter(Table table)

Method Summary

Modifier and Type	Method and 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, 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 class SizeBasedFileRewriter<PositionDeletesScanTask,DeleteFile>

filterFileGroups

protected java.lang.Iterable<java.util.List<PositionDeletesScanTask>> filterFileGroups(java.util.List<java.util.List<PositionDeletesScanTask>> groups)

Specified by:

filterFileGroups in class SizeBasedFileRewriter<PositionDeletesScanTask,DeleteFile>

defaultTargetFileSize

protected long defaultTargetFileSize()

Specified by:

defaultTargetFileSize in class SizeBasedFileRewriter<PositionDeletesScanTask,DeleteFile>