Package org.apache.iceberg.actions

Class RewritePositionDeletesGroup

java.lang.Object

org.apache.iceberg.actions.RewriteGroupBase<RewritePositionDeleteFiles.FileGroupInfo,PositionDeletesScanTask,DeleteFile>

org.apache.iceberg.actions.RewritePositionDeletesGroup

public class RewritePositionDeletesGroup
extends RewriteGroupBase<RewritePositionDeleteFiles.FileGroupInfo,PositionDeletesScanTask,DeleteFile>

Container class representing a set of position delete files to be rewritten by a RewritePositionDeleteFiles and the new files which have been written by the action.

Constructor Summary

Constructors

Constructor	Description
RewritePositionDeletesGroup(RewritePositionDeleteFiles.FileGroupInfo info, List<PositionDeletesScanTask> tasks, long writeMaxFileSize, long inputSplitSize, int expectedOutputFiles)

Method Summary

Modifier and Type	Method	Description
long	addedBytes()
Set<DeleteFile>	addedDeleteFiles()
RewritePositionDeleteFiles.FileGroupRewriteResult	asResult()
static Comparator<RewritePositionDeletesGroup>	comparator(RewriteJobOrder order)
long	maxRewrittenDataSequenceNumber()
Set<DeleteFile>	rewrittenDeleteFiles()
void	setOutputFiles(Set<DeleteFile> files)
String	toString()

Methods inherited from class org.apache.iceberg.actions.RewriteGroupBase

expectedOutputFiles, fileScanTasks, info, inputFileNum, inputFilesSizeInBytes, inputSplitSize, maxOutputFileSize

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, wait

Constructor Details

RewritePositionDeletesGroup

public RewritePositionDeletesGroup(RewritePositionDeleteFiles.FileGroupInfo info,
 List<PositionDeletesScanTask> tasks,
 long writeMaxFileSize,
 long inputSplitSize,
 int expectedOutputFiles)

Method Details

setOutputFiles

public void setOutputFiles(Set<DeleteFile> files)

maxRewrittenDataSequenceNumber

public long maxRewrittenDataSequenceNumber()

rewrittenDeleteFiles

public Set<DeleteFile> rewrittenDeleteFiles()

addedDeleteFiles

public Set<DeleteFile> addedDeleteFiles()

asResult

public RewritePositionDeleteFiles.FileGroupRewriteResult asResult()

toString

public String toString()

Overrides:

toString in class Object

addedBytes

public long addedBytes()

comparator

public static Comparator<RewritePositionDeletesGroup> comparator(RewriteJobOrder order)