Class RewritePositionDeletesCommitManager


  • public class RewritePositionDeletesCommitManager
    extends java.lang.Object
    Functionality used by RewritePositionDeleteFiles from different platforms to handle commits.
    • 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
      • 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