RewritePositionDeletesCommitManager

java.lang.Object

org.apache.iceberg.actions.RewritePositionDeletesCommitManager

public class RewritePositionDeletesCommitManager extends Object

Functionality used by RewritePositionDeleteFiles from different platforms to handle commits.

Nested Class Summary

Nested Classes

Modifier and Type

Class

Description

class

RewritePositionDeletesCommitManager.CommitService
Constructor Summary

Constructors

Constructor

Description

RewritePositionDeletesCommitManager(Table table)

RewritePositionDeletesCommitManager(Table table, Map<String,String> snapshotProperties)
Method Summary

Modifier and Type

Method

Description

void

abort(RewritePositionDeletesGroup fileGroup)

Clean up a specified file set by removing any files created for that operation, should not throw any exceptions.

void

commit(Set<RewritePositionDeletesGroup> fileGroups)

Perform a commit operation on the table adding and removing files as required for this set of file groups.

void

commitOrClean(Set<RewritePositionDeletesGroup> rewriteGroups)

RewritePositionDeletesCommitManager.CommitService

service(int rewritesPerCommit)

An async service which allows for committing multiple file groups as their rewrites complete.

Methods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Details
- RewritePositionDeletesCommitManager
  
  public RewritePositionDeletesCommitManager(Table table)
- RewritePositionDeletesCommitManager
  
  public RewritePositionDeletesCommitManager(Table table, Map<String,String> snapshotProperties)
Method Details
- commit
  
  public void commit(Set<RewritePositionDeletesGroup> fileGroups)
  
  Perform a commit operation on the table adding and removing files as required for this set of file groups.
  
  Parameters:
  
  fileGroups - file groups to commit
- abort
  
  public void abort(RewritePositionDeletesGroup fileGroup)
  
  Clean up a specified file set by removing any files created for that operation, should not throw any exceptions.
  
  Parameters:
  
  fileGroup - group of files which has already been rewritten
- commitOrClean
  
  public void commitOrClean(Set<RewritePositionDeletesGroup> rewriteGroups)
- service
  
  public RewritePositionDeletesCommitManager.CommitService service(int rewritesPerCommit)
  
  An async service which allows for committing multiple file groups as their rewrites complete. The service also allows for partial-progress since commits can fail. Once the service has been closed no new file groups should not be offered.
  
  Parameters:
  
  rewritesPerCommit - number of file groups to include in a commit
  
  Returns:
  
  the service for handling commits