org.apache.iceberg.actions

Class RewritePositionDeletesGroup

java.lang.Object

org.apache.iceberg.actions.RewritePositionDeletesGroup

public class RewritePositionDeletesGroup
extends java.lang.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 and Description
RewritePositionDeletesGroup(RewritePositionDeleteFiles.FileGroupInfo info, java.util.List<PositionDeletesScanTask> tasks)

Method Summary

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

Methods inherited from class java.lang.Object

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

Constructor Detail

RewritePositionDeletesGroup

public RewritePositionDeletesGroup(RewritePositionDeleteFiles.FileGroupInfo info,
                                   java.util.List<PositionDeletesScanTask> tasks)

Method Detail

info

public RewritePositionDeleteFiles.FileGroupInfo info()

tasks

public java.util.List<PositionDeletesScanTask> tasks()

setOutputFiles

public void setOutputFiles(java.util.Set<DeleteFile> files)

maxRewrittenDataSequenceNumber

public long maxRewrittenDataSequenceNumber()

rewrittenDeleteFiles

public java.util.Set<DeleteFile> rewrittenDeleteFiles()

addedDeleteFiles

public java.util.Set<DeleteFile> addedDeleteFiles()

asResult

public RewritePositionDeleteFiles.FileGroupRewriteResult asResult()

toString

public java.lang.String toString()

Overrides:

toString in class java.lang.Object

rewrittenBytes

public long rewrittenBytes()

addedBytes

public long addedBytes()

numRewrittenDeleteFiles

public int numRewrittenDeleteFiles()

comparator

public static java.util.Comparator<RewritePositionDeletesGroup> comparator(RewriteJobOrder order)