org.apache.iceberg.actions

Class RewriteDataFilesCommitManager.CommitService

java.lang.Object

org.apache.iceberg.actions.RewriteDataFilesCommitManager.CommitService

All Implemented Interfaces:

java.io.Closeable, java.lang.AutoCloseable

Enclosing class:

RewriteDataFilesCommitManager

public class RewriteDataFilesCommitManager.CommitService
extends java.lang.Object
implements java.io.Closeable

Method Summary

Modifier and Type	Method and Description
void	close()
void	offer(RewriteFileGroup group) Places a file group in the queue and commits a batch of file groups if rewritesPerCommit number of file groups are present in the queue.
java.util.List<RewriteFileGroup>	results() Returns all File groups which have been committed
void	start() Starts a single threaded executor service for handling file group commits.

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Method Detail

start

public void start()

Starts a single threaded executor service for handling file group commits.

offer

public void offer(RewriteFileGroup group)

Places a file group in the queue and commits a batch of file groups if rewritesPerCommit number of file groups are present in the queue.

Parameters:

group - file group to eventually be committed

results

public java.util.List<RewriteFileGroup> results()

Returns all File groups which have been committed

close

public void close()

Specified by:

close in interface java.io.Closeable

Specified by:

close in interface java.lang.AutoCloseable