Package org.apache.iceberg.actions

Class RewriteFileGroup

java.lang.Object

org.apache.iceberg.actions.RewriteGroupBase<RewriteDataFiles.FileGroupInfo,FileScanTask,DataFile>

org.apache.iceberg.actions.RewriteFileGroup

public class RewriteFileGroup
extends RewriteGroupBase<RewriteDataFiles.FileGroupInfo,FileScanTask,DataFile>

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

Constructor Summary

Constructors

Constructor	Description
RewriteFileGroup(RewriteDataFiles.FileGroupInfo info, List<FileScanTask> fileScanTasks, int outputSpecId, long writeMaxFileSize, long inputSplitSize, int expectedOutputFiles)

Method Summary

Modifier and Type	Method	Description
Set<DataFile>	addedFiles()
RewriteDataFiles.FileGroupRewriteResult	asResult()
static Comparator<RewriteFileGroup>	comparator(RewriteJobOrder rewriteJobOrder)
Set<DeleteFile>	danglingDVs()
int	outputSpecId()
Set<DataFile>	rewrittenFiles()
void	setOutputFiles(Set<DataFile> 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

RewriteFileGroup

public RewriteFileGroup(RewriteDataFiles.FileGroupInfo info,
 List<FileScanTask> fileScanTasks,
 int outputSpecId,
 long writeMaxFileSize,
 long inputSplitSize,
 int expectedOutputFiles)

Method Details

setOutputFiles

public void setOutputFiles(Set<DataFile> files)

rewrittenFiles

public Set<DataFile> rewrittenFiles()

danglingDVs

public Set<DeleteFile> danglingDVs()

addedFiles

public Set<DataFile> addedFiles()

asResult

public RewriteDataFiles.FileGroupRewriteResult asResult()

toString

public String toString()

Overrides:

toString in class Object

outputSpecId

public int outputSpecId()

comparator

public static Comparator<RewriteFileGroup> comparator(RewriteJobOrder rewriteJobOrder)