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

Modifier and Type

Method

Description

protected long

defaultTargetFileSize()

protected Iterable<List<PositionDeletesScanTask>>

filterFileGroups(List<List<PositionDeletesScanTask>> groups)

protected Iterable<PositionDeletesScanTask>

filterFiles(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 Details
- SizeBasedPositionDeletesRewriter
  
  protected SizeBasedPositionDeletesRewriter(Table table)
Method Details
- filterFiles
  
  protected Iterable<PositionDeletesScanTask> filterFiles(Iterable<PositionDeletesScanTask> tasks)
  
  Specified by:
  
  filterFiles in class SizeBasedFileRewriter<PositionDeletesScanTask,DeleteFile>
- filterFileGroups
  
  protected Iterable<List<PositionDeletesScanTask>> filterFileGroups(List<List<PositionDeletesScanTask>> groups)
  
  Specified by:
  
  filterFileGroups in class SizeBasedFileRewriter<PositionDeletesScanTask,DeleteFile>
- defaultTargetFileSize
  
  protected long defaultTargetFileSize()
  
  Specified by:
  
  defaultTargetFileSize in class SizeBasedFileRewriter<PositionDeletesScanTask,DeleteFile>