Package org.apache.iceberg.actions

Class RewritePositionDeletesGroup

java.lang.Object

org.apache.iceberg.actions.RewritePositionDeletesGroup

public class RewritePositionDeletesGroup
extends Object

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)

Method Summary

Modifier and Type	Method	Description
long	addedBytes()
Set<DeleteFile>	addedDeleteFiles()
RewritePositionDeleteFiles.FileGroupRewriteResult	asResult()
static Comparator<RewritePositionDeletesGroup>	comparator(RewriteJobOrder order)
RewritePositionDeleteFiles.FileGroupInfo	info()
long	maxRewrittenDataSequenceNumber()
int	numRewrittenDeleteFiles()
long	rewrittenBytes()
Set<DeleteFile>	rewrittenDeleteFiles()
void	setOutputFiles(Set<DeleteFile> files)
List<PositionDeletesScanTask>	tasks()
String	toString()

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)

Method Details

info

public RewritePositionDeleteFiles.FileGroupInfo info()

tasks

public List<PositionDeletesScanTask> tasks()

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

rewrittenBytes

public long rewrittenBytes()

addedBytes

public long addedBytes()

numRewrittenDeleteFiles

public int numRewrittenDeleteFiles()

comparator

public static Comparator<RewritePositionDeletesGroup> comparator(RewriteJobOrder order)