org.apache.iceberg.actions

Class RewritePositionDeletesCommitManager

java.lang.Object

org.apache.iceberg.actions.RewritePositionDeletesCommitManager

public class RewritePositionDeletesCommitManager
extends java.lang.Object

Functionality used by RewritePositionDeleteFiles from different platforms to handle commits.

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
class	RewritePositionDeletesCommitManager.CommitService

Constructor Summary

Constructors

Constructor and Description
RewritePositionDeletesCommitManager(Table table)
RewritePositionDeletesCommitManager(Table table, java.util.Map<java.lang.String,java.lang.String> snapshotProperties)

Method Summary

Modifier and Type	Method and 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(java.util.Set<RewritePositionDeletesGroup> fileGroups) Perform a commit operation on the table adding and removing files as required for this set of file groups.
void	commitOrClean(java.util.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 Detail

RewritePositionDeletesCommitManager

public RewritePositionDeletesCommitManager(Table table)

RewritePositionDeletesCommitManager

public RewritePositionDeletesCommitManager(Table table,
                                           java.util.Map<java.lang.String,java.lang.String> snapshotProperties)

Method Detail

commit

public void commit(java.util.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(java.util.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