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)

Deprecated.
since 1.9.0, will be removed in 1.10.0

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)

List<FileScanTask>

fileScans()

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

int

numFiles()

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

int

outputSpecId()

Set<DataFile>

rewrittenFiles()

void

setOutputFiles(Set<DataFile> files)

long

sizeInBytes()

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

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
  
  @Deprecated public RewriteFileGroup(RewriteDataFiles.FileGroupInfo info, List<FileScanTask> fileScanTasks)
  
  Deprecated.
  since 1.9.0, will be removed in 1.10.0
- RewriteFileGroup
  
  public RewriteFileGroup(RewriteDataFiles.FileGroupInfo info, List<FileScanTask> fileScanTasks, int outputSpecId, long writeMaxFileSize, long inputSplitSize, int expectedOutputFiles)
Method Details
- fileScans
  
  @Deprecated public List<FileScanTask> fileScans()
  
  Deprecated.
  since 1.9.0, will be removed in 1.10.0; use RewriteGroupBase.fileScanTasks()
- setOutputFiles
  
  public void setOutputFiles(Set<DataFile> files)
- rewrittenFiles
  
  public Set<DataFile> rewrittenFiles()
- addedFiles
  
  public Set<DataFile> addedFiles()
- asResult
  
  public RewriteDataFiles.FileGroupRewriteResult asResult()
- toString
  
  public String toString()
  
  Overrides:
  
  toString in class Object
- sizeInBytes
  
  @Deprecated public long sizeInBytes()
  
  Deprecated.
  since 1.9.0, will be removed in 1.10.0; use RewriteGroupBase.inputFilesSizeInBytes()
- numFiles
  
  @Deprecated public int numFiles()
  
  Deprecated.
  since 1.9.0, will be removed in 1.10.0; use RewriteGroupBase.inputFileNum()
- outputSpecId
  
  public int outputSpecId()
- comparator
  
  public static Comparator<RewriteFileGroup> comparator(RewriteJobOrder rewriteJobOrder)