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)	Deprecated. since 1.9.0, will be removed in 1.10.0
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()
int	numRewrittenDeleteFiles()	Deprecated. since 1.9.0, will be removed in 1.10.0; use RewriteGroupBase.inputFileNum()
long	rewrittenBytes()	Deprecated. since 1.9.0, will be removed in 1.10.0; use RewriteGroupBase.inputFilesSizeInBytes()
Set<DeleteFile>	rewrittenDeleteFiles()
void	setOutputFiles(Set<DeleteFile> files)
List<PositionDeletesScanTask>	tasks()	Deprecated. since 1.9.0, will be removed in 1.10.0; use RewriteGroupBase.fileScanTasks()
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

@Deprecated
public RewritePositionDeletesGroup(RewritePositionDeleteFiles.FileGroupInfo info,
 List<PositionDeletesScanTask> tasks)

Deprecated.

since 1.9.0, will be removed in 1.10.0

RewritePositionDeletesGroup

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

Method Details

tasks

@Deprecated
public List<PositionDeletesScanTask> tasks()

Deprecated.

since 1.9.0, will be removed in 1.10.0; use RewriteGroupBase.fileScanTasks()

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

@Deprecated
public long rewrittenBytes()

Deprecated.

since 1.9.0, will be removed in 1.10.0; use RewriteGroupBase.inputFilesSizeInBytes()

addedBytes

public long addedBytes()

numRewrittenDeleteFiles

@Deprecated
public int numRewrittenDeleteFiles()

Deprecated.

since 1.9.0, will be removed in 1.10.0; use RewriteGroupBase.inputFileNum()

comparator

public static Comparator<RewritePositionDeletesGroup> comparator(RewriteJobOrder order)