public class RewriteDataFilesCommitManager
extends java.lang.Object
Modifier and Type | Class and Description |
---|---|
class |
RewriteDataFilesCommitManager.CommitService |
Constructor and Description |
---|
RewriteDataFilesCommitManager(Table table) |
RewriteDataFilesCommitManager(Table table,
long startingSnapshotId) |
RewriteDataFilesCommitManager(Table table,
long startingSnapshotId,
boolean useStartingSequenceNumber) |
Modifier and Type | Method and Description |
---|---|
void |
abortFileGroup(RewriteFileGroup fileGroup)
Clean up a specified file set by removing any files created for that operation, should not
throw any exceptions
|
void |
commitFileGroups(java.util.Set<RewriteFileGroup> 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<RewriteFileGroup> rewriteGroups) |
RewriteDataFilesCommitManager.CommitService |
service(int rewritesPerCommit)
An async service which allows for committing multiple file groups as their rewrites complete.
|
public RewriteDataFilesCommitManager(Table table)
public RewriteDataFilesCommitManager(Table table, long startingSnapshotId)
public RewriteDataFilesCommitManager(Table table, long startingSnapshotId, boolean useStartingSequenceNumber)
public void commitFileGroups(java.util.Set<RewriteFileGroup> fileGroups)
fileGroups
- fileSets to commitpublic void abortFileGroup(RewriteFileGroup fileGroup)
fileGroup
- group of files which has already been rewrittenpublic void commitOrClean(java.util.Set<RewriteFileGroup> rewriteGroups)
public RewriteDataFilesCommitManager.CommitService service(int rewritesPerCommit)
rewritesPerCommit
- number of file groups to include in a commit